Source file src/github.com/emissary-ingress/emissary/v3/pkg/api/agent/director.pb.go

Documentation: github.com/emissary-ingress/emissary/v3/pkg/api/agent

     1  //*
     2  // Communication between the Ambassador Agent and the Director service
     3  // to populate the Central Edge Policy Console, which is a cloud service
     4  // run by Datawire.
     5  
     6  // Code generated by protoc-gen-go. DO NOT EDIT.
     7  // versions:
     8  // 	protoc-gen-go v1.28.1
     9  // 	protoc        v3.21.5
    10  // source: agent/director.proto
    11  
    12  package agent
    13  
    14  import (
    15  	_go "github.com/prometheus/client_model/go"
    16  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    17  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    18  	durationpb "google.golang.org/protobuf/types/known/durationpb"
    19  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    20  	reflect "reflect"
    21  	sync "sync"
    22  )
    23  
    24  const (
    25  	// Verify that this generated code is sufficiently up-to-date.
    26  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    27  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    28  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    29  )
    30  
    31  type RolloutCommand_Action int32
    32  
    33  const (
    34  	RolloutCommand_PAUSE  RolloutCommand_Action = 0
    35  	RolloutCommand_RESUME RolloutCommand_Action = 1
    36  	RolloutCommand_ABORT  RolloutCommand_Action = 2
    37  )
    38  
    39  // Enum value maps for RolloutCommand_Action.
    40  var (
    41  	RolloutCommand_Action_name = map[int32]string{
    42  		0: "PAUSE",
    43  		1: "RESUME",
    44  		2: "ABORT",
    45  	}
    46  	RolloutCommand_Action_value = map[string]int32{
    47  		"PAUSE":  0,
    48  		"RESUME": 1,
    49  		"ABORT":  2,
    50  	}
    51  )
    52  
    53  func (x RolloutCommand_Action) Enum() *RolloutCommand_Action {
    54  	p := new(RolloutCommand_Action)
    55  	*p = x
    56  	return p
    57  }
    58  
    59  func (x RolloutCommand_Action) String() string {
    60  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    61  }
    62  
    63  func (RolloutCommand_Action) Descriptor() protoreflect.EnumDescriptor {
    64  	return file_agent_director_proto_enumTypes[0].Descriptor()
    65  }
    66  
    67  func (RolloutCommand_Action) Type() protoreflect.EnumType {
    68  	return &file_agent_director_proto_enumTypes[0]
    69  }
    70  
    71  func (x RolloutCommand_Action) Number() protoreflect.EnumNumber {
    72  	return protoreflect.EnumNumber(x)
    73  }
    74  
    75  // Deprecated: Use RolloutCommand_Action.Descriptor instead.
    76  func (RolloutCommand_Action) EnumDescriptor() ([]byte, []int) {
    77  	return file_agent_director_proto_rawDescGZIP(), []int{10, 0}
    78  }
    79  
    80  type SecretSyncCommand_Action int32
    81  
    82  const (
    83  	SecretSyncCommand_SET    SecretSyncCommand_Action = 0
    84  	SecretSyncCommand_DELETE SecretSyncCommand_Action = 1
    85  )
    86  
    87  // Enum value maps for SecretSyncCommand_Action.
    88  var (
    89  	SecretSyncCommand_Action_name = map[int32]string{
    90  		0: "SET",
    91  		1: "DELETE",
    92  	}
    93  	SecretSyncCommand_Action_value = map[string]int32{
    94  		"SET":    0,
    95  		"DELETE": 1,
    96  	}
    97  )
    98  
    99  func (x SecretSyncCommand_Action) Enum() *SecretSyncCommand_Action {
   100  	p := new(SecretSyncCommand_Action)
   101  	*p = x
   102  	return p
   103  }
   104  
   105  func (x SecretSyncCommand_Action) String() string {
   106  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   107  }
   108  
   109  func (SecretSyncCommand_Action) Descriptor() protoreflect.EnumDescriptor {
   110  	return file_agent_director_proto_enumTypes[1].Descriptor()
   111  }
   112  
   113  func (SecretSyncCommand_Action) Type() protoreflect.EnumType {
   114  	return &file_agent_director_proto_enumTypes[1]
   115  }
   116  
   117  func (x SecretSyncCommand_Action) Number() protoreflect.EnumNumber {
   118  	return protoreflect.EnumNumber(x)
   119  }
   120  
   121  // Deprecated: Use SecretSyncCommand_Action.Descriptor instead.
   122  func (SecretSyncCommand_Action) EnumDescriptor() ([]byte, []int) {
   123  	return file_agent_director_proto_rawDescGZIP(), []int{11, 0}
   124  }
   125  
   126  // How Ambassador's Agent identifies itself to the DCP
   127  // This is the identity of the ambassador the agent is reporting on behalf of
   128  // no user account specific information should be contained in here
   129  type Identity struct {
   130  	state         protoimpl.MessageState
   131  	sizeCache     protoimpl.SizeCache
   132  	unknownFields protoimpl.UnknownFields
   133  
   134  	// The account ID assigned by the DCP
   135  	//
   136  	// Deprecated: Do not use.
   137  	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
   138  	// Ambassador version
   139  	//
   140  	// Deprecated: Do not use.
   141  	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
   142  	// This Ambassador's hostname
   143  	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
   144  	// License information
   145  	License string `protobuf:"bytes,4,opt,name=license,proto3" json:"license,omitempty"`
   146  	// The cluster ID, as determined by Ambassador
   147  	ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
   148  	// Label or description for the user
   149  	//
   150  	// Deprecated: Do not use.
   151  	Label string `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
   152  }
   153  
   154  func (x *Identity) Reset() {
   155  	*x = Identity{}
   156  	if protoimpl.UnsafeEnabled {
   157  		mi := &file_agent_director_proto_msgTypes[0]
   158  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   159  		ms.StoreMessageInfo(mi)
   160  	}
   161  }
   162  
   163  func (x *Identity) String() string {
   164  	return protoimpl.X.MessageStringOf(x)
   165  }
   166  
   167  func (*Identity) ProtoMessage() {}
   168  
   169  func (x *Identity) ProtoReflect() protoreflect.Message {
   170  	mi := &file_agent_director_proto_msgTypes[0]
   171  	if protoimpl.UnsafeEnabled && x != nil {
   172  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   173  		if ms.LoadMessageInfo() == nil {
   174  			ms.StoreMessageInfo(mi)
   175  		}
   176  		return ms
   177  	}
   178  	return mi.MessageOf(x)
   179  }
   180  
   181  // Deprecated: Use Identity.ProtoReflect.Descriptor instead.
   182  func (*Identity) Descriptor() ([]byte, []int) {
   183  	return file_agent_director_proto_rawDescGZIP(), []int{0}
   184  }
   185  
   186  // Deprecated: Do not use.
   187  func (x *Identity) GetAccountId() string {
   188  	if x != nil {
   189  		return x.AccountId
   190  	}
   191  	return ""
   192  }
   193  
   194  // Deprecated: Do not use.
   195  func (x *Identity) GetVersion() string {
   196  	if x != nil {
   197  		return x.Version
   198  	}
   199  	return ""
   200  }
   201  
   202  func (x *Identity) GetHostname() string {
   203  	if x != nil {
   204  		return x.Hostname
   205  	}
   206  	return ""
   207  }
   208  
   209  func (x *Identity) GetLicense() string {
   210  	if x != nil {
   211  		return x.License
   212  	}
   213  	return ""
   214  }
   215  
   216  func (x *Identity) GetClusterId() string {
   217  	if x != nil {
   218  		return x.ClusterId
   219  	}
   220  	return ""
   221  }
   222  
   223  // Deprecated: Do not use.
   224  func (x *Identity) GetLabel() string {
   225  	if x != nil {
   226  		return x.Label
   227  	}
   228  	return ""
   229  }
   230  
   231  // Information that Ambassador's Agent can send to the Director
   232  // component of the DCP
   233  type Snapshot struct {
   234  	state         protoimpl.MessageState
   235  	sizeCache     protoimpl.SizeCache
   236  	unknownFields protoimpl.UnknownFields
   237  
   238  	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
   239  	Message  string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
   240  	// no longer used.
   241  	//
   242  	// Deprecated: Do not use.
   243  	Services    []*Service `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
   244  	RawSnapshot []byte     `protobuf:"bytes,4,opt,name=raw_snapshot,json=rawSnapshot,proto3" json:"raw_snapshot,omitempty"`
   245  	// describes how the raw_snapshot is encoded
   246  	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
   247  	// api version of RawSnapshot
   248  	ApiVersion string                 `protobuf:"bytes,6,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
   249  	SnapshotTs *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
   250  }
   251  
   252  func (x *Snapshot) Reset() {
   253  	*x = Snapshot{}
   254  	if protoimpl.UnsafeEnabled {
   255  		mi := &file_agent_director_proto_msgTypes[1]
   256  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   257  		ms.StoreMessageInfo(mi)
   258  	}
   259  }
   260  
   261  func (x *Snapshot) String() string {
   262  	return protoimpl.X.MessageStringOf(x)
   263  }
   264  
   265  func (*Snapshot) ProtoMessage() {}
   266  
   267  func (x *Snapshot) ProtoReflect() protoreflect.Message {
   268  	mi := &file_agent_director_proto_msgTypes[1]
   269  	if protoimpl.UnsafeEnabled && x != nil {
   270  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   271  		if ms.LoadMessageInfo() == nil {
   272  			ms.StoreMessageInfo(mi)
   273  		}
   274  		return ms
   275  	}
   276  	return mi.MessageOf(x)
   277  }
   278  
   279  // Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.
   280  func (*Snapshot) Descriptor() ([]byte, []int) {
   281  	return file_agent_director_proto_rawDescGZIP(), []int{1}
   282  }
   283  
   284  func (x *Snapshot) GetIdentity() *Identity {
   285  	if x != nil {
   286  		return x.Identity
   287  	}
   288  	return nil
   289  }
   290  
   291  func (x *Snapshot) GetMessage() string {
   292  	if x != nil {
   293  		return x.Message
   294  	}
   295  	return ""
   296  }
   297  
   298  // Deprecated: Do not use.
   299  func (x *Snapshot) GetServices() []*Service {
   300  	if x != nil {
   301  		return x.Services
   302  	}
   303  	return nil
   304  }
   305  
   306  func (x *Snapshot) GetRawSnapshot() []byte {
   307  	if x != nil {
   308  		return x.RawSnapshot
   309  	}
   310  	return nil
   311  }
   312  
   313  func (x *Snapshot) GetContentType() string {
   314  	if x != nil {
   315  		return x.ContentType
   316  	}
   317  	return ""
   318  }
   319  
   320  func (x *Snapshot) GetApiVersion() string {
   321  	if x != nil {
   322  		return x.ApiVersion
   323  	}
   324  	return ""
   325  }
   326  
   327  func (x *Snapshot) GetSnapshotTs() *timestamppb.Timestamp {
   328  	if x != nil {
   329  		return x.SnapshotTs
   330  	}
   331  	return nil
   332  }
   333  
   334  // RawSnapshotChunk is a fragment of a JSON serialization of a
   335  // Snapshot protobuf object.
   336  type RawSnapshotChunk struct {
   337  	state         protoimpl.MessageState
   338  	sizeCache     protoimpl.SizeCache
   339  	unknownFields protoimpl.UnknownFields
   340  
   341  	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
   342  }
   343  
   344  func (x *RawSnapshotChunk) Reset() {
   345  	*x = RawSnapshotChunk{}
   346  	if protoimpl.UnsafeEnabled {
   347  		mi := &file_agent_director_proto_msgTypes[2]
   348  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   349  		ms.StoreMessageInfo(mi)
   350  	}
   351  }
   352  
   353  func (x *RawSnapshotChunk) String() string {
   354  	return protoimpl.X.MessageStringOf(x)
   355  }
   356  
   357  func (*RawSnapshotChunk) ProtoMessage() {}
   358  
   359  func (x *RawSnapshotChunk) ProtoReflect() protoreflect.Message {
   360  	mi := &file_agent_director_proto_msgTypes[2]
   361  	if protoimpl.UnsafeEnabled && x != nil {
   362  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   363  		if ms.LoadMessageInfo() == nil {
   364  			ms.StoreMessageInfo(mi)
   365  		}
   366  		return ms
   367  	}
   368  	return mi.MessageOf(x)
   369  }
   370  
   371  // Deprecated: Use RawSnapshotChunk.ProtoReflect.Descriptor instead.
   372  func (*RawSnapshotChunk) Descriptor() ([]byte, []int) {
   373  	return file_agent_director_proto_rawDescGZIP(), []int{2}
   374  }
   375  
   376  func (x *RawSnapshotChunk) GetChunk() []byte {
   377  	if x != nil {
   378  		return x.Chunk
   379  	}
   380  	return nil
   381  }
   382  
   383  // Diagnostic information from ambassador admin
   384  type Diagnostics struct {
   385  	state         protoimpl.MessageState
   386  	sizeCache     protoimpl.SizeCache
   387  	unknownFields protoimpl.UnknownFields
   388  
   389  	Identity       *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
   390  	Message        string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
   391  	RawDiagnostics []byte    `protobuf:"bytes,3,opt,name=raw_diagnostics,json=rawDiagnostics,proto3" json:"raw_diagnostics,omitempty"`
   392  	// describes how the raw_diagnostic is encoded
   393  	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
   394  	// api version of Diagnostics
   395  	ApiVersion string                 `protobuf:"bytes,5,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
   396  	SnapshotTs *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
   397  }
   398  
   399  func (x *Diagnostics) Reset() {
   400  	*x = Diagnostics{}
   401  	if protoimpl.UnsafeEnabled {
   402  		mi := &file_agent_director_proto_msgTypes[3]
   403  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   404  		ms.StoreMessageInfo(mi)
   405  	}
   406  }
   407  
   408  func (x *Diagnostics) String() string {
   409  	return protoimpl.X.MessageStringOf(x)
   410  }
   411  
   412  func (*Diagnostics) ProtoMessage() {}
   413  
   414  func (x *Diagnostics) ProtoReflect() protoreflect.Message {
   415  	mi := &file_agent_director_proto_msgTypes[3]
   416  	if protoimpl.UnsafeEnabled && x != nil {
   417  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   418  		if ms.LoadMessageInfo() == nil {
   419  			ms.StoreMessageInfo(mi)
   420  		}
   421  		return ms
   422  	}
   423  	return mi.MessageOf(x)
   424  }
   425  
   426  // Deprecated: Use Diagnostics.ProtoReflect.Descriptor instead.
   427  func (*Diagnostics) Descriptor() ([]byte, []int) {
   428  	return file_agent_director_proto_rawDescGZIP(), []int{3}
   429  }
   430  
   431  func (x *Diagnostics) GetIdentity() *Identity {
   432  	if x != nil {
   433  		return x.Identity
   434  	}
   435  	return nil
   436  }
   437  
   438  func (x *Diagnostics) GetMessage() string {
   439  	if x != nil {
   440  		return x.Message
   441  	}
   442  	return ""
   443  }
   444  
   445  func (x *Diagnostics) GetRawDiagnostics() []byte {
   446  	if x != nil {
   447  		return x.RawDiagnostics
   448  	}
   449  	return nil
   450  }
   451  
   452  func (x *Diagnostics) GetContentType() string {
   453  	if x != nil {
   454  		return x.ContentType
   455  	}
   456  	return ""
   457  }
   458  
   459  func (x *Diagnostics) GetApiVersion() string {
   460  	if x != nil {
   461  		return x.ApiVersion
   462  	}
   463  	return ""
   464  }
   465  
   466  func (x *Diagnostics) GetSnapshotTs() *timestamppb.Timestamp {
   467  	if x != nil {
   468  		return x.SnapshotTs
   469  	}
   470  	return nil
   471  }
   472  
   473  // RawDiagnosticChunk is a fragment of a JSON serialization of a
   474  // Diagnostic protobuf object.
   475  type RawDiagnosticsChunk struct {
   476  	state         protoimpl.MessageState
   477  	sizeCache     protoimpl.SizeCache
   478  	unknownFields protoimpl.UnknownFields
   479  
   480  	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
   481  }
   482  
   483  func (x *RawDiagnosticsChunk) Reset() {
   484  	*x = RawDiagnosticsChunk{}
   485  	if protoimpl.UnsafeEnabled {
   486  		mi := &file_agent_director_proto_msgTypes[4]
   487  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   488  		ms.StoreMessageInfo(mi)
   489  	}
   490  }
   491  
   492  func (x *RawDiagnosticsChunk) String() string {
   493  	return protoimpl.X.MessageStringOf(x)
   494  }
   495  
   496  func (*RawDiagnosticsChunk) ProtoMessage() {}
   497  
   498  func (x *RawDiagnosticsChunk) ProtoReflect() protoreflect.Message {
   499  	mi := &file_agent_director_proto_msgTypes[4]
   500  	if protoimpl.UnsafeEnabled && x != nil {
   501  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   502  		if ms.LoadMessageInfo() == nil {
   503  			ms.StoreMessageInfo(mi)
   504  		}
   505  		return ms
   506  	}
   507  	return mi.MessageOf(x)
   508  }
   509  
   510  // Deprecated: Use RawDiagnosticsChunk.ProtoReflect.Descriptor instead.
   511  func (*RawDiagnosticsChunk) Descriptor() ([]byte, []int) {
   512  	return file_agent_director_proto_rawDescGZIP(), []int{4}
   513  }
   514  
   515  func (x *RawDiagnosticsChunk) GetChunk() []byte {
   516  	if x != nil {
   517  		return x.Chunk
   518  	}
   519  	return nil
   520  }
   521  
   522  type Service struct {
   523  	state         protoimpl.MessageState
   524  	sizeCache     protoimpl.SizeCache
   525  	unknownFields protoimpl.UnknownFields
   526  
   527  	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   528  	Namespace   string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
   529  	Labels      map[string]string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
   530  	Annotations map[string]string `protobuf:"bytes,4,rep,name=annotations,proto3" json:"annotations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
   531  }
   532  
   533  func (x *Service) Reset() {
   534  	*x = Service{}
   535  	if protoimpl.UnsafeEnabled {
   536  		mi := &file_agent_director_proto_msgTypes[5]
   537  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   538  		ms.StoreMessageInfo(mi)
   539  	}
   540  }
   541  
   542  func (x *Service) String() string {
   543  	return protoimpl.X.MessageStringOf(x)
   544  }
   545  
   546  func (*Service) ProtoMessage() {}
   547  
   548  func (x *Service) ProtoReflect() protoreflect.Message {
   549  	mi := &file_agent_director_proto_msgTypes[5]
   550  	if protoimpl.UnsafeEnabled && x != nil {
   551  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   552  		if ms.LoadMessageInfo() == nil {
   553  			ms.StoreMessageInfo(mi)
   554  		}
   555  		return ms
   556  	}
   557  	return mi.MessageOf(x)
   558  }
   559  
   560  // Deprecated: Use Service.ProtoReflect.Descriptor instead.
   561  func (*Service) Descriptor() ([]byte, []int) {
   562  	return file_agent_director_proto_rawDescGZIP(), []int{5}
   563  }
   564  
   565  func (x *Service) GetName() string {
   566  	if x != nil {
   567  		return x.Name
   568  	}
   569  	return ""
   570  }
   571  
   572  func (x *Service) GetNamespace() string {
   573  	if x != nil {
   574  		return x.Namespace
   575  	}
   576  	return ""
   577  }
   578  
   579  func (x *Service) GetLabels() map[string]string {
   580  	if x != nil {
   581  		return x.Labels
   582  	}
   583  	return nil
   584  }
   585  
   586  func (x *Service) GetAnnotations() map[string]string {
   587  	if x != nil {
   588  		return x.Annotations
   589  	}
   590  	return nil
   591  }
   592  
   593  // The Director's response to a Snapshot from the Agent
   594  type SnapshotResponse struct {
   595  	state         protoimpl.MessageState
   596  	sizeCache     protoimpl.SizeCache
   597  	unknownFields protoimpl.UnknownFields
   598  }
   599  
   600  func (x *SnapshotResponse) Reset() {
   601  	*x = SnapshotResponse{}
   602  	if protoimpl.UnsafeEnabled {
   603  		mi := &file_agent_director_proto_msgTypes[6]
   604  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   605  		ms.StoreMessageInfo(mi)
   606  	}
   607  }
   608  
   609  func (x *SnapshotResponse) String() string {
   610  	return protoimpl.X.MessageStringOf(x)
   611  }
   612  
   613  func (*SnapshotResponse) ProtoMessage() {}
   614  
   615  func (x *SnapshotResponse) ProtoReflect() protoreflect.Message {
   616  	mi := &file_agent_director_proto_msgTypes[6]
   617  	if protoimpl.UnsafeEnabled && x != nil {
   618  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   619  		if ms.LoadMessageInfo() == nil {
   620  			ms.StoreMessageInfo(mi)
   621  		}
   622  		return ms
   623  	}
   624  	return mi.MessageOf(x)
   625  }
   626  
   627  // Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.
   628  func (*SnapshotResponse) Descriptor() ([]byte, []int) {
   629  	return file_agent_director_proto_rawDescGZIP(), []int{6}
   630  }
   631  
   632  // The Director's response to a Diagnostics message from the Agent
   633  type DiagnosticsResponse struct {
   634  	state         protoimpl.MessageState
   635  	sizeCache     protoimpl.SizeCache
   636  	unknownFields protoimpl.UnknownFields
   637  }
   638  
   639  func (x *DiagnosticsResponse) Reset() {
   640  	*x = DiagnosticsResponse{}
   641  	if protoimpl.UnsafeEnabled {
   642  		mi := &file_agent_director_proto_msgTypes[7]
   643  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   644  		ms.StoreMessageInfo(mi)
   645  	}
   646  }
   647  
   648  func (x *DiagnosticsResponse) String() string {
   649  	return protoimpl.X.MessageStringOf(x)
   650  }
   651  
   652  func (*DiagnosticsResponse) ProtoMessage() {}
   653  
   654  func (x *DiagnosticsResponse) ProtoReflect() protoreflect.Message {
   655  	mi := &file_agent_director_proto_msgTypes[7]
   656  	if protoimpl.UnsafeEnabled && x != nil {
   657  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   658  		if ms.LoadMessageInfo() == nil {
   659  			ms.StoreMessageInfo(mi)
   660  		}
   661  		return ms
   662  	}
   663  	return mi.MessageOf(x)
   664  }
   665  
   666  // Deprecated: Use DiagnosticsResponse.ProtoReflect.Descriptor instead.
   667  func (*DiagnosticsResponse) Descriptor() ([]byte, []int) {
   668  	return file_agent_director_proto_rawDescGZIP(), []int{7}
   669  }
   670  
   671  // Instructions that the DCP can send to Ambassador
   672  type Directive struct {
   673  	state         protoimpl.MessageState
   674  	sizeCache     protoimpl.SizeCache
   675  	unknownFields protoimpl.UnknownFields
   676  
   677  	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
   678  	// Stop sending snapshots. The default value (false) indicates that
   679  	// snapshot should be sent.
   680  	StopReporting bool `protobuf:"varint,2,opt,name=stop_reporting,json=stopReporting,proto3" json:"stop_reporting,omitempty"`
   681  	// Minimum time to wait before pushing the next snapshot. The default
   682  	// value (zero duration) indicates that the Agent should not modify
   683  	// the existing report period.
   684  	MinReportPeriod *durationpb.Duration `protobuf:"bytes,3,opt,name=min_report_period,json=minReportPeriod,proto3" json:"min_report_period,omitempty"`
   685  	// Commands to execute
   686  	Commands []*Command `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"`
   687  }
   688  
   689  func (x *Directive) Reset() {
   690  	*x = Directive{}
   691  	if protoimpl.UnsafeEnabled {
   692  		mi := &file_agent_director_proto_msgTypes[8]
   693  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   694  		ms.StoreMessageInfo(mi)
   695  	}
   696  }
   697  
   698  func (x *Directive) String() string {
   699  	return protoimpl.X.MessageStringOf(x)
   700  }
   701  
   702  func (*Directive) ProtoMessage() {}
   703  
   704  func (x *Directive) ProtoReflect() protoreflect.Message {
   705  	mi := &file_agent_director_proto_msgTypes[8]
   706  	if protoimpl.UnsafeEnabled && x != nil {
   707  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   708  		if ms.LoadMessageInfo() == nil {
   709  			ms.StoreMessageInfo(mi)
   710  		}
   711  		return ms
   712  	}
   713  	return mi.MessageOf(x)
   714  }
   715  
   716  // Deprecated: Use Directive.ProtoReflect.Descriptor instead.
   717  func (*Directive) Descriptor() ([]byte, []int) {
   718  	return file_agent_director_proto_rawDescGZIP(), []int{8}
   719  }
   720  
   721  func (x *Directive) GetID() string {
   722  	if x != nil {
   723  		return x.ID
   724  	}
   725  	return ""
   726  }
   727  
   728  func (x *Directive) GetStopReporting() bool {
   729  	if x != nil {
   730  		return x.StopReporting
   731  	}
   732  	return false
   733  }
   734  
   735  func (x *Directive) GetMinReportPeriod() *durationpb.Duration {
   736  	if x != nil {
   737  		return x.MinReportPeriod
   738  	}
   739  	return nil
   740  }
   741  
   742  func (x *Directive) GetCommands() []*Command {
   743  	if x != nil {
   744  		return x.Commands
   745  	}
   746  	return nil
   747  }
   748  
   749  // An individual instruction from the DCP
   750  type Command struct {
   751  	state         protoimpl.MessageState
   752  	sizeCache     protoimpl.SizeCache
   753  	unknownFields protoimpl.UnknownFields
   754  
   755  	// Log this message if present
   756  	Message           string             `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
   757  	RolloutCommand    *RolloutCommand    `protobuf:"bytes,2,opt,name=rolloutCommand,proto3" json:"rolloutCommand,omitempty"`
   758  	SecretSyncCommand *SecretSyncCommand `protobuf:"bytes,3,opt,name=secretSyncCommand,proto3" json:"secretSyncCommand,omitempty"`
   759  }
   760  
   761  func (x *Command) Reset() {
   762  	*x = Command{}
   763  	if protoimpl.UnsafeEnabled {
   764  		mi := &file_agent_director_proto_msgTypes[9]
   765  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   766  		ms.StoreMessageInfo(mi)
   767  	}
   768  }
   769  
   770  func (x *Command) String() string {
   771  	return protoimpl.X.MessageStringOf(x)
   772  }
   773  
   774  func (*Command) ProtoMessage() {}
   775  
   776  func (x *Command) ProtoReflect() protoreflect.Message {
   777  	mi := &file_agent_director_proto_msgTypes[9]
   778  	if protoimpl.UnsafeEnabled && x != nil {
   779  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   780  		if ms.LoadMessageInfo() == nil {
   781  			ms.StoreMessageInfo(mi)
   782  		}
   783  		return ms
   784  	}
   785  	return mi.MessageOf(x)
   786  }
   787  
   788  // Deprecated: Use Command.ProtoReflect.Descriptor instead.
   789  func (*Command) Descriptor() ([]byte, []int) {
   790  	return file_agent_director_proto_rawDescGZIP(), []int{9}
   791  }
   792  
   793  func (x *Command) GetMessage() string {
   794  	if x != nil {
   795  		return x.Message
   796  	}
   797  	return ""
   798  }
   799  
   800  func (x *Command) GetRolloutCommand() *RolloutCommand {
   801  	if x != nil {
   802  		return x.RolloutCommand
   803  	}
   804  	return nil
   805  }
   806  
   807  func (x *Command) GetSecretSyncCommand() *SecretSyncCommand {
   808  	if x != nil {
   809  		return x.SecretSyncCommand
   810  	}
   811  	return nil
   812  }
   813  
   814  type RolloutCommand struct {
   815  	state         protoimpl.MessageState
   816  	sizeCache     protoimpl.SizeCache
   817  	unknownFields protoimpl.UnknownFields
   818  
   819  	Name      string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   820  	Namespace string                `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
   821  	Action    RolloutCommand_Action `protobuf:"varint,3,opt,name=action,proto3,enum=agent.RolloutCommand_Action" json:"action,omitempty"`
   822  	CommandId string                `protobuf:"bytes,4,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
   823  }
   824  
   825  func (x *RolloutCommand) Reset() {
   826  	*x = RolloutCommand{}
   827  	if protoimpl.UnsafeEnabled {
   828  		mi := &file_agent_director_proto_msgTypes[10]
   829  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   830  		ms.StoreMessageInfo(mi)
   831  	}
   832  }
   833  
   834  func (x *RolloutCommand) String() string {
   835  	return protoimpl.X.MessageStringOf(x)
   836  }
   837  
   838  func (*RolloutCommand) ProtoMessage() {}
   839  
   840  func (x *RolloutCommand) ProtoReflect() protoreflect.Message {
   841  	mi := &file_agent_director_proto_msgTypes[10]
   842  	if protoimpl.UnsafeEnabled && x != nil {
   843  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   844  		if ms.LoadMessageInfo() == nil {
   845  			ms.StoreMessageInfo(mi)
   846  		}
   847  		return ms
   848  	}
   849  	return mi.MessageOf(x)
   850  }
   851  
   852  // Deprecated: Use RolloutCommand.ProtoReflect.Descriptor instead.
   853  func (*RolloutCommand) Descriptor() ([]byte, []int) {
   854  	return file_agent_director_proto_rawDescGZIP(), []int{10}
   855  }
   856  
   857  func (x *RolloutCommand) GetName() string {
   858  	if x != nil {
   859  		return x.Name
   860  	}
   861  	return ""
   862  }
   863  
   864  func (x *RolloutCommand) GetNamespace() string {
   865  	if x != nil {
   866  		return x.Namespace
   867  	}
   868  	return ""
   869  }
   870  
   871  func (x *RolloutCommand) GetAction() RolloutCommand_Action {
   872  	if x != nil {
   873  		return x.Action
   874  	}
   875  	return RolloutCommand_PAUSE
   876  }
   877  
   878  func (x *RolloutCommand) GetCommandId() string {
   879  	if x != nil {
   880  		return x.CommandId
   881  	}
   882  	return ""
   883  }
   884  
   885  type SecretSyncCommand struct {
   886  	state         protoimpl.MessageState
   887  	sizeCache     protoimpl.SizeCache
   888  	unknownFields protoimpl.UnknownFields
   889  
   890  	Name      string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   891  	Namespace string                   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
   892  	CommandId string                   `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
   893  	Action    SecretSyncCommand_Action `protobuf:"varint,4,opt,name=action,proto3,enum=agent.SecretSyncCommand_Action" json:"action,omitempty"`
   894  	Secret    map[string][]byte        `protobuf:"bytes,5,rep,name=secret,proto3" json:"secret,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
   895  }
   896  
   897  func (x *SecretSyncCommand) Reset() {
   898  	*x = SecretSyncCommand{}
   899  	if protoimpl.UnsafeEnabled {
   900  		mi := &file_agent_director_proto_msgTypes[11]
   901  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   902  		ms.StoreMessageInfo(mi)
   903  	}
   904  }
   905  
   906  func (x *SecretSyncCommand) String() string {
   907  	return protoimpl.X.MessageStringOf(x)
   908  }
   909  
   910  func (*SecretSyncCommand) ProtoMessage() {}
   911  
   912  func (x *SecretSyncCommand) ProtoReflect() protoreflect.Message {
   913  	mi := &file_agent_director_proto_msgTypes[11]
   914  	if protoimpl.UnsafeEnabled && x != nil {
   915  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   916  		if ms.LoadMessageInfo() == nil {
   917  			ms.StoreMessageInfo(mi)
   918  		}
   919  		return ms
   920  	}
   921  	return mi.MessageOf(x)
   922  }
   923  
   924  // Deprecated: Use SecretSyncCommand.ProtoReflect.Descriptor instead.
   925  func (*SecretSyncCommand) Descriptor() ([]byte, []int) {
   926  	return file_agent_director_proto_rawDescGZIP(), []int{11}
   927  }
   928  
   929  func (x *SecretSyncCommand) GetName() string {
   930  	if x != nil {
   931  		return x.Name
   932  	}
   933  	return ""
   934  }
   935  
   936  func (x *SecretSyncCommand) GetNamespace() string {
   937  	if x != nil {
   938  		return x.Namespace
   939  	}
   940  	return ""
   941  }
   942  
   943  func (x *SecretSyncCommand) GetCommandId() string {
   944  	if x != nil {
   945  		return x.CommandId
   946  	}
   947  	return ""
   948  }
   949  
   950  func (x *SecretSyncCommand) GetAction() SecretSyncCommand_Action {
   951  	if x != nil {
   952  		return x.Action
   953  	}
   954  	return SecretSyncCommand_SET
   955  }
   956  
   957  func (x *SecretSyncCommand) GetSecret() map[string][]byte {
   958  	if x != nil {
   959  		return x.Secret
   960  	}
   961  	return nil
   962  }
   963  
   964  type CommandResult struct {
   965  	state         protoimpl.MessageState
   966  	sizeCache     protoimpl.SizeCache
   967  	unknownFields protoimpl.UnknownFields
   968  
   969  	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
   970  	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
   971  	Message   string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
   972  }
   973  
   974  func (x *CommandResult) Reset() {
   975  	*x = CommandResult{}
   976  	if protoimpl.UnsafeEnabled {
   977  		mi := &file_agent_director_proto_msgTypes[12]
   978  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   979  		ms.StoreMessageInfo(mi)
   980  	}
   981  }
   982  
   983  func (x *CommandResult) String() string {
   984  	return protoimpl.X.MessageStringOf(x)
   985  }
   986  
   987  func (*CommandResult) ProtoMessage() {}
   988  
   989  func (x *CommandResult) ProtoReflect() protoreflect.Message {
   990  	mi := &file_agent_director_proto_msgTypes[12]
   991  	if protoimpl.UnsafeEnabled && x != nil {
   992  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   993  		if ms.LoadMessageInfo() == nil {
   994  			ms.StoreMessageInfo(mi)
   995  		}
   996  		return ms
   997  	}
   998  	return mi.MessageOf(x)
   999  }
  1000  
  1001  // Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.
  1002  func (*CommandResult) Descriptor() ([]byte, []int) {
  1003  	return file_agent_director_proto_rawDescGZIP(), []int{12}
  1004  }
  1005  
  1006  func (x *CommandResult) GetCommandId() string {
  1007  	if x != nil {
  1008  		return x.CommandId
  1009  	}
  1010  	return ""
  1011  }
  1012  
  1013  func (x *CommandResult) GetSuccess() bool {
  1014  	if x != nil {
  1015  		return x.Success
  1016  	}
  1017  	return false
  1018  }
  1019  
  1020  func (x *CommandResult) GetMessage() string {
  1021  	if x != nil {
  1022  		return x.Message
  1023  	}
  1024  	return ""
  1025  }
  1026  
  1027  type CommandResultResponse struct {
  1028  	state         protoimpl.MessageState
  1029  	sizeCache     protoimpl.SizeCache
  1030  	unknownFields protoimpl.UnknownFields
  1031  }
  1032  
  1033  func (x *CommandResultResponse) Reset() {
  1034  	*x = CommandResultResponse{}
  1035  	if protoimpl.UnsafeEnabled {
  1036  		mi := &file_agent_director_proto_msgTypes[13]
  1037  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1038  		ms.StoreMessageInfo(mi)
  1039  	}
  1040  }
  1041  
  1042  func (x *CommandResultResponse) String() string {
  1043  	return protoimpl.X.MessageStringOf(x)
  1044  }
  1045  
  1046  func (*CommandResultResponse) ProtoMessage() {}
  1047  
  1048  func (x *CommandResultResponse) ProtoReflect() protoreflect.Message {
  1049  	mi := &file_agent_director_proto_msgTypes[13]
  1050  	if protoimpl.UnsafeEnabled && x != nil {
  1051  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1052  		if ms.LoadMessageInfo() == nil {
  1053  			ms.StoreMessageInfo(mi)
  1054  		}
  1055  		return ms
  1056  	}
  1057  	return mi.MessageOf(x)
  1058  }
  1059  
  1060  // Deprecated: Use CommandResultResponse.ProtoReflect.Descriptor instead.
  1061  func (*CommandResultResponse) Descriptor() ([]byte, []int) {
  1062  	return file_agent_director_proto_rawDescGZIP(), []int{13}
  1063  }
  1064  
  1065  type StreamMetricsMessage struct {
  1066  	state         protoimpl.MessageState
  1067  	sizeCache     protoimpl.SizeCache
  1068  	unknownFields protoimpl.UnknownFields
  1069  
  1070  	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
  1071  	// A list of metric entries
  1072  	EnvoyMetrics []*_go.MetricFamily `protobuf:"bytes,2,rep,name=envoy_metrics,json=envoyMetrics,proto3" json:"envoy_metrics,omitempty"`
  1073  }
  1074  
  1075  func (x *StreamMetricsMessage) Reset() {
  1076  	*x = StreamMetricsMessage{}
  1077  	if protoimpl.UnsafeEnabled {
  1078  		mi := &file_agent_director_proto_msgTypes[14]
  1079  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1080  		ms.StoreMessageInfo(mi)
  1081  	}
  1082  }
  1083  
  1084  func (x *StreamMetricsMessage) String() string {
  1085  	return protoimpl.X.MessageStringOf(x)
  1086  }
  1087  
  1088  func (*StreamMetricsMessage) ProtoMessage() {}
  1089  
  1090  func (x *StreamMetricsMessage) ProtoReflect() protoreflect.Message {
  1091  	mi := &file_agent_director_proto_msgTypes[14]
  1092  	if protoimpl.UnsafeEnabled && x != nil {
  1093  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1094  		if ms.LoadMessageInfo() == nil {
  1095  			ms.StoreMessageInfo(mi)
  1096  		}
  1097  		return ms
  1098  	}
  1099  	return mi.MessageOf(x)
  1100  }
  1101  
  1102  // Deprecated: Use StreamMetricsMessage.ProtoReflect.Descriptor instead.
  1103  func (*StreamMetricsMessage) Descriptor() ([]byte, []int) {
  1104  	return file_agent_director_proto_rawDescGZIP(), []int{14}
  1105  }
  1106  
  1107  func (x *StreamMetricsMessage) GetIdentity() *Identity {
  1108  	if x != nil {
  1109  		return x.Identity
  1110  	}
  1111  	return nil
  1112  }
  1113  
  1114  func (x *StreamMetricsMessage) GetEnvoyMetrics() []*_go.MetricFamily {
  1115  	if x != nil {
  1116  		return x.EnvoyMetrics
  1117  	}
  1118  	return nil
  1119  }
  1120  
  1121  type StreamMetricsResponse struct {
  1122  	state         protoimpl.MessageState
  1123  	sizeCache     protoimpl.SizeCache
  1124  	unknownFields protoimpl.UnknownFields
  1125  }
  1126  
  1127  func (x *StreamMetricsResponse) Reset() {
  1128  	*x = StreamMetricsResponse{}
  1129  	if protoimpl.UnsafeEnabled {
  1130  		mi := &file_agent_director_proto_msgTypes[15]
  1131  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1132  		ms.StoreMessageInfo(mi)
  1133  	}
  1134  }
  1135  
  1136  func (x *StreamMetricsResponse) String() string {
  1137  	return protoimpl.X.MessageStringOf(x)
  1138  }
  1139  
  1140  func (*StreamMetricsResponse) ProtoMessage() {}
  1141  
  1142  func (x *StreamMetricsResponse) ProtoReflect() protoreflect.Message {
  1143  	mi := &file_agent_director_proto_msgTypes[15]
  1144  	if protoimpl.UnsafeEnabled && x != nil {
  1145  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1146  		if ms.LoadMessageInfo() == nil {
  1147  			ms.StoreMessageInfo(mi)
  1148  		}
  1149  		return ms
  1150  	}
  1151  	return mi.MessageOf(x)
  1152  }
  1153  
  1154  // Deprecated: Use StreamMetricsResponse.ProtoReflect.Descriptor instead.
  1155  func (*StreamMetricsResponse) Descriptor() ([]byte, []int) {
  1156  	return file_agent_director_proto_rawDescGZIP(), []int{15}
  1157  }
  1158  
  1159  var File_agent_director_proto protoreflect.FileDescriptor
  1160  
  1161  var file_agent_director_proto_rawDesc = []byte{
  1162  	0x0a, 0x14, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2f, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x6f, 0x72,
  1163  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x1a, 0x1e, 0x67,
  1164  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64,
  1165  	0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
  1166  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74,
  1167  	0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x18,
  1168  	0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2f, 0x6d, 0x65, 0x74, 0x72, 0x69,
  1169  	0x63, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xba, 0x01, 0x0a, 0x08, 0x49, 0x64, 0x65,
  1170  	0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x21, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
  1171  	0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x09, 0x61,
  1172  	0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73,
  1173  	0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x07, 0x76,
  1174  	0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61,
  1175  	0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61,
  1176  	0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65, 0x18, 0x04, 0x20,
  1177  	0x01, 0x28, 0x09, 0x52, 0x07, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65, 0x12, 0x1d, 0x0a, 0x0a,
  1178  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09,
  1179  	0x52, 0x09, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x05, 0x6c,
  1180  	0x61, 0x62, 0x65, 0x6c, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x05,
  1181  	0x6c, 0x61, 0x62, 0x65, 0x6c, 0x22, 0xa5, 0x02, 0x0a, 0x08, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
  1182  	0x6f, 0x74, 0x12, 0x2b, 0x0a, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x01,
  1183  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65,
  1184  	0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12,
  1185  	0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
  1186  	0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x2e, 0x0a, 0x08, 0x73, 0x65, 0x72,
  1187  	0x76, 0x69, 0x63, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x61, 0x67,
  1188  	0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x42, 0x02, 0x18, 0x01, 0x52,
  1189  	0x08, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x61, 0x77,
  1190  	0x5f, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52,
  1191  	0x0b, 0x72, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x12, 0x21, 0x0a, 0x0c,
  1192  	0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01,
  1193  	0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12,
  1194  	0x1f, 0x0a, 0x0b, 0x61, 0x70, 0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x06,
  1195  	0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x70, 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
  1196  	0x12, 0x3b, 0x0a, 0x0b, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x73, 0x18,
  1197  	0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
  1198  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
  1199  	0x70, 0x52, 0x0a, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x73, 0x22, 0x28, 0x0a,
  1200  	0x10, 0x52, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x43, 0x68, 0x75, 0x6e,
  1201  	0x6b, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c,
  1202  	0x52, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x22, 0xfe, 0x01, 0x0a, 0x0b, 0x44, 0x69, 0x61, 0x67,
  1203  	0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x12, 0x2b, 0x0a, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74,
  1204  	0x69, 0x74, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e,
  1205  	0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x08, 0x69, 0x64, 0x65, 0x6e,
  1206  	0x74, 0x69, 0x74, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18,
  1207  	0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x27,
  1208  	0x0a, 0x0f, 0x72, 0x61, 0x77, 0x5f, 0x64, 0x69, 0x61, 0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63,
  1209  	0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0e, 0x72, 0x61, 0x77, 0x44, 0x69, 0x61, 0x67,
  1210  	0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x65,
  1211  	0x6e, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63,
  1212  	0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x70,
  1213  	0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52,
  1214  	0x0a, 0x61, 0x70, 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3b, 0x0a, 0x0b, 0x73,
  1215  	0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b,
  1216  	0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1217  	0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x73, 0x6e,
  1218  	0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x73, 0x22, 0x2b, 0x0a, 0x13, 0x52, 0x61, 0x77, 0x44,
  1219  	0x69, 0x61, 0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x12,
  1220  	0x14, 0x0a, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05,
  1221  	0x63, 0x68, 0x75, 0x6e, 0x6b, 0x22, 0xad, 0x02, 0x0a, 0x07, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
  1222  	0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
  1223  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61,
  1224  	0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70,
  1225  	0x61, 0x63, 0x65, 0x12, 0x32, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x03, 0x20,
  1226  	0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76,
  1227  	0x69, 0x63, 0x65, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52,
  1228  	0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x41, 0x0a, 0x0b, 0x61, 0x6e, 0x6e, 0x6f, 0x74,
  1229  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x61,
  1230  	0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x41, 0x6e, 0x6e,
  1231  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0b, 0x61,
  1232  	0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61,
  1233  	0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
  1234  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76,
  1235  	0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
  1236  	0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x3e, 0x0a, 0x10, 0x41, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74,
  1237  	0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
  1238  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76,
  1239  	0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
  1240  	0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x12, 0x0a, 0x10, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f,
  1241  	0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x15, 0x0a, 0x13, 0x44, 0x69, 0x61,
  1242  	0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1243  	0x22, 0xb5, 0x01, 0x0a, 0x09, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x76, 0x65, 0x12, 0x0e,
  1244  	0x0a, 0x02, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x49, 0x44, 0x12, 0x25,
  1245  	0x0a, 0x0e, 0x73, 0x74, 0x6f, 0x70, 0x5f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x69, 0x6e, 0x67,
  1246  	0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x73, 0x74, 0x6f, 0x70, 0x52, 0x65, 0x70, 0x6f,
  1247  	0x72, 0x74, 0x69, 0x6e, 0x67, 0x12, 0x45, 0x0a, 0x11, 0x6d, 0x69, 0x6e, 0x5f, 0x72, 0x65, 0x70,
  1248  	0x6f, 0x72, 0x74, 0x5f, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b,
  1249  	0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
  1250  	0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0f, 0x6d, 0x69, 0x6e,
  1251  	0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x50, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x12, 0x2a, 0x0a, 0x08,
  1252  	0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0e,
  1253  	0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x08,
  1254  	0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x73, 0x22, 0xaa, 0x01, 0x0a, 0x07, 0x43, 0x6f, 0x6d,
  1255  	0x6d, 0x61, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18,
  1256  	0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x3d,
  1257  	0x0a, 0x0e, 0x72, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64,
  1258  	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x52,
  1259  	0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x0e, 0x72,
  1260  	0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x46, 0x0a,
  1261  	0x11, 0x73, 0x65, 0x63, 0x72, 0x65, 0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f, 0x6d, 0x6d, 0x61,
  1262  	0x6e, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74,
  1263  	0x2e, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f, 0x6d, 0x6d, 0x61,
  1264  	0x6e, 0x64, 0x52, 0x11, 0x73, 0x65, 0x63, 0x72, 0x65, 0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f,
  1265  	0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0e, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75,
  1266  	0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1267  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09,
  1268  	0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
  1269  	0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x34, 0x0a, 0x06, 0x61, 0x63,
  1270  	0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x61, 0x67, 0x65,
  1271  	0x6e, 0x74, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e,
  1272  	0x64, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e,
  1273  	0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x04,
  1274  	0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x49, 0x64, 0x22,
  1275  	0x2a, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05, 0x50, 0x41, 0x55,
  1276  	0x53, 0x45, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x52, 0x45, 0x53, 0x55, 0x4d, 0x45, 0x10, 0x01,
  1277  	0x12, 0x09, 0x0a, 0x05, 0x41, 0x42, 0x4f, 0x52, 0x54, 0x10, 0x02, 0x22, 0xb5, 0x02, 0x0a, 0x11,
  1278  	0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e,
  1279  	0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
  1280  	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61,
  1281  	0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70,
  1282  	0x61, 0x63, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x5f, 0x69,
  1283  	0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64,
  1284  	0x49, 0x64, 0x12, 0x37, 0x0a, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01,
  1285  	0x28, 0x0e, 0x32, 0x1f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x63, 0x72, 0x65,
  1286  	0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x2e, 0x41, 0x63, 0x74,
  1287  	0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3c, 0x0a, 0x06, 0x73,
  1288  	0x65, 0x63, 0x72, 0x65, 0x74, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x61, 0x67,
  1289  	0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x53, 0x79, 0x6e, 0x63, 0x43, 0x6f,
  1290  	0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x2e, 0x53, 0x65, 0x63, 0x72, 0x65, 0x74, 0x45, 0x6e, 0x74, 0x72,
  1291  	0x79, 0x52, 0x06, 0x73, 0x65, 0x63, 0x72, 0x65, 0x74, 0x1a, 0x39, 0x0a, 0x0b, 0x53, 0x65, 0x63,
  1292  	0x72, 0x65, 0x74, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18,
  1293  	0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61,
  1294  	0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65,
  1295  	0x3a, 0x02, 0x38, 0x01, 0x22, 0x1d, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x07,
  1296  	0x0a, 0x03, 0x53, 0x45, 0x54, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x44, 0x45, 0x4c, 0x45, 0x54,
  1297  	0x45, 0x10, 0x01, 0x22, 0x62, 0x0a, 0x0d, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65,
  1298  	0x73, 0x75, 0x6c, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x5f,
  1299  	0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e,
  1300  	0x64, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x02,
  1301  	0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x18, 0x0a,
  1302  	0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
  1303  	0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0x17, 0x0a, 0x15, 0x43, 0x6f, 0x6d, 0x6d, 0x61,
  1304  	0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1305  	0x22, 0x8c, 0x01, 0x0a, 0x14, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69,
  1306  	0x63, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x2b, 0x0a, 0x08, 0x69, 0x64, 0x65,
  1307  	0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x61, 0x67,
  1308  	0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x08, 0x69, 0x64,
  1309  	0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x47, 0x0a, 0x0d, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x5f,
  1310  	0x6d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22, 0x2e,
  1311  	0x69, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x63, 0x6c,
  1312  	0x69, 0x65, 0x6e, 0x74, 0x2e, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x46, 0x61, 0x6d, 0x69, 0x6c,
  1313  	0x79, 0x52, 0x0c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x22,
  1314  	0x17, 0x0a, 0x15, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73,
  1315  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xaa, 0x03, 0x0a, 0x08, 0x44, 0x69, 0x72,
  1316  	0x65, 0x63, 0x74, 0x6f, 0x72, 0x12, 0x37, 0x0a, 0x06, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x12,
  1317  	0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74,
  1318  	0x1a, 0x17, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f,
  1319  	0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x03, 0x88, 0x02, 0x01, 0x12, 0x44,
  1320  	0x0a, 0x0c, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17,
  1321  	0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
  1322  	0x6f, 0x74, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x1a, 0x17, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e,
  1323  	0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1324  	0x22, 0x00, 0x28, 0x01, 0x12, 0x4f, 0x0a, 0x11, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x44, 0x69,
  1325  	0x61, 0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x12, 0x1a, 0x2e, 0x61, 0x67, 0x65, 0x6e,
  1326  	0x74, 0x2e, 0x52, 0x61, 0x77, 0x44, 0x69, 0x61, 0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73,
  1327  	0x43, 0x68, 0x75, 0x6e, 0x6b, 0x1a, 0x1a, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x44, 0x69,
  1328  	0x61, 0x67, 0x6e, 0x6f, 0x73, 0x74, 0x69, 0x63, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1329  	0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x4e, 0x0a, 0x0d, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d,
  1330  	0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x12, 0x1b, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53,
  1331  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x4d, 0x65, 0x73, 0x73,
  1332  	0x61, 0x67, 0x65, 0x1a, 0x1c, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x74, 0x72, 0x65,
  1333  	0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1334  	0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x31, 0x0a, 0x08, 0x52, 0x65, 0x74, 0x72, 0x69, 0x65, 0x76,
  1335  	0x65, 0x12, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69,
  1336  	0x74, 0x79, 0x1a, 0x10, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x44, 0x69, 0x72, 0x65, 0x63,
  1337  	0x74, 0x69, 0x76, 0x65, 0x22, 0x00, 0x30, 0x01, 0x12, 0x4b, 0x0a, 0x13, 0x52, 0x65, 0x70, 0x6f,
  1338  	0x72, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12,
  1339  	0x14, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52,
  1340  	0x65, 0x73, 0x75, 0x6c, 0x74, 0x1a, 0x1c, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6f,
  1341  	0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
  1342  	0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x09, 0x5a, 0x07, 0x2e, 0x2f, 0x61, 0x67, 0x65, 0x6e, 0x74,
  1343  	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  1344  }
  1345  
  1346  var (
  1347  	file_agent_director_proto_rawDescOnce sync.Once
  1348  	file_agent_director_proto_rawDescData = file_agent_director_proto_rawDesc
  1349  )
  1350  
  1351  func file_agent_director_proto_rawDescGZIP() []byte {
  1352  	file_agent_director_proto_rawDescOnce.Do(func() {
  1353  		file_agent_director_proto_rawDescData = protoimpl.X.CompressGZIP(file_agent_director_proto_rawDescData)
  1354  	})
  1355  	return file_agent_director_proto_rawDescData
  1356  }
  1357  
  1358  var file_agent_director_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
  1359  var file_agent_director_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
  1360  var file_agent_director_proto_goTypes = []interface{}{
  1361  	(RolloutCommand_Action)(0),    // 0: agent.RolloutCommand.Action
  1362  	(SecretSyncCommand_Action)(0), // 1: agent.SecretSyncCommand.Action
  1363  	(*Identity)(nil),              // 2: agent.Identity
  1364  	(*Snapshot)(nil),              // 3: agent.Snapshot
  1365  	(*RawSnapshotChunk)(nil),      // 4: agent.RawSnapshotChunk
  1366  	(*Diagnostics)(nil),           // 5: agent.Diagnostics
  1367  	(*RawDiagnosticsChunk)(nil),   // 6: agent.RawDiagnosticsChunk
  1368  	(*Service)(nil),               // 7: agent.Service
  1369  	(*SnapshotResponse)(nil),      // 8: agent.SnapshotResponse
  1370  	(*DiagnosticsResponse)(nil),   // 9: agent.DiagnosticsResponse
  1371  	(*Directive)(nil),             // 10: agent.Directive
  1372  	(*Command)(nil),               // 11: agent.Command
  1373  	(*RolloutCommand)(nil),        // 12: agent.RolloutCommand
  1374  	(*SecretSyncCommand)(nil),     // 13: agent.SecretSyncCommand
  1375  	(*CommandResult)(nil),         // 14: agent.CommandResult
  1376  	(*CommandResultResponse)(nil), // 15: agent.CommandResultResponse
  1377  	(*StreamMetricsMessage)(nil),  // 16: agent.StreamMetricsMessage
  1378  	(*StreamMetricsResponse)(nil), // 17: agent.StreamMetricsResponse
  1379  	nil,                           // 18: agent.Service.LabelsEntry
  1380  	nil,                           // 19: agent.Service.AnnotationsEntry
  1381  	nil,                           // 20: agent.SecretSyncCommand.SecretEntry
  1382  	(*timestamppb.Timestamp)(nil), // 21: google.protobuf.Timestamp
  1383  	(*durationpb.Duration)(nil),   // 22: google.protobuf.Duration
  1384  	(*_go.MetricFamily)(nil),      // 23: io.prometheus.client.MetricFamily
  1385  }
  1386  var file_agent_director_proto_depIdxs = []int32{
  1387  	2,  // 0: agent.Snapshot.identity:type_name -> agent.Identity
  1388  	7,  // 1: agent.Snapshot.services:type_name -> agent.Service
  1389  	21, // 2: agent.Snapshot.snapshot_ts:type_name -> google.protobuf.Timestamp
  1390  	2,  // 3: agent.Diagnostics.identity:type_name -> agent.Identity
  1391  	21, // 4: agent.Diagnostics.snapshot_ts:type_name -> google.protobuf.Timestamp
  1392  	18, // 5: agent.Service.labels:type_name -> agent.Service.LabelsEntry
  1393  	19, // 6: agent.Service.annotations:type_name -> agent.Service.AnnotationsEntry
  1394  	22, // 7: agent.Directive.min_report_period:type_name -> google.protobuf.Duration
  1395  	11, // 8: agent.Directive.commands:type_name -> agent.Command
  1396  	12, // 9: agent.Command.rolloutCommand:type_name -> agent.RolloutCommand
  1397  	13, // 10: agent.Command.secretSyncCommand:type_name -> agent.SecretSyncCommand
  1398  	0,  // 11: agent.RolloutCommand.action:type_name -> agent.RolloutCommand.Action
  1399  	1,  // 12: agent.SecretSyncCommand.action:type_name -> agent.SecretSyncCommand.Action
  1400  	20, // 13: agent.SecretSyncCommand.secret:type_name -> agent.SecretSyncCommand.SecretEntry
  1401  	2,  // 14: agent.StreamMetricsMessage.identity:type_name -> agent.Identity
  1402  	23, // 15: agent.StreamMetricsMessage.envoy_metrics:type_name -> io.prometheus.client.MetricFamily
  1403  	3,  // 16: agent.Director.Report:input_type -> agent.Snapshot
  1404  	4,  // 17: agent.Director.ReportStream:input_type -> agent.RawSnapshotChunk
  1405  	6,  // 18: agent.Director.StreamDiagnostics:input_type -> agent.RawDiagnosticsChunk
  1406  	16, // 19: agent.Director.StreamMetrics:input_type -> agent.StreamMetricsMessage
  1407  	2,  // 20: agent.Director.Retrieve:input_type -> agent.Identity
  1408  	14, // 21: agent.Director.ReportCommandResult:input_type -> agent.CommandResult
  1409  	8,  // 22: agent.Director.Report:output_type -> agent.SnapshotResponse
  1410  	8,  // 23: agent.Director.ReportStream:output_type -> agent.SnapshotResponse
  1411  	9,  // 24: agent.Director.StreamDiagnostics:output_type -> agent.DiagnosticsResponse
  1412  	17, // 25: agent.Director.StreamMetrics:output_type -> agent.StreamMetricsResponse
  1413  	10, // 26: agent.Director.Retrieve:output_type -> agent.Directive
  1414  	15, // 27: agent.Director.ReportCommandResult:output_type -> agent.CommandResultResponse
  1415  	22, // [22:28] is the sub-list for method output_type
  1416  	16, // [16:22] is the sub-list for method input_type
  1417  	16, // [16:16] is the sub-list for extension type_name
  1418  	16, // [16:16] is the sub-list for extension extendee
  1419  	0,  // [0:16] is the sub-list for field type_name
  1420  }
  1421  
  1422  func init() { file_agent_director_proto_init() }
  1423  func file_agent_director_proto_init() {
  1424  	if File_agent_director_proto != nil {
  1425  		return
  1426  	}
  1427  	if !protoimpl.UnsafeEnabled {
  1428  		file_agent_director_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1429  			switch v := v.(*Identity); i {
  1430  			case 0:
  1431  				return &v.state
  1432  			case 1:
  1433  				return &v.sizeCache
  1434  			case 2:
  1435  				return &v.unknownFields
  1436  			default:
  1437  				return nil
  1438  			}
  1439  		}
  1440  		file_agent_director_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1441  			switch v := v.(*Snapshot); i {
  1442  			case 0:
  1443  				return &v.state
  1444  			case 1:
  1445  				return &v.sizeCache
  1446  			case 2:
  1447  				return &v.unknownFields
  1448  			default:
  1449  				return nil
  1450  			}
  1451  		}
  1452  		file_agent_director_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1453  			switch v := v.(*RawSnapshotChunk); i {
  1454  			case 0:
  1455  				return &v.state
  1456  			case 1:
  1457  				return &v.sizeCache
  1458  			case 2:
  1459  				return &v.unknownFields
  1460  			default:
  1461  				return nil
  1462  			}
  1463  		}
  1464  		file_agent_director_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1465  			switch v := v.(*Diagnostics); i {
  1466  			case 0:
  1467  				return &v.state
  1468  			case 1:
  1469  				return &v.sizeCache
  1470  			case 2:
  1471  				return &v.unknownFields
  1472  			default:
  1473  				return nil
  1474  			}
  1475  		}
  1476  		file_agent_director_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1477  			switch v := v.(*RawDiagnosticsChunk); i {
  1478  			case 0:
  1479  				return &v.state
  1480  			case 1:
  1481  				return &v.sizeCache
  1482  			case 2:
  1483  				return &v.unknownFields
  1484  			default:
  1485  				return nil
  1486  			}
  1487  		}
  1488  		file_agent_director_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1489  			switch v := v.(*Service); i {
  1490  			case 0:
  1491  				return &v.state
  1492  			case 1:
  1493  				return &v.sizeCache
  1494  			case 2:
  1495  				return &v.unknownFields
  1496  			default:
  1497  				return nil
  1498  			}
  1499  		}
  1500  		file_agent_director_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1501  			switch v := v.(*SnapshotResponse); i {
  1502  			case 0:
  1503  				return &v.state
  1504  			case 1:
  1505  				return &v.sizeCache
  1506  			case 2:
  1507  				return &v.unknownFields
  1508  			default:
  1509  				return nil
  1510  			}
  1511  		}
  1512  		file_agent_director_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1513  			switch v := v.(*DiagnosticsResponse); i {
  1514  			case 0:
  1515  				return &v.state
  1516  			case 1:
  1517  				return &v.sizeCache
  1518  			case 2:
  1519  				return &v.unknownFields
  1520  			default:
  1521  				return nil
  1522  			}
  1523  		}
  1524  		file_agent_director_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1525  			switch v := v.(*Directive); i {
  1526  			case 0:
  1527  				return &v.state
  1528  			case 1:
  1529  				return &v.sizeCache
  1530  			case 2:
  1531  				return &v.unknownFields
  1532  			default:
  1533  				return nil
  1534  			}
  1535  		}
  1536  		file_agent_director_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1537  			switch v := v.(*Command); i {
  1538  			case 0:
  1539  				return &v.state
  1540  			case 1:
  1541  				return &v.sizeCache
  1542  			case 2:
  1543  				return &v.unknownFields
  1544  			default:
  1545  				return nil
  1546  			}
  1547  		}
  1548  		file_agent_director_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1549  			switch v := v.(*RolloutCommand); i {
  1550  			case 0:
  1551  				return &v.state
  1552  			case 1:
  1553  				return &v.sizeCache
  1554  			case 2:
  1555  				return &v.unknownFields
  1556  			default:
  1557  				return nil
  1558  			}
  1559  		}
  1560  		file_agent_director_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1561  			switch v := v.(*SecretSyncCommand); i {
  1562  			case 0:
  1563  				return &v.state
  1564  			case 1:
  1565  				return &v.sizeCache
  1566  			case 2:
  1567  				return &v.unknownFields
  1568  			default:
  1569  				return nil
  1570  			}
  1571  		}
  1572  		file_agent_director_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1573  			switch v := v.(*CommandResult); i {
  1574  			case 0:
  1575  				return &v.state
  1576  			case 1:
  1577  				return &v.sizeCache
  1578  			case 2:
  1579  				return &v.unknownFields
  1580  			default:
  1581  				return nil
  1582  			}
  1583  		}
  1584  		file_agent_director_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1585  			switch v := v.(*CommandResultResponse); i {
  1586  			case 0:
  1587  				return &v.state
  1588  			case 1:
  1589  				return &v.sizeCache
  1590  			case 2:
  1591  				return &v.unknownFields
  1592  			default:
  1593  				return nil
  1594  			}
  1595  		}
  1596  		file_agent_director_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  1597  			switch v := v.(*StreamMetricsMessage); i {
  1598  			case 0:
  1599  				return &v.state
  1600  			case 1:
  1601  				return &v.sizeCache
  1602  			case 2:
  1603  				return &v.unknownFields
  1604  			default:
  1605  				return nil
  1606  			}
  1607  		}
  1608  		file_agent_director_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
  1609  			switch v := v.(*StreamMetricsResponse); i {
  1610  			case 0:
  1611  				return &v.state
  1612  			case 1:
  1613  				return &v.sizeCache
  1614  			case 2:
  1615  				return &v.unknownFields
  1616  			default:
  1617  				return nil
  1618  			}
  1619  		}
  1620  	}
  1621  	type x struct{}
  1622  	out := protoimpl.TypeBuilder{
  1623  		File: protoimpl.DescBuilder{
  1624  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1625  			RawDescriptor: file_agent_director_proto_rawDesc,
  1626  			NumEnums:      2,
  1627  			NumMessages:   19,
  1628  			NumExtensions: 0,
  1629  			NumServices:   1,
  1630  		},
  1631  		GoTypes:           file_agent_director_proto_goTypes,
  1632  		DependencyIndexes: file_agent_director_proto_depIdxs,
  1633  		EnumInfos:         file_agent_director_proto_enumTypes,
  1634  		MessageInfos:      file_agent_director_proto_msgTypes,
  1635  	}.Build()
  1636  	File_agent_director_proto = out.File
  1637  	file_agent_director_proto_rawDesc = nil
  1638  	file_agent_director_proto_goTypes = nil
  1639  	file_agent_director_proto_depIdxs = nil
  1640  }
  1641  

View as plain text