Source file src/github.com/datawire/ambassador/v2/pkg/api/agent/director.pb.go

Documentation: github.com/datawire/ambassador/v2/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.27.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{7, 0}
    78  }
    79  
    80  // How Ambassador's Agent identifies itself to the DCP
    81  // This is the identity of the ambassador the agent is reporting on behalf of
    82  // no user account specific information should be contained in here
    83  type Identity struct {
    84  	state         protoimpl.MessageState
    85  	sizeCache     protoimpl.SizeCache
    86  	unknownFields protoimpl.UnknownFields
    87  
    88  	// The account ID assigned by the DCP
    89  	//
    90  	// Deprecated: Do not use.
    91  	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
    92  	// Ambassador version
    93  	//
    94  	// Deprecated: Do not use.
    95  	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
    96  	// This Ambassador's hostname
    97  	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
    98  	// License information
    99  	License string `protobuf:"bytes,4,opt,name=license,proto3" json:"license,omitempty"`
   100  	// The cluster ID, as determined by Ambassador
   101  	ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
   102  	// Label or description for the user
   103  	//
   104  	// Deprecated: Do not use.
   105  	Label string `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
   106  }
   107  
   108  func (x *Identity) Reset() {
   109  	*x = Identity{}
   110  	if protoimpl.UnsafeEnabled {
   111  		mi := &file_agent_director_proto_msgTypes[0]
   112  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   113  		ms.StoreMessageInfo(mi)
   114  	}
   115  }
   116  
   117  func (x *Identity) String() string {
   118  	return protoimpl.X.MessageStringOf(x)
   119  }
   120  
   121  func (*Identity) ProtoMessage() {}
   122  
   123  func (x *Identity) ProtoReflect() protoreflect.Message {
   124  	mi := &file_agent_director_proto_msgTypes[0]
   125  	if protoimpl.UnsafeEnabled && x != nil {
   126  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   127  		if ms.LoadMessageInfo() == nil {
   128  			ms.StoreMessageInfo(mi)
   129  		}
   130  		return ms
   131  	}
   132  	return mi.MessageOf(x)
   133  }
   134  
   135  // Deprecated: Use Identity.ProtoReflect.Descriptor instead.
   136  func (*Identity) Descriptor() ([]byte, []int) {
   137  	return file_agent_director_proto_rawDescGZIP(), []int{0}
   138  }
   139  
   140  // Deprecated: Do not use.
   141  func (x *Identity) GetAccountId() string {
   142  	if x != nil {
   143  		return x.AccountId
   144  	}
   145  	return ""
   146  }
   147  
   148  // Deprecated: Do not use.
   149  func (x *Identity) GetVersion() string {
   150  	if x != nil {
   151  		return x.Version
   152  	}
   153  	return ""
   154  }
   155  
   156  func (x *Identity) GetHostname() string {
   157  	if x != nil {
   158  		return x.Hostname
   159  	}
   160  	return ""
   161  }
   162  
   163  func (x *Identity) GetLicense() string {
   164  	if x != nil {
   165  		return x.License
   166  	}
   167  	return ""
   168  }
   169  
   170  func (x *Identity) GetClusterId() string {
   171  	if x != nil {
   172  		return x.ClusterId
   173  	}
   174  	return ""
   175  }
   176  
   177  // Deprecated: Do not use.
   178  func (x *Identity) GetLabel() string {
   179  	if x != nil {
   180  		return x.Label
   181  	}
   182  	return ""
   183  }
   184  
   185  // Information that Ambassador's Agent can send to the Director
   186  // component of the DCP
   187  type Snapshot struct {
   188  	state         protoimpl.MessageState
   189  	sizeCache     protoimpl.SizeCache
   190  	unknownFields protoimpl.UnknownFields
   191  
   192  	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
   193  	Message  string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
   194  	// no longer used.
   195  	//
   196  	// Deprecated: Do not use.
   197  	Services    []*Service `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
   198  	RawSnapshot []byte     `protobuf:"bytes,4,opt,name=raw_snapshot,json=rawSnapshot,proto3" json:"raw_snapshot,omitempty"`
   199  	// describes how the raw_snapshot is encoded
   200  	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
   201  	// api version of RawSnapshot
   202  	ApiVersion string                 `protobuf:"bytes,6,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
   203  	SnapshotTs *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
   204  }
   205  
   206  func (x *Snapshot) Reset() {
   207  	*x = Snapshot{}
   208  	if protoimpl.UnsafeEnabled {
   209  		mi := &file_agent_director_proto_msgTypes[1]
   210  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   211  		ms.StoreMessageInfo(mi)
   212  	}
   213  }
   214  
   215  func (x *Snapshot) String() string {
   216  	return protoimpl.X.MessageStringOf(x)
   217  }
   218  
   219  func (*Snapshot) ProtoMessage() {}
   220  
   221  func (x *Snapshot) ProtoReflect() protoreflect.Message {
   222  	mi := &file_agent_director_proto_msgTypes[1]
   223  	if protoimpl.UnsafeEnabled && x != nil {
   224  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   225  		if ms.LoadMessageInfo() == nil {
   226  			ms.StoreMessageInfo(mi)
   227  		}
   228  		return ms
   229  	}
   230  	return mi.MessageOf(x)
   231  }
   232  
   233  // Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.
   234  func (*Snapshot) Descriptor() ([]byte, []int) {
   235  	return file_agent_director_proto_rawDescGZIP(), []int{1}
   236  }
   237  
   238  func (x *Snapshot) GetIdentity() *Identity {
   239  	if x != nil {
   240  		return x.Identity
   241  	}
   242  	return nil
   243  }
   244  
   245  func (x *Snapshot) GetMessage() string {
   246  	if x != nil {
   247  		return x.Message
   248  	}
   249  	return ""
   250  }
   251  
   252  // Deprecated: Do not use.
   253  func (x *Snapshot) GetServices() []*Service {
   254  	if x != nil {
   255  		return x.Services
   256  	}
   257  	return nil
   258  }
   259  
   260  func (x *Snapshot) GetRawSnapshot() []byte {
   261  	if x != nil {
   262  		return x.RawSnapshot
   263  	}
   264  	return nil
   265  }
   266  
   267  func (x *Snapshot) GetContentType() string {
   268  	if x != nil {
   269  		return x.ContentType
   270  	}
   271  	return ""
   272  }
   273  
   274  func (x *Snapshot) GetApiVersion() string {
   275  	if x != nil {
   276  		return x.ApiVersion
   277  	}
   278  	return ""
   279  }
   280  
   281  func (x *Snapshot) GetSnapshotTs() *timestamppb.Timestamp {
   282  	if x != nil {
   283  		return x.SnapshotTs
   284  	}
   285  	return nil
   286  }
   287  
   288  // RawSnapshotChunk is a fragment of a JSON serialization of a
   289  // Snapshot protobuf object.
   290  type RawSnapshotChunk struct {
   291  	state         protoimpl.MessageState
   292  	sizeCache     protoimpl.SizeCache
   293  	unknownFields protoimpl.UnknownFields
   294  
   295  	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
   296  }
   297  
   298  func (x *RawSnapshotChunk) Reset() {
   299  	*x = RawSnapshotChunk{}
   300  	if protoimpl.UnsafeEnabled {
   301  		mi := &file_agent_director_proto_msgTypes[2]
   302  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   303  		ms.StoreMessageInfo(mi)
   304  	}
   305  }
   306  
   307  func (x *RawSnapshotChunk) String() string {
   308  	return protoimpl.X.MessageStringOf(x)
   309  }
   310  
   311  func (*RawSnapshotChunk) ProtoMessage() {}
   312  
   313  func (x *RawSnapshotChunk) ProtoReflect() protoreflect.Message {
   314  	mi := &file_agent_director_proto_msgTypes[2]
   315  	if protoimpl.UnsafeEnabled && x != nil {
   316  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   317  		if ms.LoadMessageInfo() == nil {
   318  			ms.StoreMessageInfo(mi)
   319  		}
   320  		return ms
   321  	}
   322  	return mi.MessageOf(x)
   323  }
   324  
   325  // Deprecated: Use RawSnapshotChunk.ProtoReflect.Descriptor instead.
   326  func (*RawSnapshotChunk) Descriptor() ([]byte, []int) {
   327  	return file_agent_director_proto_rawDescGZIP(), []int{2}
   328  }
   329  
   330  func (x *RawSnapshotChunk) GetChunk() []byte {
   331  	if x != nil {
   332  		return x.Chunk
   333  	}
   334  	return nil
   335  }
   336  
   337  type Service struct {
   338  	state         protoimpl.MessageState
   339  	sizeCache     protoimpl.SizeCache
   340  	unknownFields protoimpl.UnknownFields
   341  
   342  	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   343  	Namespace   string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
   344  	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"`
   345  	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"`
   346  }
   347  
   348  func (x *Service) Reset() {
   349  	*x = Service{}
   350  	if protoimpl.UnsafeEnabled {
   351  		mi := &file_agent_director_proto_msgTypes[3]
   352  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   353  		ms.StoreMessageInfo(mi)
   354  	}
   355  }
   356  
   357  func (x *Service) String() string {
   358  	return protoimpl.X.MessageStringOf(x)
   359  }
   360  
   361  func (*Service) ProtoMessage() {}
   362  
   363  func (x *Service) ProtoReflect() protoreflect.Message {
   364  	mi := &file_agent_director_proto_msgTypes[3]
   365  	if protoimpl.UnsafeEnabled && x != nil {
   366  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   367  		if ms.LoadMessageInfo() == nil {
   368  			ms.StoreMessageInfo(mi)
   369  		}
   370  		return ms
   371  	}
   372  	return mi.MessageOf(x)
   373  }
   374  
   375  // Deprecated: Use Service.ProtoReflect.Descriptor instead.
   376  func (*Service) Descriptor() ([]byte, []int) {
   377  	return file_agent_director_proto_rawDescGZIP(), []int{3}
   378  }
   379  
   380  func (x *Service) GetName() string {
   381  	if x != nil {
   382  		return x.Name
   383  	}
   384  	return ""
   385  }
   386  
   387  func (x *Service) GetNamespace() string {
   388  	if x != nil {
   389  		return x.Namespace
   390  	}
   391  	return ""
   392  }
   393  
   394  func (x *Service) GetLabels() map[string]string {
   395  	if x != nil {
   396  		return x.Labels
   397  	}
   398  	return nil
   399  }
   400  
   401  func (x *Service) GetAnnotations() map[string]string {
   402  	if x != nil {
   403  		return x.Annotations
   404  	}
   405  	return nil
   406  }
   407  
   408  // The Director's response to a Snapshot from the Agent
   409  type SnapshotResponse struct {
   410  	state         protoimpl.MessageState
   411  	sizeCache     protoimpl.SizeCache
   412  	unknownFields protoimpl.UnknownFields
   413  }
   414  
   415  func (x *SnapshotResponse) Reset() {
   416  	*x = SnapshotResponse{}
   417  	if protoimpl.UnsafeEnabled {
   418  		mi := &file_agent_director_proto_msgTypes[4]
   419  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   420  		ms.StoreMessageInfo(mi)
   421  	}
   422  }
   423  
   424  func (x *SnapshotResponse) String() string {
   425  	return protoimpl.X.MessageStringOf(x)
   426  }
   427  
   428  func (*SnapshotResponse) ProtoMessage() {}
   429  
   430  func (x *SnapshotResponse) ProtoReflect() protoreflect.Message {
   431  	mi := &file_agent_director_proto_msgTypes[4]
   432  	if protoimpl.UnsafeEnabled && x != nil {
   433  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   434  		if ms.LoadMessageInfo() == nil {
   435  			ms.StoreMessageInfo(mi)
   436  		}
   437  		return ms
   438  	}
   439  	return mi.MessageOf(x)
   440  }
   441  
   442  // Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.
   443  func (*SnapshotResponse) Descriptor() ([]byte, []int) {
   444  	return file_agent_director_proto_rawDescGZIP(), []int{4}
   445  }
   446  
   447  // Instructions that the DCP can send to Ambassador
   448  type Directive struct {
   449  	state         protoimpl.MessageState
   450  	sizeCache     protoimpl.SizeCache
   451  	unknownFields protoimpl.UnknownFields
   452  
   453  	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
   454  	// Stop sending snapshots. The default value (false) indicates that
   455  	// snapshot should be sent.
   456  	StopReporting bool `protobuf:"varint,2,opt,name=stop_reporting,json=stopReporting,proto3" json:"stop_reporting,omitempty"`
   457  	// Minimum time to wait before pushing the next snapshot. The default
   458  	// value (zero duration) indicates that the Agent should not modify
   459  	// the existing report period.
   460  	MinReportPeriod *durationpb.Duration `protobuf:"bytes,3,opt,name=min_report_period,json=minReportPeriod,proto3" json:"min_report_period,omitempty"`
   461  	// Commands to execute
   462  	Commands []*Command `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"`
   463  }
   464  
   465  func (x *Directive) Reset() {
   466  	*x = Directive{}
   467  	if protoimpl.UnsafeEnabled {
   468  		mi := &file_agent_director_proto_msgTypes[5]
   469  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   470  		ms.StoreMessageInfo(mi)
   471  	}
   472  }
   473  
   474  func (x *Directive) String() string {
   475  	return protoimpl.X.MessageStringOf(x)
   476  }
   477  
   478  func (*Directive) ProtoMessage() {}
   479  
   480  func (x *Directive) ProtoReflect() protoreflect.Message {
   481  	mi := &file_agent_director_proto_msgTypes[5]
   482  	if protoimpl.UnsafeEnabled && x != nil {
   483  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   484  		if ms.LoadMessageInfo() == nil {
   485  			ms.StoreMessageInfo(mi)
   486  		}
   487  		return ms
   488  	}
   489  	return mi.MessageOf(x)
   490  }
   491  
   492  // Deprecated: Use Directive.ProtoReflect.Descriptor instead.
   493  func (*Directive) Descriptor() ([]byte, []int) {
   494  	return file_agent_director_proto_rawDescGZIP(), []int{5}
   495  }
   496  
   497  func (x *Directive) GetID() string {
   498  	if x != nil {
   499  		return x.ID
   500  	}
   501  	return ""
   502  }
   503  
   504  func (x *Directive) GetStopReporting() bool {
   505  	if x != nil {
   506  		return x.StopReporting
   507  	}
   508  	return false
   509  }
   510  
   511  func (x *Directive) GetMinReportPeriod() *durationpb.Duration {
   512  	if x != nil {
   513  		return x.MinReportPeriod
   514  	}
   515  	return nil
   516  }
   517  
   518  func (x *Directive) GetCommands() []*Command {
   519  	if x != nil {
   520  		return x.Commands
   521  	}
   522  	return nil
   523  }
   524  
   525  // An individual instruction from the DCP
   526  type Command struct {
   527  	state         protoimpl.MessageState
   528  	sizeCache     protoimpl.SizeCache
   529  	unknownFields protoimpl.UnknownFields
   530  
   531  	// Log this message if present
   532  	Message        string          `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
   533  	RolloutCommand *RolloutCommand `protobuf:"bytes,2,opt,name=rolloutCommand,proto3" json:"rolloutCommand,omitempty"`
   534  }
   535  
   536  func (x *Command) Reset() {
   537  	*x = Command{}
   538  	if protoimpl.UnsafeEnabled {
   539  		mi := &file_agent_director_proto_msgTypes[6]
   540  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   541  		ms.StoreMessageInfo(mi)
   542  	}
   543  }
   544  
   545  func (x *Command) String() string {
   546  	return protoimpl.X.MessageStringOf(x)
   547  }
   548  
   549  func (*Command) ProtoMessage() {}
   550  
   551  func (x *Command) ProtoReflect() protoreflect.Message {
   552  	mi := &file_agent_director_proto_msgTypes[6]
   553  	if protoimpl.UnsafeEnabled && x != nil {
   554  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   555  		if ms.LoadMessageInfo() == nil {
   556  			ms.StoreMessageInfo(mi)
   557  		}
   558  		return ms
   559  	}
   560  	return mi.MessageOf(x)
   561  }
   562  
   563  // Deprecated: Use Command.ProtoReflect.Descriptor instead.
   564  func (*Command) Descriptor() ([]byte, []int) {
   565  	return file_agent_director_proto_rawDescGZIP(), []int{6}
   566  }
   567  
   568  func (x *Command) GetMessage() string {
   569  	if x != nil {
   570  		return x.Message
   571  	}
   572  	return ""
   573  }
   574  
   575  func (x *Command) GetRolloutCommand() *RolloutCommand {
   576  	if x != nil {
   577  		return x.RolloutCommand
   578  	}
   579  	return nil
   580  }
   581  
   582  type RolloutCommand struct {
   583  	state         protoimpl.MessageState
   584  	sizeCache     protoimpl.SizeCache
   585  	unknownFields protoimpl.UnknownFields
   586  
   587  	Name      string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   588  	Namespace string                `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
   589  	Action    RolloutCommand_Action `protobuf:"varint,3,opt,name=action,proto3,enum=agent.RolloutCommand_Action" json:"action,omitempty"`
   590  	CommandId string                `protobuf:"bytes,4,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
   591  }
   592  
   593  func (x *RolloutCommand) Reset() {
   594  	*x = RolloutCommand{}
   595  	if protoimpl.UnsafeEnabled {
   596  		mi := &file_agent_director_proto_msgTypes[7]
   597  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   598  		ms.StoreMessageInfo(mi)
   599  	}
   600  }
   601  
   602  func (x *RolloutCommand) String() string {
   603  	return protoimpl.X.MessageStringOf(x)
   604  }
   605  
   606  func (*RolloutCommand) ProtoMessage() {}
   607  
   608  func (x *RolloutCommand) ProtoReflect() protoreflect.Message {
   609  	mi := &file_agent_director_proto_msgTypes[7]
   610  	if protoimpl.UnsafeEnabled && x != nil {
   611  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   612  		if ms.LoadMessageInfo() == nil {
   613  			ms.StoreMessageInfo(mi)
   614  		}
   615  		return ms
   616  	}
   617  	return mi.MessageOf(x)
   618  }
   619  
   620  // Deprecated: Use RolloutCommand.ProtoReflect.Descriptor instead.
   621  func (*RolloutCommand) Descriptor() ([]byte, []int) {
   622  	return file_agent_director_proto_rawDescGZIP(), []int{7}
   623  }
   624  
   625  func (x *RolloutCommand) GetName() string {
   626  	if x != nil {
   627  		return x.Name
   628  	}
   629  	return ""
   630  }
   631  
   632  func (x *RolloutCommand) GetNamespace() string {
   633  	if x != nil {
   634  		return x.Namespace
   635  	}
   636  	return ""
   637  }
   638  
   639  func (x *RolloutCommand) GetAction() RolloutCommand_Action {
   640  	if x != nil {
   641  		return x.Action
   642  	}
   643  	return RolloutCommand_PAUSE
   644  }
   645  
   646  func (x *RolloutCommand) GetCommandId() string {
   647  	if x != nil {
   648  		return x.CommandId
   649  	}
   650  	return ""
   651  }
   652  
   653  type CommandResult struct {
   654  	state         protoimpl.MessageState
   655  	sizeCache     protoimpl.SizeCache
   656  	unknownFields protoimpl.UnknownFields
   657  
   658  	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
   659  	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
   660  	Message   string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
   661  }
   662  
   663  func (x *CommandResult) Reset() {
   664  	*x = CommandResult{}
   665  	if protoimpl.UnsafeEnabled {
   666  		mi := &file_agent_director_proto_msgTypes[8]
   667  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   668  		ms.StoreMessageInfo(mi)
   669  	}
   670  }
   671  
   672  func (x *CommandResult) String() string {
   673  	return protoimpl.X.MessageStringOf(x)
   674  }
   675  
   676  func (*CommandResult) ProtoMessage() {}
   677  
   678  func (x *CommandResult) ProtoReflect() protoreflect.Message {
   679  	mi := &file_agent_director_proto_msgTypes[8]
   680  	if protoimpl.UnsafeEnabled && x != nil {
   681  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   682  		if ms.LoadMessageInfo() == nil {
   683  			ms.StoreMessageInfo(mi)
   684  		}
   685  		return ms
   686  	}
   687  	return mi.MessageOf(x)
   688  }
   689  
   690  // Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.
   691  func (*CommandResult) Descriptor() ([]byte, []int) {
   692  	return file_agent_director_proto_rawDescGZIP(), []int{8}
   693  }
   694  
   695  func (x *CommandResult) GetCommandId() string {
   696  	if x != nil {
   697  		return x.CommandId
   698  	}
   699  	return ""
   700  }
   701  
   702  func (x *CommandResult) GetSuccess() bool {
   703  	if x != nil {
   704  		return x.Success
   705  	}
   706  	return false
   707  }
   708  
   709  func (x *CommandResult) GetMessage() string {
   710  	if x != nil {
   711  		return x.Message
   712  	}
   713  	return ""
   714  }
   715  
   716  type CommandResultResponse struct {
   717  	state         protoimpl.MessageState
   718  	sizeCache     protoimpl.SizeCache
   719  	unknownFields protoimpl.UnknownFields
   720  }
   721  
   722  func (x *CommandResultResponse) Reset() {
   723  	*x = CommandResultResponse{}
   724  	if protoimpl.UnsafeEnabled {
   725  		mi := &file_agent_director_proto_msgTypes[9]
   726  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   727  		ms.StoreMessageInfo(mi)
   728  	}
   729  }
   730  
   731  func (x *CommandResultResponse) String() string {
   732  	return protoimpl.X.MessageStringOf(x)
   733  }
   734  
   735  func (*CommandResultResponse) ProtoMessage() {}
   736  
   737  func (x *CommandResultResponse) ProtoReflect() protoreflect.Message {
   738  	mi := &file_agent_director_proto_msgTypes[9]
   739  	if protoimpl.UnsafeEnabled && x != nil {
   740  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   741  		if ms.LoadMessageInfo() == nil {
   742  			ms.StoreMessageInfo(mi)
   743  		}
   744  		return ms
   745  	}
   746  	return mi.MessageOf(x)
   747  }
   748  
   749  // Deprecated: Use CommandResultResponse.ProtoReflect.Descriptor instead.
   750  func (*CommandResultResponse) Descriptor() ([]byte, []int) {
   751  	return file_agent_director_proto_rawDescGZIP(), []int{9}
   752  }
   753  
   754  type StreamMetricsMessage struct {
   755  	state         protoimpl.MessageState
   756  	sizeCache     protoimpl.SizeCache
   757  	unknownFields protoimpl.UnknownFields
   758  
   759  	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
   760  	// A list of metric entries
   761  	EnvoyMetrics []*_go.MetricFamily `protobuf:"bytes,2,rep,name=envoy_metrics,json=envoyMetrics,proto3" json:"envoy_metrics,omitempty"`
   762  }
   763  
   764  func (x *StreamMetricsMessage) Reset() {
   765  	*x = StreamMetricsMessage{}
   766  	if protoimpl.UnsafeEnabled {
   767  		mi := &file_agent_director_proto_msgTypes[10]
   768  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   769  		ms.StoreMessageInfo(mi)
   770  	}
   771  }
   772  
   773  func (x *StreamMetricsMessage) String() string {
   774  	return protoimpl.X.MessageStringOf(x)
   775  }
   776  
   777  func (*StreamMetricsMessage) ProtoMessage() {}
   778  
   779  func (x *StreamMetricsMessage) ProtoReflect() protoreflect.Message {
   780  	mi := &file_agent_director_proto_msgTypes[10]
   781  	if protoimpl.UnsafeEnabled && x != nil {
   782  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   783  		if ms.LoadMessageInfo() == nil {
   784  			ms.StoreMessageInfo(mi)
   785  		}
   786  		return ms
   787  	}
   788  	return mi.MessageOf(x)
   789  }
   790  
   791  // Deprecated: Use StreamMetricsMessage.ProtoReflect.Descriptor instead.
   792  func (*StreamMetricsMessage) Descriptor() ([]byte, []int) {
   793  	return file_agent_director_proto_rawDescGZIP(), []int{10}
   794  }
   795  
   796  func (x *StreamMetricsMessage) GetIdentity() *Identity {
   797  	if x != nil {
   798  		return x.Identity
   799  	}
   800  	return nil
   801  }
   802  
   803  func (x *StreamMetricsMessage) GetEnvoyMetrics() []*_go.MetricFamily {
   804  	if x != nil {
   805  		return x.EnvoyMetrics
   806  	}
   807  	return nil
   808  }
   809  
   810  type StreamMetricsResponse struct {
   811  	state         protoimpl.MessageState
   812  	sizeCache     protoimpl.SizeCache
   813  	unknownFields protoimpl.UnknownFields
   814  }
   815  
   816  func (x *StreamMetricsResponse) Reset() {
   817  	*x = StreamMetricsResponse{}
   818  	if protoimpl.UnsafeEnabled {
   819  		mi := &file_agent_director_proto_msgTypes[11]
   820  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   821  		ms.StoreMessageInfo(mi)
   822  	}
   823  }
   824  
   825  func (x *StreamMetricsResponse) String() string {
   826  	return protoimpl.X.MessageStringOf(x)
   827  }
   828  
   829  func (*StreamMetricsResponse) ProtoMessage() {}
   830  
   831  func (x *StreamMetricsResponse) ProtoReflect() protoreflect.Message {
   832  	mi := &file_agent_director_proto_msgTypes[11]
   833  	if protoimpl.UnsafeEnabled && x != nil {
   834  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   835  		if ms.LoadMessageInfo() == nil {
   836  			ms.StoreMessageInfo(mi)
   837  		}
   838  		return ms
   839  	}
   840  	return mi.MessageOf(x)
   841  }
   842  
   843  // Deprecated: Use StreamMetricsResponse.ProtoReflect.Descriptor instead.
   844  func (*StreamMetricsResponse) Descriptor() ([]byte, []int) {
   845  	return file_agent_director_proto_rawDescGZIP(), []int{11}
   846  }
   847  
   848  var File_agent_director_proto protoreflect.FileDescriptor
   849  
   850  var file_agent_director_proto_rawDesc = []byte{
   851  	0x0a, 0x14, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2f, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74, 0x6f, 0x72,
   852  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x1a, 0x1e, 0x67,
   853  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64,
   854  	0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
   855  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74,
   856  	0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x18,
   857  	0x70, 0x72, 0x6f, 0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2f, 0x6d, 0x65, 0x74, 0x72, 0x69,
   858  	0x63, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xba, 0x01, 0x0a, 0x08, 0x49, 0x64, 0x65,
   859  	0x6e, 0x74, 0x69, 0x74, 0x79, 0x12, 0x21, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74,
   860  	0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x09, 0x61,
   861  	0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73,
   862  	0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x07, 0x76,
   863  	0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61,
   864  	0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x68, 0x6f, 0x73, 0x74, 0x6e, 0x61,
   865  	0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65, 0x18, 0x04, 0x20,
   866  	0x01, 0x28, 0x09, 0x52, 0x07, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65, 0x12, 0x1d, 0x0a, 0x0a,
   867  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09,
   868  	0x52, 0x09, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a, 0x05, 0x6c,
   869  	0x61, 0x62, 0x65, 0x6c, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x02, 0x18, 0x01, 0x52, 0x05,
   870  	0x6c, 0x61, 0x62, 0x65, 0x6c, 0x22, 0xa5, 0x02, 0x0a, 0x08, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
   871  	0x6f, 0x74, 0x12, 0x2b, 0x0a, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18, 0x01,
   872  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65,
   873  	0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x12,
   874  	0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
   875  	0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x2e, 0x0a, 0x08, 0x73, 0x65, 0x72,
   876  	0x76, 0x69, 0x63, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x61, 0x67,
   877  	0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x42, 0x02, 0x18, 0x01, 0x52,
   878  	0x08, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x72, 0x61, 0x77,
   879  	0x5f, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52,
   880  	0x0b, 0x72, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x12, 0x21, 0x0a, 0x0c,
   881  	0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01,
   882  	0x28, 0x09, 0x52, 0x0b, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12,
   883  	0x1f, 0x0a, 0x0b, 0x61, 0x70, 0x69, 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x06,
   884  	0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x70, 0x69, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e,
   885  	0x12, 0x3b, 0x0a, 0x0b, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x73, 0x18,
   886  	0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
   887  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
   888  	0x70, 0x52, 0x0a, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x73, 0x22, 0x28, 0x0a,
   889  	0x10, 0x52, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x43, 0x68, 0x75, 0x6e,
   890  	0x6b, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c,
   891  	0x52, 0x05, 0x63, 0x68, 0x75, 0x6e, 0x6b, 0x22, 0xad, 0x02, 0x0a, 0x07, 0x53, 0x65, 0x72, 0x76,
   892  	0x69, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
   893  	0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73,
   894  	0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65,
   895  	0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x32, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18,
   896  	0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65,
   897  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72,
   898  	0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x12, 0x41, 0x0a, 0x0b, 0x61, 0x6e, 0x6e,
   899  	0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f,
   900  	0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x41,
   901  	0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52,
   902  	0x0b, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x39, 0x0a, 0x0b,
   903  	0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
   904  	0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
   905  	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61,
   906  	0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0x3e, 0x0a, 0x10, 0x41, 0x6e, 0x6e, 0x6f, 0x74,
   907  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
   908  	0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
   909  	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61,
   910  	0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x12, 0x0a, 0x10, 0x53, 0x6e, 0x61, 0x70, 0x73,
   911  	0x68, 0x6f, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xb5, 0x01, 0x0a, 0x09,
   912  	0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x76, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x44, 0x18,
   913  	0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x49, 0x44, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x6f,
   914  	0x70, 0x5f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28,
   915  	0x08, 0x52, 0x0d, 0x73, 0x74, 0x6f, 0x70, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x69, 0x6e, 0x67,
   916  	0x12, 0x45, 0x0a, 0x11, 0x6d, 0x69, 0x6e, 0x5f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x5f, 0x70,
   917  	0x65, 0x72, 0x69, 0x6f, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f,
   918  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75,
   919  	0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0f, 0x6d, 0x69, 0x6e, 0x52, 0x65, 0x70, 0x6f, 0x72,
   920  	0x74, 0x50, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x12, 0x2a, 0x0a, 0x08, 0x63, 0x6f, 0x6d, 0x6d, 0x61,
   921  	0x6e, 0x64, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x61, 0x67, 0x65, 0x6e,
   922  	0x74, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x08, 0x63, 0x6f, 0x6d, 0x6d, 0x61,
   923  	0x6e, 0x64, 0x73, 0x22, 0x62, 0x0a, 0x07, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x18,
   924  	0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
   925  	0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x3d, 0x0a, 0x0e, 0x72, 0x6f, 0x6c, 0x6c,
   926  	0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,
   927  	0x32, 0x15, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74,
   928  	0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x0e, 0x72, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74,
   929  	0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0e, 0x52, 0x6f, 0x6c, 0x6c,
   930  	0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61,
   931  	0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1c,
   932  	0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
   933  	0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x34, 0x0a, 0x06,
   934  	0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x61,
   935  	0x67, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x43, 0x6f, 0x6d, 0x6d,
   936  	0x61, 0x6e, 0x64, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x06, 0x61, 0x63, 0x74, 0x69,
   937  	0x6f, 0x6e, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x5f, 0x69, 0x64,
   938  	0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x49,
   939  	0x64, 0x22, 0x2a, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x09, 0x0a, 0x05, 0x50,
   940  	0x41, 0x55, 0x53, 0x45, 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x52, 0x45, 0x53, 0x55, 0x4d, 0x45,
   941  	0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x42, 0x4f, 0x52, 0x54, 0x10, 0x02, 0x22, 0x62, 0x0a,
   942  	0x0d, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x1d,
   943  	0x0a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
   944  	0x28, 0x09, 0x52, 0x09, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x49, 0x64, 0x12, 0x18, 0x0a,
   945  	0x07, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07,
   946  	0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61,
   947  	0x67, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
   948  	0x65, 0x22, 0x17, 0x0a, 0x15, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75,
   949  	0x6c, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x8c, 0x01, 0x0a, 0x14, 0x53,
   950  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x4d, 0x65, 0x73, 0x73,
   951  	0x61, 0x67, 0x65, 0x12, 0x2b, 0x0a, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x18,
   952  	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64,
   953  	0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x52, 0x08, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79,
   954  	0x12, 0x47, 0x0a, 0x0d, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x5f, 0x6d, 0x65, 0x74, 0x72, 0x69, 0x63,
   955  	0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x69, 0x6f, 0x2e, 0x70, 0x72, 0x6f,
   956  	0x6d, 0x65, 0x74, 0x68, 0x65, 0x75, 0x73, 0x2e, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x4d,
   957  	0x65, 0x74, 0x72, 0x69, 0x63, 0x46, 0x61, 0x6d, 0x69, 0x6c, 0x79, 0x52, 0x0c, 0x65, 0x6e, 0x76,
   958  	0x6f, 0x79, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x22, 0x17, 0x0a, 0x15, 0x53, 0x74, 0x72,
   959  	0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
   960  	0x73, 0x65, 0x32, 0x9b, 0x03, 0x0a, 0x08, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x12,
   961  	0x37, 0x0a, 0x06, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x12, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e,
   962  	0x74, 0x2e, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x1a, 0x17, 0x2e, 0x61, 0x67, 0x65,
   963  	0x6e, 0x74, 0x2e, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f,
   964  	0x6e, 0x73, 0x65, 0x22, 0x03, 0x88, 0x02, 0x01, 0x12, 0x44, 0x0a, 0x0c, 0x52, 0x65, 0x70, 0x6f,
   965  	0x72, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74,
   966  	0x2e, 0x52, 0x61, 0x77, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x43, 0x68, 0x75, 0x6e,
   967  	0x6b, 0x1a, 0x17, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
   968  	0x6f, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x4e,
   969  	0x0a, 0x0d, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69, 0x63, 0x73, 0x12,
   970  	0x1b, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65,
   971  	0x74, 0x72, 0x69, 0x63, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a, 0x1c, 0x2e, 0x61,
   972  	0x67, 0x65, 0x6e, 0x74, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4d, 0x65, 0x74, 0x72, 0x69,
   973  	0x63, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x12, 0x31,
   974  	0x0a, 0x08, 0x52, 0x65, 0x74, 0x72, 0x69, 0x65, 0x76, 0x65, 0x12, 0x0f, 0x2e, 0x61, 0x67, 0x65,
   975  	0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x74, 0x79, 0x1a, 0x10, 0x2e, 0x61, 0x67,
   976  	0x65, 0x6e, 0x74, 0x2e, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x76, 0x65, 0x22, 0x00, 0x30,
   977  	0x01, 0x12, 0x4b, 0x0a, 0x13, 0x52, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x43, 0x6f, 0x6d, 0x6d, 0x61,
   978  	0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x14, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74,
   979  	0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x1a, 0x1c,
   980  	0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65,
   981  	0x73, 0x75, 0x6c, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x40,
   982  	0x0a, 0x10, 0x52, 0x65, 0x74, 0x72, 0x69, 0x65, 0x76, 0x65, 0x53, 0x6e, 0x61, 0x70, 0x73, 0x68,
   983  	0x6f, 0x74, 0x12, 0x0f, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74,
   984  	0x69, 0x74, 0x79, 0x1a, 0x17, 0x2e, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x61, 0x77, 0x53,
   985  	0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x43, 0x68, 0x75, 0x6e, 0x6b, 0x22, 0x00, 0x30, 0x01,
   986  	0x42, 0x09, 0x5a, 0x07, 0x2e, 0x2f, 0x61, 0x67, 0x65, 0x6e, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f,
   987  	0x74, 0x6f, 0x33,
   988  }
   989  
   990  var (
   991  	file_agent_director_proto_rawDescOnce sync.Once
   992  	file_agent_director_proto_rawDescData = file_agent_director_proto_rawDesc
   993  )
   994  
   995  func file_agent_director_proto_rawDescGZIP() []byte {
   996  	file_agent_director_proto_rawDescOnce.Do(func() {
   997  		file_agent_director_proto_rawDescData = protoimpl.X.CompressGZIP(file_agent_director_proto_rawDescData)
   998  	})
   999  	return file_agent_director_proto_rawDescData
  1000  }
  1001  
  1002  var file_agent_director_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
  1003  var file_agent_director_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
  1004  var file_agent_director_proto_goTypes = []interface{}{
  1005  	(RolloutCommand_Action)(0),    // 0: agent.RolloutCommand.Action
  1006  	(*Identity)(nil),              // 1: agent.Identity
  1007  	(*Snapshot)(nil),              // 2: agent.Snapshot
  1008  	(*RawSnapshotChunk)(nil),      // 3: agent.RawSnapshotChunk
  1009  	(*Service)(nil),               // 4: agent.Service
  1010  	(*SnapshotResponse)(nil),      // 5: agent.SnapshotResponse
  1011  	(*Directive)(nil),             // 6: agent.Directive
  1012  	(*Command)(nil),               // 7: agent.Command
  1013  	(*RolloutCommand)(nil),        // 8: agent.RolloutCommand
  1014  	(*CommandResult)(nil),         // 9: agent.CommandResult
  1015  	(*CommandResultResponse)(nil), // 10: agent.CommandResultResponse
  1016  	(*StreamMetricsMessage)(nil),  // 11: agent.StreamMetricsMessage
  1017  	(*StreamMetricsResponse)(nil), // 12: agent.StreamMetricsResponse
  1018  	nil,                           // 13: agent.Service.LabelsEntry
  1019  	nil,                           // 14: agent.Service.AnnotationsEntry
  1020  	(*timestamppb.Timestamp)(nil), // 15: google.protobuf.Timestamp
  1021  	(*durationpb.Duration)(nil),   // 16: google.protobuf.Duration
  1022  	(*_go.MetricFamily)(nil),      // 17: io.prometheus.client.MetricFamily
  1023  }
  1024  var file_agent_director_proto_depIdxs = []int32{
  1025  	1,  // 0: agent.Snapshot.identity:type_name -> agent.Identity
  1026  	4,  // 1: agent.Snapshot.services:type_name -> agent.Service
  1027  	15, // 2: agent.Snapshot.snapshot_ts:type_name -> google.protobuf.Timestamp
  1028  	13, // 3: agent.Service.labels:type_name -> agent.Service.LabelsEntry
  1029  	14, // 4: agent.Service.annotations:type_name -> agent.Service.AnnotationsEntry
  1030  	16, // 5: agent.Directive.min_report_period:type_name -> google.protobuf.Duration
  1031  	7,  // 6: agent.Directive.commands:type_name -> agent.Command
  1032  	8,  // 7: agent.Command.rolloutCommand:type_name -> agent.RolloutCommand
  1033  	0,  // 8: agent.RolloutCommand.action:type_name -> agent.RolloutCommand.Action
  1034  	1,  // 9: agent.StreamMetricsMessage.identity:type_name -> agent.Identity
  1035  	17, // 10: agent.StreamMetricsMessage.envoy_metrics:type_name -> io.prometheus.client.MetricFamily
  1036  	2,  // 11: agent.Director.Report:input_type -> agent.Snapshot
  1037  	3,  // 12: agent.Director.ReportStream:input_type -> agent.RawSnapshotChunk
  1038  	11, // 13: agent.Director.StreamMetrics:input_type -> agent.StreamMetricsMessage
  1039  	1,  // 14: agent.Director.Retrieve:input_type -> agent.Identity
  1040  	9,  // 15: agent.Director.ReportCommandResult:input_type -> agent.CommandResult
  1041  	1,  // 16: agent.Director.RetrieveSnapshot:input_type -> agent.Identity
  1042  	5,  // 17: agent.Director.Report:output_type -> agent.SnapshotResponse
  1043  	5,  // 18: agent.Director.ReportStream:output_type -> agent.SnapshotResponse
  1044  	12, // 19: agent.Director.StreamMetrics:output_type -> agent.StreamMetricsResponse
  1045  	6,  // 20: agent.Director.Retrieve:output_type -> agent.Directive
  1046  	10, // 21: agent.Director.ReportCommandResult:output_type -> agent.CommandResultResponse
  1047  	3,  // 22: agent.Director.RetrieveSnapshot:output_type -> agent.RawSnapshotChunk
  1048  	17, // [17:23] is the sub-list for method output_type
  1049  	11, // [11:17] is the sub-list for method input_type
  1050  	11, // [11:11] is the sub-list for extension type_name
  1051  	11, // [11:11] is the sub-list for extension extendee
  1052  	0,  // [0:11] is the sub-list for field type_name
  1053  }
  1054  
  1055  func init() { file_agent_director_proto_init() }
  1056  func file_agent_director_proto_init() {
  1057  	if File_agent_director_proto != nil {
  1058  		return
  1059  	}
  1060  	if !protoimpl.UnsafeEnabled {
  1061  		file_agent_director_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1062  			switch v := v.(*Identity); i {
  1063  			case 0:
  1064  				return &v.state
  1065  			case 1:
  1066  				return &v.sizeCache
  1067  			case 2:
  1068  				return &v.unknownFields
  1069  			default:
  1070  				return nil
  1071  			}
  1072  		}
  1073  		file_agent_director_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1074  			switch v := v.(*Snapshot); i {
  1075  			case 0:
  1076  				return &v.state
  1077  			case 1:
  1078  				return &v.sizeCache
  1079  			case 2:
  1080  				return &v.unknownFields
  1081  			default:
  1082  				return nil
  1083  			}
  1084  		}
  1085  		file_agent_director_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1086  			switch v := v.(*RawSnapshotChunk); i {
  1087  			case 0:
  1088  				return &v.state
  1089  			case 1:
  1090  				return &v.sizeCache
  1091  			case 2:
  1092  				return &v.unknownFields
  1093  			default:
  1094  				return nil
  1095  			}
  1096  		}
  1097  		file_agent_director_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1098  			switch v := v.(*Service); i {
  1099  			case 0:
  1100  				return &v.state
  1101  			case 1:
  1102  				return &v.sizeCache
  1103  			case 2:
  1104  				return &v.unknownFields
  1105  			default:
  1106  				return nil
  1107  			}
  1108  		}
  1109  		file_agent_director_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1110  			switch v := v.(*SnapshotResponse); i {
  1111  			case 0:
  1112  				return &v.state
  1113  			case 1:
  1114  				return &v.sizeCache
  1115  			case 2:
  1116  				return &v.unknownFields
  1117  			default:
  1118  				return nil
  1119  			}
  1120  		}
  1121  		file_agent_director_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1122  			switch v := v.(*Directive); i {
  1123  			case 0:
  1124  				return &v.state
  1125  			case 1:
  1126  				return &v.sizeCache
  1127  			case 2:
  1128  				return &v.unknownFields
  1129  			default:
  1130  				return nil
  1131  			}
  1132  		}
  1133  		file_agent_director_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1134  			switch v := v.(*Command); i {
  1135  			case 0:
  1136  				return &v.state
  1137  			case 1:
  1138  				return &v.sizeCache
  1139  			case 2:
  1140  				return &v.unknownFields
  1141  			default:
  1142  				return nil
  1143  			}
  1144  		}
  1145  		file_agent_director_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1146  			switch v := v.(*RolloutCommand); i {
  1147  			case 0:
  1148  				return &v.state
  1149  			case 1:
  1150  				return &v.sizeCache
  1151  			case 2:
  1152  				return &v.unknownFields
  1153  			default:
  1154  				return nil
  1155  			}
  1156  		}
  1157  		file_agent_director_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1158  			switch v := v.(*CommandResult); i {
  1159  			case 0:
  1160  				return &v.state
  1161  			case 1:
  1162  				return &v.sizeCache
  1163  			case 2:
  1164  				return &v.unknownFields
  1165  			default:
  1166  				return nil
  1167  			}
  1168  		}
  1169  		file_agent_director_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1170  			switch v := v.(*CommandResultResponse); i {
  1171  			case 0:
  1172  				return &v.state
  1173  			case 1:
  1174  				return &v.sizeCache
  1175  			case 2:
  1176  				return &v.unknownFields
  1177  			default:
  1178  				return nil
  1179  			}
  1180  		}
  1181  		file_agent_director_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1182  			switch v := v.(*StreamMetricsMessage); i {
  1183  			case 0:
  1184  				return &v.state
  1185  			case 1:
  1186  				return &v.sizeCache
  1187  			case 2:
  1188  				return &v.unknownFields
  1189  			default:
  1190  				return nil
  1191  			}
  1192  		}
  1193  		file_agent_director_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1194  			switch v := v.(*StreamMetricsResponse); i {
  1195  			case 0:
  1196  				return &v.state
  1197  			case 1:
  1198  				return &v.sizeCache
  1199  			case 2:
  1200  				return &v.unknownFields
  1201  			default:
  1202  				return nil
  1203  			}
  1204  		}
  1205  	}
  1206  	type x struct{}
  1207  	out := protoimpl.TypeBuilder{
  1208  		File: protoimpl.DescBuilder{
  1209  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1210  			RawDescriptor: file_agent_director_proto_rawDesc,
  1211  			NumEnums:      1,
  1212  			NumMessages:   14,
  1213  			NumExtensions: 0,
  1214  			NumServices:   1,
  1215  		},
  1216  		GoTypes:           file_agent_director_proto_goTypes,
  1217  		DependencyIndexes: file_agent_director_proto_depIdxs,
  1218  		EnumInfos:         file_agent_director_proto_enumTypes,
  1219  		MessageInfos:      file_agent_director_proto_msgTypes,
  1220  	}.Build()
  1221  	File_agent_director_proto = out.File
  1222  	file_agent_director_proto_rawDesc = nil
  1223  	file_agent_director_proto_goTypes = nil
  1224  	file_agent_director_proto_depIdxs = nil
  1225  }
  1226  

View as plain text