Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterApproveConfigServiceServer(s grpc.ServiceRegistrar, srv ApproveConfigServiceServer)
- func RegisterChangeControlConfigServiceServer(s grpc.ServiceRegistrar, srv ChangeControlConfigServiceServer)
- func RegisterChangeControlServiceServer(s grpc.ServiceRegistrar, srv ChangeControlServiceServer)
- type Action
- func (*Action) Descriptor() ([]byte, []int)deprecated
- func (x *Action) GetArgs() *fmp.MapStringString
- func (x *Action) GetName() *wrapperspb.StringValue
- func (x *Action) GetTimeout() *wrapperspb.UInt32Value
- func (*Action) ProtoMessage()
- func (x *Action) ProtoReflect() protoreflect.Message
- func (x *Action) Reset()
- func (x *Action) String() string
- type ApproveConfig
- func (*ApproveConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfig) GetApprove() *FlagConfig
- func (x *ApproveConfig) GetKey() *ChangeControlKey
- func (x *ApproveConfig) GetVersion() *timestamppb.Timestamp
- func (*ApproveConfig) ProtoMessage()
- func (x *ApproveConfig) ProtoReflect() protoreflect.Message
- func (x *ApproveConfig) Reset()
- func (x *ApproveConfig) String() string
- type ApproveConfigBatchedStreamRequest
- func (*ApproveConfigBatchedStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
- func (x *ApproveConfigBatchedStreamRequest) GetPartialEqFilter() []*ApproveConfig
- func (x *ApproveConfigBatchedStreamRequest) GetTime() *time.TimeBounds
- func (*ApproveConfigBatchedStreamRequest) ProtoMessage()
- func (x *ApproveConfigBatchedStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigBatchedStreamRequest) Reset()
- func (x *ApproveConfigBatchedStreamRequest) String() string
- type ApproveConfigBatchedStreamResponse
- func (*ApproveConfigBatchedStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigBatchedStreamResponse) GetResponses() []*ApproveConfigStreamResponse
- func (*ApproveConfigBatchedStreamResponse) ProtoMessage()
- func (x *ApproveConfigBatchedStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigBatchedStreamResponse) Reset()
- func (x *ApproveConfigBatchedStreamResponse) String() string
- type ApproveConfigDeleteAllRequest
- func (*ApproveConfigDeleteAllRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteAllRequest) GetPartialEqFilter() []*ApproveConfig
- func (*ApproveConfigDeleteAllRequest) ProtoMessage()
- func (x *ApproveConfigDeleteAllRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteAllRequest) Reset()
- func (x *ApproveConfigDeleteAllRequest) String() string
- type ApproveConfigDeleteAllResponse
- func (*ApproveConfigDeleteAllResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteAllResponse) GetError() *wrapperspb.StringValue
- func (x *ApproveConfigDeleteAllResponse) GetKey() *ChangeControlKey
- func (x *ApproveConfigDeleteAllResponse) GetTime() *timestamppb.Timestamp
- func (x *ApproveConfigDeleteAllResponse) GetType() fmp.DeleteError
- func (*ApproveConfigDeleteAllResponse) ProtoMessage()
- func (x *ApproveConfigDeleteAllResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteAllResponse) Reset()
- func (x *ApproveConfigDeleteAllResponse) String() string
- type ApproveConfigDeleteRequest
- func (*ApproveConfigDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteRequest) GetKey() *ChangeControlKey
- func (*ApproveConfigDeleteRequest) ProtoMessage()
- func (x *ApproveConfigDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteRequest) Reset()
- func (x *ApproveConfigDeleteRequest) String() string
- type ApproveConfigDeleteResponse
- func (*ApproveConfigDeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteResponse) GetKey() *ChangeControlKey
- func (x *ApproveConfigDeleteResponse) GetTime() *timestamppb.Timestamp
- func (*ApproveConfigDeleteResponse) ProtoMessage()
- func (x *ApproveConfigDeleteResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteResponse) Reset()
- func (x *ApproveConfigDeleteResponse) String() string
- type ApproveConfigDeleteSomeRequest
- func (*ApproveConfigDeleteSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteSomeRequest) GetKeys() []*ChangeControlKey
- func (*ApproveConfigDeleteSomeRequest) ProtoMessage()
- func (x *ApproveConfigDeleteSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteSomeRequest) Reset()
- func (x *ApproveConfigDeleteSomeRequest) String() string
- type ApproveConfigDeleteSomeResponse
- func (*ApproveConfigDeleteSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigDeleteSomeResponse) GetError() string
- func (x *ApproveConfigDeleteSomeResponse) GetKey() *ChangeControlKey
- func (*ApproveConfigDeleteSomeResponse) ProtoMessage()
- func (x *ApproveConfigDeleteSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigDeleteSomeResponse) Reset()
- func (x *ApproveConfigDeleteSomeResponse) String() string
- type ApproveConfigRequest
- func (*ApproveConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigRequest) GetKey() *ChangeControlKey
- func (x *ApproveConfigRequest) GetTime() *timestamppb.Timestamp
- func (*ApproveConfigRequest) ProtoMessage()
- func (x *ApproveConfigRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigRequest) Reset()
- func (x *ApproveConfigRequest) String() string
- type ApproveConfigResponse
- func (*ApproveConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigResponse) GetTime() *timestamppb.Timestamp
- func (x *ApproveConfigResponse) GetValue() *ApproveConfig
- func (*ApproveConfigResponse) ProtoMessage()
- func (x *ApproveConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigResponse) Reset()
- func (x *ApproveConfigResponse) String() string
- type ApproveConfigServiceClient
- type ApproveConfigServiceServer
- type ApproveConfigService_DeleteAllClient
- type ApproveConfigService_DeleteAllServer
- type ApproveConfigService_DeleteSomeClient
- type ApproveConfigService_DeleteSomeServer
- type ApproveConfigService_GetAllBatchedClient
- type ApproveConfigService_GetAllBatchedServer
- type ApproveConfigService_GetAllClient
- type ApproveConfigService_GetAllServer
- type ApproveConfigService_GetSomeClient
- type ApproveConfigService_GetSomeServer
- type ApproveConfigService_SetSomeClient
- type ApproveConfigService_SetSomeServer
- type ApproveConfigService_SubscribeBatchedClient
- type ApproveConfigService_SubscribeBatchedServer
- type ApproveConfigService_SubscribeClient
- type ApproveConfigService_SubscribeMetaClient
- type ApproveConfigService_SubscribeMetaServer
- type ApproveConfigService_SubscribeServer
- type ApproveConfigSetRequest
- func (*ApproveConfigSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSetRequest) GetValue() *ApproveConfig
- func (*ApproveConfigSetRequest) ProtoMessage()
- func (x *ApproveConfigSetRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSetRequest) Reset()
- func (x *ApproveConfigSetRequest) String() string
- type ApproveConfigSetResponse
- func (*ApproveConfigSetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSetResponse) GetTime() *timestamppb.Timestamp
- func (x *ApproveConfigSetResponse) GetValue() *ApproveConfig
- func (*ApproveConfigSetResponse) ProtoMessage()
- func (x *ApproveConfigSetResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSetResponse) Reset()
- func (x *ApproveConfigSetResponse) String() string
- type ApproveConfigSetSomeRequest
- func (*ApproveConfigSetSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSetSomeRequest) GetValues() []*ApproveConfig
- func (*ApproveConfigSetSomeRequest) ProtoMessage()
- func (x *ApproveConfigSetSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSetSomeRequest) Reset()
- func (x *ApproveConfigSetSomeRequest) String() string
- type ApproveConfigSetSomeResponse
- func (*ApproveConfigSetSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSetSomeResponse) GetError() string
- func (x *ApproveConfigSetSomeResponse) GetKey() *ChangeControlKey
- func (*ApproveConfigSetSomeResponse) ProtoMessage()
- func (x *ApproveConfigSetSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSetSomeResponse) Reset()
- func (x *ApproveConfigSetSomeResponse) String() string
- type ApproveConfigSomeRequest
- func (*ApproveConfigSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSomeRequest) GetKeys() []*ChangeControlKey
- func (x *ApproveConfigSomeRequest) GetTime() *timestamppb.Timestamp
- func (*ApproveConfigSomeRequest) ProtoMessage()
- func (x *ApproveConfigSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSomeRequest) Reset()
- func (x *ApproveConfigSomeRequest) String() string
- type ApproveConfigSomeResponse
- func (*ApproveConfigSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigSomeResponse) GetError() *wrapperspb.StringValue
- func (x *ApproveConfigSomeResponse) GetTime() *timestamppb.Timestamp
- func (x *ApproveConfigSomeResponse) GetValue() *ApproveConfig
- func (*ApproveConfigSomeResponse) ProtoMessage()
- func (x *ApproveConfigSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigSomeResponse) Reset()
- func (x *ApproveConfigSomeResponse) String() string
- type ApproveConfigStreamRequest
- func (*ApproveConfigStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigStreamRequest) GetPartialEqFilter() []*ApproveConfig
- func (x *ApproveConfigStreamRequest) GetTime() *time.TimeBounds
- func (*ApproveConfigStreamRequest) ProtoMessage()
- func (x *ApproveConfigStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigStreamRequest) Reset()
- func (x *ApproveConfigStreamRequest) String() string
- type ApproveConfigStreamResponse
- func (*ApproveConfigStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApproveConfigStreamResponse) GetTime() *timestamppb.Timestamp
- func (x *ApproveConfigStreamResponse) GetType() subscriptions.Operation
- func (x *ApproveConfigStreamResponse) GetValue() *ApproveConfig
- func (*ApproveConfigStreamResponse) ProtoMessage()
- func (x *ApproveConfigStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ApproveConfigStreamResponse) Reset()
- func (x *ApproveConfigStreamResponse) String() string
- type Change
- func (*Change) Descriptor() ([]byte, []int)deprecated
- func (x *Change) GetName() *wrapperspb.StringValue
- func (x *Change) GetNotes() *wrapperspb.StringValue
- func (x *Change) GetRootStageId() *wrapperspb.StringValue
- func (x *Change) GetStages() *StageMap
- func (x *Change) GetTime() *timestamppb.Timestamp
- func (x *Change) GetUser() *wrapperspb.StringValue
- func (*Change) ProtoMessage()
- func (x *Change) ProtoReflect() protoreflect.Message
- func (x *Change) Reset()
- func (x *Change) String() string
- type ChangeConfig
- func (*ChangeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeConfig) GetName() *wrapperspb.StringValue
- func (x *ChangeConfig) GetNotes() *wrapperspb.StringValue
- func (x *ChangeConfig) GetRootStageId() *wrapperspb.StringValue
- func (x *ChangeConfig) GetStages() *StageConfigMap
- func (*ChangeConfig) ProtoMessage()
- func (x *ChangeConfig) ProtoReflect() protoreflect.Message
- func (x *ChangeConfig) Reset()
- func (x *ChangeConfig) String() string
- type ChangeControl
- func (*ChangeControl) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControl) GetApprove() *Flag
- func (x *ChangeControl) GetChange() *Change
- func (x *ChangeControl) GetDeviceIdToStageIds() *DeviceToStageMap
- func (x *ChangeControl) GetDeviceIds() *fmp.RepeatedString
- func (x *ChangeControl) GetError() *wrapperspb.StringValue
- func (x *ChangeControl) GetKey() *ChangeControlKey
- func (x *ChangeControl) GetSchedule() *TimestampFlag
- func (x *ChangeControl) GetStart() *Flag
- func (x *ChangeControl) GetStatus() ChangeControlStatus
- func (*ChangeControl) ProtoMessage()
- func (x *ChangeControl) ProtoReflect() protoreflect.Message
- func (x *ChangeControl) Reset()
- func (x *ChangeControl) String() string
- type ChangeControlBatchedStreamRequest
- func (*ChangeControlBatchedStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlBatchedStreamRequest) GetFilter() *Filter
- func (x *ChangeControlBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
- func (x *ChangeControlBatchedStreamRequest) GetPartialEqFilter() []*ChangeControl
- func (x *ChangeControlBatchedStreamRequest) GetTime() *time.TimeBounds
- func (*ChangeControlBatchedStreamRequest) ProtoMessage()
- func (x *ChangeControlBatchedStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlBatchedStreamRequest) Reset()
- func (x *ChangeControlBatchedStreamRequest) String() string
- type ChangeControlBatchedStreamResponse
- func (*ChangeControlBatchedStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlBatchedStreamResponse) GetResponses() []*ChangeControlStreamResponse
- func (*ChangeControlBatchedStreamResponse) ProtoMessage()
- func (x *ChangeControlBatchedStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlBatchedStreamResponse) Reset()
- func (x *ChangeControlBatchedStreamResponse) String() string
- type ChangeControlConfig
- func (*ChangeControlConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfig) GetChange() *ChangeConfig
- func (x *ChangeControlConfig) GetKey() *ChangeControlKey
- func (x *ChangeControlConfig) GetSchedule() *TimestampFlagConfig
- func (x *ChangeControlConfig) GetStart() *FlagConfig
- func (*ChangeControlConfig) ProtoMessage()
- func (x *ChangeControlConfig) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfig) Reset()
- func (x *ChangeControlConfig) String() string
- type ChangeControlConfigBatchedStreamRequest
- func (*ChangeControlConfigBatchedStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
- func (x *ChangeControlConfigBatchedStreamRequest) GetPartialEqFilter() []*ChangeControlConfig
- func (x *ChangeControlConfigBatchedStreamRequest) GetTime() *time.TimeBounds
- func (*ChangeControlConfigBatchedStreamRequest) ProtoMessage()
- func (x *ChangeControlConfigBatchedStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigBatchedStreamRequest) Reset()
- func (x *ChangeControlConfigBatchedStreamRequest) String() string
- type ChangeControlConfigBatchedStreamResponse
- func (*ChangeControlConfigBatchedStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigBatchedStreamResponse) GetResponses() []*ChangeControlConfigStreamResponse
- func (*ChangeControlConfigBatchedStreamResponse) ProtoMessage()
- func (x *ChangeControlConfigBatchedStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigBatchedStreamResponse) Reset()
- func (x *ChangeControlConfigBatchedStreamResponse) String() string
- type ChangeControlConfigDeleteAllRequest
- func (*ChangeControlConfigDeleteAllRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteAllRequest) GetPartialEqFilter() []*ChangeControlConfig
- func (*ChangeControlConfigDeleteAllRequest) ProtoMessage()
- func (x *ChangeControlConfigDeleteAllRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteAllRequest) Reset()
- func (x *ChangeControlConfigDeleteAllRequest) String() string
- type ChangeControlConfigDeleteAllResponse
- func (*ChangeControlConfigDeleteAllResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteAllResponse) GetError() *wrapperspb.StringValue
- func (x *ChangeControlConfigDeleteAllResponse) GetKey() *ChangeControlKey
- func (x *ChangeControlConfigDeleteAllResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlConfigDeleteAllResponse) GetType() fmp.DeleteError
- func (*ChangeControlConfigDeleteAllResponse) ProtoMessage()
- func (x *ChangeControlConfigDeleteAllResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteAllResponse) Reset()
- func (x *ChangeControlConfigDeleteAllResponse) String() string
- type ChangeControlConfigDeleteRequest
- func (*ChangeControlConfigDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteRequest) GetKey() *ChangeControlKey
- func (*ChangeControlConfigDeleteRequest) ProtoMessage()
- func (x *ChangeControlConfigDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteRequest) Reset()
- func (x *ChangeControlConfigDeleteRequest) String() string
- type ChangeControlConfigDeleteResponse
- func (*ChangeControlConfigDeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteResponse) GetKey() *ChangeControlKey
- func (x *ChangeControlConfigDeleteResponse) GetTime() *timestamppb.Timestamp
- func (*ChangeControlConfigDeleteResponse) ProtoMessage()
- func (x *ChangeControlConfigDeleteResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteResponse) Reset()
- func (x *ChangeControlConfigDeleteResponse) String() string
- type ChangeControlConfigDeleteSomeRequest
- func (*ChangeControlConfigDeleteSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteSomeRequest) GetKeys() []*ChangeControlKey
- func (*ChangeControlConfigDeleteSomeRequest) ProtoMessage()
- func (x *ChangeControlConfigDeleteSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteSomeRequest) Reset()
- func (x *ChangeControlConfigDeleteSomeRequest) String() string
- type ChangeControlConfigDeleteSomeResponse
- func (*ChangeControlConfigDeleteSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigDeleteSomeResponse) GetError() string
- func (x *ChangeControlConfigDeleteSomeResponse) GetKey() *ChangeControlKey
- func (*ChangeControlConfigDeleteSomeResponse) ProtoMessage()
- func (x *ChangeControlConfigDeleteSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigDeleteSomeResponse) Reset()
- func (x *ChangeControlConfigDeleteSomeResponse) String() string
- type ChangeControlConfigRequest
- func (*ChangeControlConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigRequest) GetKey() *ChangeControlKey
- func (x *ChangeControlConfigRequest) GetTime() *timestamppb.Timestamp
- func (*ChangeControlConfigRequest) ProtoMessage()
- func (x *ChangeControlConfigRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigRequest) Reset()
- func (x *ChangeControlConfigRequest) String() string
- type ChangeControlConfigResponse
- func (*ChangeControlConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlConfigResponse) GetValue() *ChangeControlConfig
- func (*ChangeControlConfigResponse) ProtoMessage()
- func (x *ChangeControlConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigResponse) Reset()
- func (x *ChangeControlConfigResponse) String() string
- type ChangeControlConfigServiceClient
- type ChangeControlConfigServiceServer
- type ChangeControlConfigService_DeleteAllClient
- type ChangeControlConfigService_DeleteAllServer
- type ChangeControlConfigService_DeleteSomeClient
- type ChangeControlConfigService_DeleteSomeServer
- type ChangeControlConfigService_GetAllBatchedClient
- type ChangeControlConfigService_GetAllBatchedServer
- type ChangeControlConfigService_GetAllClient
- type ChangeControlConfigService_GetAllServer
- type ChangeControlConfigService_GetSomeClient
- type ChangeControlConfigService_GetSomeServer
- type ChangeControlConfigService_SetSomeClient
- type ChangeControlConfigService_SetSomeServer
- type ChangeControlConfigService_SubscribeBatchedClient
- type ChangeControlConfigService_SubscribeBatchedServer
- type ChangeControlConfigService_SubscribeClient
- type ChangeControlConfigService_SubscribeMetaClient
- type ChangeControlConfigService_SubscribeMetaServer
- type ChangeControlConfigService_SubscribeServer
- type ChangeControlConfigSetRequest
- func (*ChangeControlConfigSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSetRequest) GetValue() *ChangeControlConfig
- func (*ChangeControlConfigSetRequest) ProtoMessage()
- func (x *ChangeControlConfigSetRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSetRequest) Reset()
- func (x *ChangeControlConfigSetRequest) String() string
- type ChangeControlConfigSetResponse
- func (*ChangeControlConfigSetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSetResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlConfigSetResponse) GetValue() *ChangeControlConfig
- func (*ChangeControlConfigSetResponse) ProtoMessage()
- func (x *ChangeControlConfigSetResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSetResponse) Reset()
- func (x *ChangeControlConfigSetResponse) String() string
- type ChangeControlConfigSetSomeRequest
- func (*ChangeControlConfigSetSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSetSomeRequest) GetValues() []*ChangeControlConfig
- func (*ChangeControlConfigSetSomeRequest) ProtoMessage()
- func (x *ChangeControlConfigSetSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSetSomeRequest) Reset()
- func (x *ChangeControlConfigSetSomeRequest) String() string
- type ChangeControlConfigSetSomeResponse
- func (*ChangeControlConfigSetSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSetSomeResponse) GetError() string
- func (x *ChangeControlConfigSetSomeResponse) GetKey() *ChangeControlKey
- func (*ChangeControlConfigSetSomeResponse) ProtoMessage()
- func (x *ChangeControlConfigSetSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSetSomeResponse) Reset()
- func (x *ChangeControlConfigSetSomeResponse) String() string
- type ChangeControlConfigSomeRequest
- func (*ChangeControlConfigSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSomeRequest) GetKeys() []*ChangeControlKey
- func (x *ChangeControlConfigSomeRequest) GetTime() *timestamppb.Timestamp
- func (*ChangeControlConfigSomeRequest) ProtoMessage()
- func (x *ChangeControlConfigSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSomeRequest) Reset()
- func (x *ChangeControlConfigSomeRequest) String() string
- type ChangeControlConfigSomeResponse
- func (*ChangeControlConfigSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigSomeResponse) GetError() *wrapperspb.StringValue
- func (x *ChangeControlConfigSomeResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlConfigSomeResponse) GetValue() *ChangeControlConfig
- func (*ChangeControlConfigSomeResponse) ProtoMessage()
- func (x *ChangeControlConfigSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigSomeResponse) Reset()
- func (x *ChangeControlConfigSomeResponse) String() string
- type ChangeControlConfigStreamRequest
- func (*ChangeControlConfigStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigStreamRequest) GetPartialEqFilter() []*ChangeControlConfig
- func (x *ChangeControlConfigStreamRequest) GetTime() *time.TimeBounds
- func (*ChangeControlConfigStreamRequest) ProtoMessage()
- func (x *ChangeControlConfigStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigStreamRequest) Reset()
- func (x *ChangeControlConfigStreamRequest) String() string
- type ChangeControlConfigStreamResponse
- func (*ChangeControlConfigStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlConfigStreamResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlConfigStreamResponse) GetType() subscriptions.Operation
- func (x *ChangeControlConfigStreamResponse) GetValue() *ChangeControlConfig
- func (*ChangeControlConfigStreamResponse) ProtoMessage()
- func (x *ChangeControlConfigStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlConfigStreamResponse) Reset()
- func (x *ChangeControlConfigStreamResponse) String() string
- type ChangeControlKey
- func (*ChangeControlKey) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlKey) GetId() *wrapperspb.StringValue
- func (*ChangeControlKey) ProtoMessage()
- func (x *ChangeControlKey) ProtoReflect() protoreflect.Message
- func (x *ChangeControlKey) Reset()
- func (x *ChangeControlKey) String() string
- type ChangeControlRequest
- func (*ChangeControlRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlRequest) GetKey() *ChangeControlKey
- func (x *ChangeControlRequest) GetTime() *timestamppb.Timestamp
- func (*ChangeControlRequest) ProtoMessage()
- func (x *ChangeControlRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlRequest) Reset()
- func (x *ChangeControlRequest) String() string
- type ChangeControlResponse
- func (*ChangeControlResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlResponse) GetValue() *ChangeControl
- func (*ChangeControlResponse) ProtoMessage()
- func (x *ChangeControlResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlResponse) Reset()
- func (x *ChangeControlResponse) String() string
- type ChangeControlServiceClient
- type ChangeControlServiceServer
- type ChangeControlService_GetAllBatchedClient
- type ChangeControlService_GetAllBatchedServer
- type ChangeControlService_GetAllClient
- type ChangeControlService_GetAllServer
- type ChangeControlService_GetSomeClient
- type ChangeControlService_GetSomeServer
- type ChangeControlService_SubscribeBatchedClient
- type ChangeControlService_SubscribeBatchedServer
- type ChangeControlService_SubscribeClient
- type ChangeControlService_SubscribeMetaClient
- type ChangeControlService_SubscribeMetaServer
- type ChangeControlService_SubscribeServer
- type ChangeControlSomeRequest
- func (*ChangeControlSomeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlSomeRequest) GetKeys() []*ChangeControlKey
- func (x *ChangeControlSomeRequest) GetTime() *timestamppb.Timestamp
- func (*ChangeControlSomeRequest) ProtoMessage()
- func (x *ChangeControlSomeRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlSomeRequest) Reset()
- func (x *ChangeControlSomeRequest) String() string
- type ChangeControlSomeResponse
- func (*ChangeControlSomeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlSomeResponse) GetError() *wrapperspb.StringValue
- func (x *ChangeControlSomeResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlSomeResponse) GetValue() *ChangeControl
- func (*ChangeControlSomeResponse) ProtoMessage()
- func (x *ChangeControlSomeResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlSomeResponse) Reset()
- func (x *ChangeControlSomeResponse) String() string
- type ChangeControlStatus
- func (ChangeControlStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ChangeControlStatus) Enum() *ChangeControlStatus
- func (ChangeControlStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChangeControlStatus) Number() protoreflect.EnumNumber
- func (x ChangeControlStatus) String() string
- func (ChangeControlStatus) Type() protoreflect.EnumType
- type ChangeControlStreamRequest
- func (*ChangeControlStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlStreamRequest) GetFilter() *Filter
- func (x *ChangeControlStreamRequest) GetPartialEqFilter() []*ChangeControl
- func (x *ChangeControlStreamRequest) GetTime() *time.TimeBounds
- func (*ChangeControlStreamRequest) ProtoMessage()
- func (x *ChangeControlStreamRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeControlStreamRequest) Reset()
- func (x *ChangeControlStreamRequest) String() string
- type ChangeControlStreamResponse
- func (*ChangeControlStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeControlStreamResponse) GetTime() *timestamppb.Timestamp
- func (x *ChangeControlStreamResponse) GetType() subscriptions.Operation
- func (x *ChangeControlStreamResponse) GetValue() *ChangeControl
- func (*ChangeControlStreamResponse) ProtoMessage()
- func (x *ChangeControlStreamResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeControlStreamResponse) Reset()
- func (x *ChangeControlStreamResponse) String() string
- type DeviceToStageMap
- func (*DeviceToStageMap) Descriptor() ([]byte, []int)deprecated
- func (x *DeviceToStageMap) GetValues() map[string]*fmp.RepeatedString
- func (*DeviceToStageMap) ProtoMessage()
- func (x *DeviceToStageMap) ProtoReflect() protoreflect.Message
- func (x *DeviceToStageMap) Reset()
- func (x *DeviceToStageMap) String() string
- type Filter
- type Flag
- func (*Flag) Descriptor() ([]byte, []int)deprecated
- func (x *Flag) GetNotes() *wrapperspb.StringValue
- func (x *Flag) GetTime() *timestamppb.Timestamp
- func (x *Flag) GetUser() *wrapperspb.StringValue
- func (x *Flag) GetValue() *wrapperspb.BoolValue
- func (*Flag) ProtoMessage()
- func (x *Flag) ProtoReflect() protoreflect.Message
- func (x *Flag) Reset()
- func (x *Flag) String() string
- type FlagConfig
- func (*FlagConfig) Descriptor() ([]byte, []int)deprecated
- func (x *FlagConfig) GetNotes() *wrapperspb.StringValue
- func (x *FlagConfig) GetValue() *wrapperspb.BoolValue
- func (*FlagConfig) ProtoMessage()
- func (x *FlagConfig) ProtoReflect() protoreflect.Message
- func (x *FlagConfig) Reset()
- func (x *FlagConfig) String() string
- type MetaResponse
- func (*MetaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MetaResponse) GetCount() *wrapperspb.UInt32Value
- func (x *MetaResponse) GetTime() *timestamppb.Timestamp
- func (x *MetaResponse) GetType() subscriptions.Operation
- func (*MetaResponse) ProtoMessage()
- func (x *MetaResponse) ProtoReflect() protoreflect.Message
- func (x *MetaResponse) Reset()
- func (x *MetaResponse) String() string
- type RepeatedRepeatedString
- func (*RepeatedRepeatedString) Descriptor() ([]byte, []int)deprecated
- func (x *RepeatedRepeatedString) GetValues() []*fmp.RepeatedString
- func (*RepeatedRepeatedString) ProtoMessage()
- func (x *RepeatedRepeatedString) ProtoReflect() protoreflect.Message
- func (x *RepeatedRepeatedString) Reset()
- func (x *RepeatedRepeatedString) String() string
- type Stage
- func (*Stage) Descriptor() ([]byte, []int)deprecated
- func (x *Stage) GetAction() *Action
- func (x *Stage) GetEndTime() *timestamppb.Timestamp
- func (x *Stage) GetError() *wrapperspb.StringValue
- func (x *Stage) GetName() *wrapperspb.StringValue
- func (x *Stage) GetRows() *RepeatedRepeatedString
- func (x *Stage) GetStartTime() *timestamppb.Timestamp
- func (x *Stage) GetStatus() StageStatus
- func (*Stage) ProtoMessage()
- func (x *Stage) ProtoReflect() protoreflect.Message
- func (x *Stage) Reset()
- func (x *Stage) String() string
- type StageConfig
- func (*StageConfig) Descriptor() ([]byte, []int)deprecated
- func (x *StageConfig) GetAction() *Action
- func (x *StageConfig) GetName() *wrapperspb.StringValue
- func (x *StageConfig) GetRows() *RepeatedRepeatedString
- func (*StageConfig) ProtoMessage()
- func (x *StageConfig) ProtoReflect() protoreflect.Message
- func (x *StageConfig) Reset()
- func (x *StageConfig) String() string
- type StageConfigMap
- type StageMap
- type StageStatus
- func (StageStatus) Descriptor() protoreflect.EnumDescriptor
- func (x StageStatus) Enum() *StageStatus
- func (StageStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x StageStatus) Number() protoreflect.EnumNumber
- func (x StageStatus) String() string
- func (StageStatus) Type() protoreflect.EnumType
- type TimestampFlag
- func (*TimestampFlag) Descriptor() ([]byte, []int)deprecated
- func (x *TimestampFlag) GetNotes() *wrapperspb.StringValue
- func (x *TimestampFlag) GetTime() *timestamppb.Timestamp
- func (x *TimestampFlag) GetUser() *wrapperspb.StringValue
- func (x *TimestampFlag) GetValue() *timestamppb.Timestamp
- func (*TimestampFlag) ProtoMessage()
- func (x *TimestampFlag) ProtoReflect() protoreflect.Message
- func (x *TimestampFlag) Reset()
- func (x *TimestampFlag) String() string
- type TimestampFlagConfig
- func (*TimestampFlagConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TimestampFlagConfig) GetNotes() *wrapperspb.StringValue
- func (x *TimestampFlagConfig) GetValue() *timestamppb.Timestamp
- func (*TimestampFlagConfig) ProtoMessage()
- func (x *TimestampFlagConfig) ProtoReflect() protoreflect.Message
- func (x *TimestampFlagConfig) Reset()
- func (x *TimestampFlagConfig) String() string
- type UnimplementedApproveConfigServiceServer
- func (UnimplementedApproveConfigServiceServer) Delete(context.Context, *ApproveConfigDeleteRequest) (*ApproveConfigDeleteResponse, error)
- func (UnimplementedApproveConfigServiceServer) DeleteAll(*ApproveConfigDeleteAllRequest, ApproveConfigService_DeleteAllServer) error
- func (UnimplementedApproveConfigServiceServer) DeleteSome(*ApproveConfigDeleteSomeRequest, ApproveConfigService_DeleteSomeServer) error
- func (UnimplementedApproveConfigServiceServer) GetAll(*ApproveConfigStreamRequest, ApproveConfigService_GetAllServer) error
- func (UnimplementedApproveConfigServiceServer) GetAllBatched(*ApproveConfigBatchedStreamRequest, ApproveConfigService_GetAllBatchedServer) error
- func (UnimplementedApproveConfigServiceServer) GetMeta(context.Context, *ApproveConfigStreamRequest) (*MetaResponse, error)
- func (UnimplementedApproveConfigServiceServer) GetOne(context.Context, *ApproveConfigRequest) (*ApproveConfigResponse, error)
- func (UnimplementedApproveConfigServiceServer) GetSome(*ApproveConfigSomeRequest, ApproveConfigService_GetSomeServer) error
- func (UnimplementedApproveConfigServiceServer) Set(context.Context, *ApproveConfigSetRequest) (*ApproveConfigSetResponse, error)
- func (UnimplementedApproveConfigServiceServer) SetSome(*ApproveConfigSetSomeRequest, ApproveConfigService_SetSomeServer) error
- func (UnimplementedApproveConfigServiceServer) Subscribe(*ApproveConfigStreamRequest, ApproveConfigService_SubscribeServer) error
- func (UnimplementedApproveConfigServiceServer) SubscribeBatched(*ApproveConfigBatchedStreamRequest, ...) error
- func (UnimplementedApproveConfigServiceServer) SubscribeMeta(*ApproveConfigStreamRequest, ApproveConfigService_SubscribeMetaServer) error
- type UnimplementedChangeControlConfigServiceServer
- func (UnimplementedChangeControlConfigServiceServer) Delete(context.Context, *ChangeControlConfigDeleteRequest) (*ChangeControlConfigDeleteResponse, error)
- func (UnimplementedChangeControlConfigServiceServer) DeleteAll(*ChangeControlConfigDeleteAllRequest, ...) error
- func (UnimplementedChangeControlConfigServiceServer) DeleteSome(*ChangeControlConfigDeleteSomeRequest, ...) error
- func (UnimplementedChangeControlConfigServiceServer) GetAll(*ChangeControlConfigStreamRequest, ChangeControlConfigService_GetAllServer) error
- func (UnimplementedChangeControlConfigServiceServer) GetAllBatched(*ChangeControlConfigBatchedStreamRequest, ...) error
- func (UnimplementedChangeControlConfigServiceServer) GetMeta(context.Context, *ChangeControlConfigStreamRequest) (*MetaResponse, error)
- func (UnimplementedChangeControlConfigServiceServer) GetOne(context.Context, *ChangeControlConfigRequest) (*ChangeControlConfigResponse, error)
- func (UnimplementedChangeControlConfigServiceServer) GetSome(*ChangeControlConfigSomeRequest, ChangeControlConfigService_GetSomeServer) error
- func (UnimplementedChangeControlConfigServiceServer) Set(context.Context, *ChangeControlConfigSetRequest) (*ChangeControlConfigSetResponse, error)
- func (UnimplementedChangeControlConfigServiceServer) SetSome(*ChangeControlConfigSetSomeRequest, ChangeControlConfigService_SetSomeServer) error
- func (UnimplementedChangeControlConfigServiceServer) Subscribe(*ChangeControlConfigStreamRequest, ChangeControlConfigService_SubscribeServer) error
- func (UnimplementedChangeControlConfigServiceServer) SubscribeBatched(*ChangeControlConfigBatchedStreamRequest, ...) error
- func (UnimplementedChangeControlConfigServiceServer) SubscribeMeta(*ChangeControlConfigStreamRequest, ...) error
- type UnimplementedChangeControlServiceServer
- func (UnimplementedChangeControlServiceServer) GetAll(*ChangeControlStreamRequest, ChangeControlService_GetAllServer) error
- func (UnimplementedChangeControlServiceServer) GetAllBatched(*ChangeControlBatchedStreamRequest, ChangeControlService_GetAllBatchedServer) error
- func (UnimplementedChangeControlServiceServer) GetMeta(context.Context, *ChangeControlStreamRequest) (*MetaResponse, error)
- func (UnimplementedChangeControlServiceServer) GetOne(context.Context, *ChangeControlRequest) (*ChangeControlResponse, error)
- func (UnimplementedChangeControlServiceServer) GetSome(*ChangeControlSomeRequest, ChangeControlService_GetSomeServer) error
- func (UnimplementedChangeControlServiceServer) Subscribe(*ChangeControlStreamRequest, ChangeControlService_SubscribeServer) error
- func (UnimplementedChangeControlServiceServer) SubscribeBatched(*ChangeControlBatchedStreamRequest, ...) error
- func (UnimplementedChangeControlServiceServer) SubscribeMeta(*ChangeControlStreamRequest, ChangeControlService_SubscribeMetaServer) error
- type UnsafeApproveConfigServiceServer
- type UnsafeChangeControlConfigServiceServer
- type UnsafeChangeControlServiceServer
Constants ¶
const ( ApproveConfigService_GetOne_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/GetOne" ApproveConfigService_GetSome_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/GetSome" ApproveConfigService_GetAll_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/GetAll" ApproveConfigService_Subscribe_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/Subscribe" ApproveConfigService_GetMeta_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/GetMeta" ApproveConfigService_SubscribeMeta_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/SubscribeMeta" ApproveConfigService_Set_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/Set" ApproveConfigService_SetSome_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/SetSome" ApproveConfigService_Delete_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/Delete" ApproveConfigService_DeleteSome_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/DeleteSome" ApproveConfigService_DeleteAll_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/DeleteAll" ApproveConfigService_GetAllBatched_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/GetAllBatched" ApproveConfigService_SubscribeBatched_FullMethodName = "/arista.changecontrol.v1.ApproveConfigService/SubscribeBatched" )
const ( ChangeControlService_GetOne_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/GetOne" ChangeControlService_GetSome_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/GetSome" ChangeControlService_GetAll_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/GetAll" ChangeControlService_Subscribe_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/Subscribe" ChangeControlService_GetMeta_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/GetMeta" ChangeControlService_SubscribeMeta_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/SubscribeMeta" ChangeControlService_GetAllBatched_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/GetAllBatched" ChangeControlService_SubscribeBatched_FullMethodName = "/arista.changecontrol.v1.ChangeControlService/SubscribeBatched" )
const ( ChangeControlConfigService_GetOne_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/GetOne" ChangeControlConfigService_GetSome_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/GetSome" ChangeControlConfigService_GetAll_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/GetAll" ChangeControlConfigService_Subscribe_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/Subscribe" ChangeControlConfigService_GetMeta_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/GetMeta" ChangeControlConfigService_SubscribeMeta_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/SubscribeMeta" ChangeControlConfigService_Set_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/Set" ChangeControlConfigService_SetSome_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/SetSome" ChangeControlConfigService_Delete_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/Delete" ChangeControlConfigService_DeleteSome_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/DeleteSome" ChangeControlConfigService_DeleteAll_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/DeleteAll" ChangeControlConfigService_GetAllBatched_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/GetAllBatched" ChangeControlConfigService_SubscribeBatched_FullMethodName = "/arista.changecontrol.v1.ChangeControlConfigService/SubscribeBatched" )
Variables ¶
var ( StageStatus_name = map[int32]string{ 0: "STAGE_STATUS_UNSPECIFIED", 1: "STAGE_STATUS_RUNNING", 2: "STAGE_STATUS_COMPLETED", 3: "STAGE_STATUS_NOT_STARTED", } StageStatus_value = map[string]int32{ "STAGE_STATUS_UNSPECIFIED": 0, "STAGE_STATUS_RUNNING": 1, "STAGE_STATUS_COMPLETED": 2, "STAGE_STATUS_NOT_STARTED": 3, } )
Enum value maps for StageStatus.
var ( ChangeControlStatus_name = map[int32]string{ 0: "CHANGE_CONTROL_STATUS_UNSPECIFIED", 1: "CHANGE_CONTROL_STATUS_RUNNING", 2: "CHANGE_CONTROL_STATUS_COMPLETED", 3: "CHANGE_CONTROL_STATUS_SCHEDULED", 4: "CHANGE_CONTROL_STATUS_NOT_STARTED", } ChangeControlStatus_value = map[string]int32{ "CHANGE_CONTROL_STATUS_UNSPECIFIED": 0, "CHANGE_CONTROL_STATUS_RUNNING": 1, "CHANGE_CONTROL_STATUS_COMPLETED": 2, "CHANGE_CONTROL_STATUS_SCHEDULED": 3, "CHANGE_CONTROL_STATUS_NOT_STARTED": 4, } )
Enum value maps for ChangeControlStatus.
var ApproveConfigService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "arista.changecontrol.v1.ApproveConfigService", HandlerType: (*ApproveConfigServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetOne", Handler: _ApproveConfigService_GetOne_Handler, }, { MethodName: "GetMeta", Handler: _ApproveConfigService_GetMeta_Handler, }, { MethodName: "Set", Handler: _ApproveConfigService_Set_Handler, }, { MethodName: "Delete", Handler: _ApproveConfigService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetSome", Handler: _ApproveConfigService_GetSome_Handler, ServerStreams: true, }, { StreamName: "GetAll", Handler: _ApproveConfigService_GetAll_Handler, ServerStreams: true, }, { StreamName: "Subscribe", Handler: _ApproveConfigService_Subscribe_Handler, ServerStreams: true, }, { StreamName: "SubscribeMeta", Handler: _ApproveConfigService_SubscribeMeta_Handler, ServerStreams: true, }, { StreamName: "SetSome", Handler: _ApproveConfigService_SetSome_Handler, ServerStreams: true, }, { StreamName: "DeleteSome", Handler: _ApproveConfigService_DeleteSome_Handler, ServerStreams: true, }, { StreamName: "DeleteAll", Handler: _ApproveConfigService_DeleteAll_Handler, ServerStreams: true, }, { StreamName: "GetAllBatched", Handler: _ApproveConfigService_GetAllBatched_Handler, ServerStreams: true, }, { StreamName: "SubscribeBatched", Handler: _ApproveConfigService_SubscribeBatched_Handler, ServerStreams: true, }, }, Metadata: "arista/changecontrol.v1/services.gen.proto", }
ApproveConfigService_ServiceDesc is the grpc.ServiceDesc for ApproveConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ChangeControlConfigService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "arista.changecontrol.v1.ChangeControlConfigService", HandlerType: (*ChangeControlConfigServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetOne", Handler: _ChangeControlConfigService_GetOne_Handler, }, { MethodName: "GetMeta", Handler: _ChangeControlConfigService_GetMeta_Handler, }, { MethodName: "Set", Handler: _ChangeControlConfigService_Set_Handler, }, { MethodName: "Delete", Handler: _ChangeControlConfigService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetSome", Handler: _ChangeControlConfigService_GetSome_Handler, ServerStreams: true, }, { StreamName: "GetAll", Handler: _ChangeControlConfigService_GetAll_Handler, ServerStreams: true, }, { StreamName: "Subscribe", Handler: _ChangeControlConfigService_Subscribe_Handler, ServerStreams: true, }, { StreamName: "SubscribeMeta", Handler: _ChangeControlConfigService_SubscribeMeta_Handler, ServerStreams: true, }, { StreamName: "SetSome", Handler: _ChangeControlConfigService_SetSome_Handler, ServerStreams: true, }, { StreamName: "DeleteSome", Handler: _ChangeControlConfigService_DeleteSome_Handler, ServerStreams: true, }, { StreamName: "DeleteAll", Handler: _ChangeControlConfigService_DeleteAll_Handler, ServerStreams: true, }, { StreamName: "GetAllBatched", Handler: _ChangeControlConfigService_GetAllBatched_Handler, ServerStreams: true, }, { StreamName: "SubscribeBatched", Handler: _ChangeControlConfigService_SubscribeBatched_Handler, ServerStreams: true, }, }, Metadata: "arista/changecontrol.v1/services.gen.proto", }
ChangeControlConfigService_ServiceDesc is the grpc.ServiceDesc for ChangeControlConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ChangeControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "arista.changecontrol.v1.ChangeControlService", HandlerType: (*ChangeControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetOne", Handler: _ChangeControlService_GetOne_Handler, }, { MethodName: "GetMeta", Handler: _ChangeControlService_GetMeta_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetSome", Handler: _ChangeControlService_GetSome_Handler, ServerStreams: true, }, { StreamName: "GetAll", Handler: _ChangeControlService_GetAll_Handler, ServerStreams: true, }, { StreamName: "Subscribe", Handler: _ChangeControlService_Subscribe_Handler, ServerStreams: true, }, { StreamName: "SubscribeMeta", Handler: _ChangeControlService_SubscribeMeta_Handler, ServerStreams: true, }, { StreamName: "GetAllBatched", Handler: _ChangeControlService_GetAllBatched_Handler, ServerStreams: true, }, { StreamName: "SubscribeBatched", Handler: _ChangeControlService_SubscribeBatched_Handler, ServerStreams: true, }, }, Metadata: "arista/changecontrol.v1/services.gen.proto", }
ChangeControlService_ServiceDesc is the grpc.ServiceDesc for ChangeControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_arista_changecontrol_v1_changecontrol_proto protoreflect.FileDescriptor
var File_arista_changecontrol_v1_services_gen_proto protoreflect.FileDescriptor
Functions ¶
func RegisterApproveConfigServiceServer ¶
func RegisterApproveConfigServiceServer(s grpc.ServiceRegistrar, srv ApproveConfigServiceServer)
func RegisterChangeControlConfigServiceServer ¶
func RegisterChangeControlConfigServiceServer(s grpc.ServiceRegistrar, srv ChangeControlConfigServiceServer)
func RegisterChangeControlServiceServer ¶
func RegisterChangeControlServiceServer(s grpc.ServiceRegistrar, srv ChangeControlServiceServer)
Types ¶
type Action ¶
type Action struct { // name is the name of the action. Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // timeout is the maximum duration in seconds that // the action can execute before timing out. If this // is not set, then this is interpreted to mean there // is no timeout. Timeout *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // args are the arguments of the action. Args *fmp.MapStringString `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"` // contains filtered or unexported fields }
Action is an action to perform during the execution of a stage of a change control. Available actions can be fetched using the "action" services.
func (*Action) Descriptor
deprecated
func (*Action) GetArgs ¶
func (x *Action) GetArgs() *fmp.MapStringString
func (*Action) GetName ¶
func (x *Action) GetName() *wrapperspb.StringValue
func (*Action) GetTimeout ¶
func (x *Action) GetTimeout() *wrapperspb.UInt32Value
func (*Action) ProtoMessage ¶
func (*Action) ProtoMessage()
func (*Action) ProtoReflect ¶
func (x *Action) ProtoReflect() protoreflect.Message
type ApproveConfig ¶
type ApproveConfig struct { // key uniquely identifies the change control. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // approve is the flag to approve (`approve.value` set to `true`) // or unapprove (`approve.value` set to `false`) the change control. Approve *FlagConfig `protobuf:"bytes,2,opt,name=approve,proto3" json:"approve,omitempty"` // version is the timestamp of the change control to approve. // This field must be set when `approve.value` is set to `true` // and is intended to safeguard against approving a change control // that has been updated since last read. Version *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
ApproveConfig is used to configure the approval of a change control.
func (*ApproveConfig) Descriptor
deprecated
func (*ApproveConfig) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfig.ProtoReflect.Descriptor instead.
func (*ApproveConfig) GetApprove ¶
func (x *ApproveConfig) GetApprove() *FlagConfig
func (*ApproveConfig) GetKey ¶
func (x *ApproveConfig) GetKey() *ChangeControlKey
func (*ApproveConfig) GetVersion ¶
func (x *ApproveConfig) GetVersion() *timestamppb.Timestamp
func (*ApproveConfig) ProtoMessage ¶
func (*ApproveConfig) ProtoMessage()
func (*ApproveConfig) ProtoReflect ¶
func (x *ApproveConfig) ProtoReflect() protoreflect.Message
func (*ApproveConfig) Reset ¶
func (x *ApproveConfig) Reset()
func (*ApproveConfig) String ¶
func (x *ApproveConfig) String() string
type ApproveConfigBatchedStreamRequest ¶
type ApproveConfigBatchedStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ApproveConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ApproveConfig at end. // - Each ApproveConfig response is fully-specified (all fields set). // - start: Returns the state of each ApproveConfig at start, followed by updates until now. // - Each ApproveConfig response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ApproveConfig at start, followed by updates // until end. // - Each ApproveConfig response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // MaxMessages limits the maximum number of messages that can be contained in one batch. // MaxMessages is required to be at least 1. // The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) // INTERNAL_BATCH_LIMIT is set based on the maximum message size. MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigBatchedStreamRequest) Descriptor
deprecated
func (*ApproveConfigBatchedStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigBatchedStreamRequest) GetMaxMessages ¶
func (x *ApproveConfigBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
func (*ApproveConfigBatchedStreamRequest) GetPartialEqFilter ¶
func (x *ApproveConfigBatchedStreamRequest) GetPartialEqFilter() []*ApproveConfig
func (*ApproveConfigBatchedStreamRequest) GetTime ¶
func (x *ApproveConfigBatchedStreamRequest) GetTime() *time.TimeBounds
func (*ApproveConfigBatchedStreamRequest) ProtoMessage ¶
func (*ApproveConfigBatchedStreamRequest) ProtoMessage()
func (*ApproveConfigBatchedStreamRequest) ProtoReflect ¶
func (x *ApproveConfigBatchedStreamRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigBatchedStreamRequest) Reset ¶
func (x *ApproveConfigBatchedStreamRequest) Reset()
func (*ApproveConfigBatchedStreamRequest) String ¶
func (x *ApproveConfigBatchedStreamRequest) String() string
type ApproveConfigBatchedStreamResponse ¶
type ApproveConfigBatchedStreamResponse struct { // Values are the values deemed relevant to the initiating request. // The length of this structure is guaranteed to be between (inclusive) 1 and // min(req.max_messages, INTERNAL_BATCH_LIMIT). Responses []*ApproveConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigBatchedStreamResponse) Descriptor
deprecated
func (*ApproveConfigBatchedStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigBatchedStreamResponse) GetResponses ¶
func (x *ApproveConfigBatchedStreamResponse) GetResponses() []*ApproveConfigStreamResponse
func (*ApproveConfigBatchedStreamResponse) ProtoMessage ¶
func (*ApproveConfigBatchedStreamResponse) ProtoMessage()
func (*ApproveConfigBatchedStreamResponse) ProtoReflect ¶
func (x *ApproveConfigBatchedStreamResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigBatchedStreamResponse) Reset ¶
func (x *ApproveConfigBatchedStreamResponse) Reset()
func (*ApproveConfigBatchedStreamResponse) String ¶
func (x *ApproveConfigBatchedStreamResponse) String() string
type ApproveConfigDeleteAllRequest ¶
type ApproveConfigDeleteAllRequest struct { // PartialEqFilter provides a way to server-side filter a DeleteAll. // This requires all provided fields to be equal to the response. // A filtered DeleteAll will use GetAll with filter to find things to delete. PartialEqFilter []*ApproveConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigDeleteAllRequest) Descriptor
deprecated
func (*ApproveConfigDeleteAllRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteAllRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteAllRequest) GetPartialEqFilter ¶
func (x *ApproveConfigDeleteAllRequest) GetPartialEqFilter() []*ApproveConfig
func (*ApproveConfigDeleteAllRequest) ProtoMessage ¶
func (*ApproveConfigDeleteAllRequest) ProtoMessage()
func (*ApproveConfigDeleteAllRequest) ProtoReflect ¶
func (x *ApproveConfigDeleteAllRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteAllRequest) Reset ¶
func (x *ApproveConfigDeleteAllRequest) Reset()
func (*ApproveConfigDeleteAllRequest) String ¶
func (x *ApproveConfigDeleteAllRequest) String() string
type ApproveConfigDeleteAllResponse ¶
type ApproveConfigDeleteAllResponse struct { // This describes the class of delete error. // A DeleteAllResponse is only sent when there is an error. Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"` // This indicates the error message from the delete failure. Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // This is the key of the ApproveConfig instance that failed to be deleted. Key *ChangeControlKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the (UTC) timestamp when the key was being deleted. Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigDeleteAllResponse) Descriptor
deprecated
func (*ApproveConfigDeleteAllResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteAllResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteAllResponse) GetError ¶
func (x *ApproveConfigDeleteAllResponse) GetError() *wrapperspb.StringValue
func (*ApproveConfigDeleteAllResponse) GetKey ¶
func (x *ApproveConfigDeleteAllResponse) GetKey() *ChangeControlKey
func (*ApproveConfigDeleteAllResponse) GetTime ¶
func (x *ApproveConfigDeleteAllResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigDeleteAllResponse) GetType ¶
func (x *ApproveConfigDeleteAllResponse) GetType() fmp.DeleteError
func (*ApproveConfigDeleteAllResponse) ProtoMessage ¶
func (*ApproveConfigDeleteAllResponse) ProtoMessage()
func (*ApproveConfigDeleteAllResponse) ProtoReflect ¶
func (x *ApproveConfigDeleteAllResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteAllResponse) Reset ¶
func (x *ApproveConfigDeleteAllResponse) Reset()
func (*ApproveConfigDeleteAllResponse) String ¶
func (x *ApproveConfigDeleteAllResponse) String() string
type ApproveConfigDeleteRequest ¶
type ApproveConfigDeleteRequest struct { // Key indicates which ApproveConfig instance to remove. // This field must always be set. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigDeleteRequest) Descriptor
deprecated
func (*ApproveConfigDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteRequest) GetKey ¶
func (x *ApproveConfigDeleteRequest) GetKey() *ChangeControlKey
func (*ApproveConfigDeleteRequest) ProtoMessage ¶
func (*ApproveConfigDeleteRequest) ProtoMessage()
func (*ApproveConfigDeleteRequest) ProtoReflect ¶
func (x *ApproveConfigDeleteRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteRequest) Reset ¶
func (x *ApproveConfigDeleteRequest) Reset()
func (*ApproveConfigDeleteRequest) String ¶
func (x *ApproveConfigDeleteRequest) String() string
type ApproveConfigDeleteResponse ¶
type ApproveConfigDeleteResponse struct { // Key echoes back the key of the deleted ApproveConfig instance. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the (UTC) timestamp at which the system recognizes the // deletion. The only guarantees made about this timestamp are: // // - it is after the time the request was received // - a time-ranged query with StartTime==DeletedAt will not include this instance. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigDeleteResponse) Descriptor
deprecated
func (*ApproveConfigDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteResponse) GetKey ¶
func (x *ApproveConfigDeleteResponse) GetKey() *ChangeControlKey
func (*ApproveConfigDeleteResponse) GetTime ¶
func (x *ApproveConfigDeleteResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigDeleteResponse) ProtoMessage ¶
func (*ApproveConfigDeleteResponse) ProtoMessage()
func (*ApproveConfigDeleteResponse) ProtoReflect ¶
func (x *ApproveConfigDeleteResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteResponse) Reset ¶
func (x *ApproveConfigDeleteResponse) Reset()
func (*ApproveConfigDeleteResponse) String ¶
func (x *ApproveConfigDeleteResponse) String() string
type ApproveConfigDeleteSomeRequest ¶
type ApproveConfigDeleteSomeRequest struct { // key contains a list of ApproveConfig keys to delete Keys []*ChangeControlKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigDeleteSomeRequest) Descriptor
deprecated
func (*ApproveConfigDeleteSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteSomeRequest) GetKeys ¶
func (x *ApproveConfigDeleteSomeRequest) GetKeys() []*ChangeControlKey
func (*ApproveConfigDeleteSomeRequest) ProtoMessage ¶
func (*ApproveConfigDeleteSomeRequest) ProtoMessage()
func (*ApproveConfigDeleteSomeRequest) ProtoReflect ¶
func (x *ApproveConfigDeleteSomeRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteSomeRequest) Reset ¶
func (x *ApproveConfigDeleteSomeRequest) Reset()
func (*ApproveConfigDeleteSomeRequest) String ¶
func (x *ApproveConfigDeleteSomeRequest) String() string
type ApproveConfigDeleteSomeResponse ¶
type ApproveConfigDeleteSomeResponse struct { Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
ApproveConfigDeleteSomeResponse is only sent when there is an error.
func (*ApproveConfigDeleteSomeResponse) Descriptor
deprecated
func (*ApproveConfigDeleteSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigDeleteSomeResponse) GetError ¶
func (x *ApproveConfigDeleteSomeResponse) GetError() string
func (*ApproveConfigDeleteSomeResponse) GetKey ¶
func (x *ApproveConfigDeleteSomeResponse) GetKey() *ChangeControlKey
func (*ApproveConfigDeleteSomeResponse) ProtoMessage ¶
func (*ApproveConfigDeleteSomeResponse) ProtoMessage()
func (*ApproveConfigDeleteSomeResponse) ProtoReflect ¶
func (x *ApproveConfigDeleteSomeResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigDeleteSomeResponse) Reset ¶
func (x *ApproveConfigDeleteSomeResponse) Reset()
func (*ApproveConfigDeleteSomeResponse) String ¶
func (x *ApproveConfigDeleteSomeResponse) String() string
type ApproveConfigRequest ¶
type ApproveConfigRequest struct { // Key uniquely identifies a ApproveConfig instance to retrieve. // This value must be populated. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigRequest) Descriptor
deprecated
func (*ApproveConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigRequest) GetKey ¶
func (x *ApproveConfigRequest) GetKey() *ChangeControlKey
func (*ApproveConfigRequest) GetTime ¶
func (x *ApproveConfigRequest) GetTime() *timestamppb.Timestamp
func (*ApproveConfigRequest) ProtoMessage ¶
func (*ApproveConfigRequest) ProtoMessage()
func (*ApproveConfigRequest) ProtoReflect ¶
func (x *ApproveConfigRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigRequest) Reset ¶
func (x *ApproveConfigRequest) Reset()
func (*ApproveConfigRequest) String ¶
func (x *ApproveConfigRequest) String() string
type ApproveConfigResponse ¶
type ApproveConfigResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ApproveConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time carries the (UTC) timestamp of the last-modification of the // ApproveConfig instance in this response. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigResponse) Descriptor
deprecated
func (*ApproveConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigResponse) GetTime ¶
func (x *ApproveConfigResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigResponse) GetValue ¶
func (x *ApproveConfigResponse) GetValue() *ApproveConfig
func (*ApproveConfigResponse) ProtoMessage ¶
func (*ApproveConfigResponse) ProtoMessage()
func (*ApproveConfigResponse) ProtoReflect ¶
func (x *ApproveConfigResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigResponse) Reset ¶
func (x *ApproveConfigResponse) Reset()
func (*ApproveConfigResponse) String ¶
func (x *ApproveConfigResponse) String() string
type ApproveConfigServiceClient ¶
type ApproveConfigServiceClient interface { GetOne(ctx context.Context, in *ApproveConfigRequest, opts ...grpc.CallOption) (*ApproveConfigResponse, error) GetSome(ctx context.Context, in *ApproveConfigSomeRequest, opts ...grpc.CallOption) (ApproveConfigService_GetSomeClient, error) GetAll(ctx context.Context, in *ApproveConfigStreamRequest, opts ...grpc.CallOption) (ApproveConfigService_GetAllClient, error) Subscribe(ctx context.Context, in *ApproveConfigStreamRequest, opts ...grpc.CallOption) (ApproveConfigService_SubscribeClient, error) GetMeta(ctx context.Context, in *ApproveConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error) SubscribeMeta(ctx context.Context, in *ApproveConfigStreamRequest, opts ...grpc.CallOption) (ApproveConfigService_SubscribeMetaClient, error) Set(ctx context.Context, in *ApproveConfigSetRequest, opts ...grpc.CallOption) (*ApproveConfigSetResponse, error) SetSome(ctx context.Context, in *ApproveConfigSetSomeRequest, opts ...grpc.CallOption) (ApproveConfigService_SetSomeClient, error) Delete(ctx context.Context, in *ApproveConfigDeleteRequest, opts ...grpc.CallOption) (*ApproveConfigDeleteResponse, error) DeleteSome(ctx context.Context, in *ApproveConfigDeleteSomeRequest, opts ...grpc.CallOption) (ApproveConfigService_DeleteSomeClient, error) DeleteAll(ctx context.Context, in *ApproveConfigDeleteAllRequest, opts ...grpc.CallOption) (ApproveConfigService_DeleteAllClient, error) GetAllBatched(ctx context.Context, in *ApproveConfigBatchedStreamRequest, opts ...grpc.CallOption) (ApproveConfigService_GetAllBatchedClient, error) SubscribeBatched(ctx context.Context, in *ApproveConfigBatchedStreamRequest, opts ...grpc.CallOption) (ApproveConfigService_SubscribeBatchedClient, error) }
ApproveConfigServiceClient is the client API for ApproveConfigService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewApproveConfigServiceClient ¶
func NewApproveConfigServiceClient(cc grpc.ClientConnInterface) ApproveConfigServiceClient
type ApproveConfigServiceServer ¶
type ApproveConfigServiceServer interface { GetOne(context.Context, *ApproveConfigRequest) (*ApproveConfigResponse, error) GetSome(*ApproveConfigSomeRequest, ApproveConfigService_GetSomeServer) error GetAll(*ApproveConfigStreamRequest, ApproveConfigService_GetAllServer) error Subscribe(*ApproveConfigStreamRequest, ApproveConfigService_SubscribeServer) error GetMeta(context.Context, *ApproveConfigStreamRequest) (*MetaResponse, error) SubscribeMeta(*ApproveConfigStreamRequest, ApproveConfigService_SubscribeMetaServer) error Set(context.Context, *ApproveConfigSetRequest) (*ApproveConfigSetResponse, error) SetSome(*ApproveConfigSetSomeRequest, ApproveConfigService_SetSomeServer) error Delete(context.Context, *ApproveConfigDeleteRequest) (*ApproveConfigDeleteResponse, error) DeleteSome(*ApproveConfigDeleteSomeRequest, ApproveConfigService_DeleteSomeServer) error DeleteAll(*ApproveConfigDeleteAllRequest, ApproveConfigService_DeleteAllServer) error GetAllBatched(*ApproveConfigBatchedStreamRequest, ApproveConfigService_GetAllBatchedServer) error SubscribeBatched(*ApproveConfigBatchedStreamRequest, ApproveConfigService_SubscribeBatchedServer) error // contains filtered or unexported methods }
ApproveConfigServiceServer is the server API for ApproveConfigService service. All implementations must embed UnimplementedApproveConfigServiceServer for forward compatibility
type ApproveConfigService_DeleteAllClient ¶
type ApproveConfigService_DeleteAllClient interface { Recv() (*ApproveConfigDeleteAllResponse, error) grpc.ClientStream }
type ApproveConfigService_DeleteAllServer ¶
type ApproveConfigService_DeleteAllServer interface { Send(*ApproveConfigDeleteAllResponse) error grpc.ServerStream }
type ApproveConfigService_DeleteSomeClient ¶
type ApproveConfigService_DeleteSomeClient interface { Recv() (*ApproveConfigDeleteSomeResponse, error) grpc.ClientStream }
type ApproveConfigService_DeleteSomeServer ¶
type ApproveConfigService_DeleteSomeServer interface { Send(*ApproveConfigDeleteSomeResponse) error grpc.ServerStream }
type ApproveConfigService_GetAllBatchedClient ¶
type ApproveConfigService_GetAllBatchedClient interface { Recv() (*ApproveConfigBatchedStreamResponse, error) grpc.ClientStream }
type ApproveConfigService_GetAllBatchedServer ¶
type ApproveConfigService_GetAllBatchedServer interface { Send(*ApproveConfigBatchedStreamResponse) error grpc.ServerStream }
type ApproveConfigService_GetAllClient ¶
type ApproveConfigService_GetAllClient interface { Recv() (*ApproveConfigStreamResponse, error) grpc.ClientStream }
type ApproveConfigService_GetAllServer ¶
type ApproveConfigService_GetAllServer interface { Send(*ApproveConfigStreamResponse) error grpc.ServerStream }
type ApproveConfigService_GetSomeClient ¶
type ApproveConfigService_GetSomeClient interface { Recv() (*ApproveConfigSomeResponse, error) grpc.ClientStream }
type ApproveConfigService_GetSomeServer ¶
type ApproveConfigService_GetSomeServer interface { Send(*ApproveConfigSomeResponse) error grpc.ServerStream }
type ApproveConfigService_SetSomeClient ¶
type ApproveConfigService_SetSomeClient interface { Recv() (*ApproveConfigSetSomeResponse, error) grpc.ClientStream }
type ApproveConfigService_SetSomeServer ¶
type ApproveConfigService_SetSomeServer interface { Send(*ApproveConfigSetSomeResponse) error grpc.ServerStream }
type ApproveConfigService_SubscribeBatchedClient ¶
type ApproveConfigService_SubscribeBatchedClient interface { Recv() (*ApproveConfigBatchedStreamResponse, error) grpc.ClientStream }
type ApproveConfigService_SubscribeBatchedServer ¶
type ApproveConfigService_SubscribeBatchedServer interface { Send(*ApproveConfigBatchedStreamResponse) error grpc.ServerStream }
type ApproveConfigService_SubscribeClient ¶
type ApproveConfigService_SubscribeClient interface { Recv() (*ApproveConfigStreamResponse, error) grpc.ClientStream }
type ApproveConfigService_SubscribeMetaClient ¶
type ApproveConfigService_SubscribeMetaClient interface { Recv() (*MetaResponse, error) grpc.ClientStream }
type ApproveConfigService_SubscribeMetaServer ¶
type ApproveConfigService_SubscribeMetaServer interface { Send(*MetaResponse) error grpc.ServerStream }
type ApproveConfigService_SubscribeServer ¶
type ApproveConfigService_SubscribeServer interface { Send(*ApproveConfigStreamResponse) error grpc.ServerStream }
type ApproveConfigSetRequest ¶
type ApproveConfigSetRequest struct { // ApproveConfig carries the value to set into the datastore. // See the documentation on the ApproveConfig struct for which fields are required. Value *ApproveConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSetRequest) Descriptor
deprecated
func (*ApproveConfigSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSetRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigSetRequest) GetValue ¶
func (x *ApproveConfigSetRequest) GetValue() *ApproveConfig
func (*ApproveConfigSetRequest) ProtoMessage ¶
func (*ApproveConfigSetRequest) ProtoMessage()
func (*ApproveConfigSetRequest) ProtoReflect ¶
func (x *ApproveConfigSetRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigSetRequest) Reset ¶
func (x *ApproveConfigSetRequest) Reset()
func (*ApproveConfigSetRequest) String ¶
func (x *ApproveConfigSetRequest) String() string
type ApproveConfigSetResponse ¶
type ApproveConfigSetResponse struct { // Value carries all the values given in the ApproveConfigSetRequest as well // as any server-generated values. Value *ApproveConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time indicates the (UTC) timestamp at which the system recognizes the // creation. The only guarantees made about this timestamp are: // // - it is after the time the request was received // - a time-ranged query with StartTime==CreatedAt will include this instance. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSetResponse) Descriptor
deprecated
func (*ApproveConfigSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSetResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigSetResponse) GetTime ¶
func (x *ApproveConfigSetResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigSetResponse) GetValue ¶
func (x *ApproveConfigSetResponse) GetValue() *ApproveConfig
func (*ApproveConfigSetResponse) ProtoMessage ¶
func (*ApproveConfigSetResponse) ProtoMessage()
func (*ApproveConfigSetResponse) ProtoReflect ¶
func (x *ApproveConfigSetResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigSetResponse) Reset ¶
func (x *ApproveConfigSetResponse) Reset()
func (*ApproveConfigSetResponse) String ¶
func (x *ApproveConfigSetResponse) String() string
type ApproveConfigSetSomeRequest ¶
type ApproveConfigSetSomeRequest struct { // value contains a list of ApproveConfig values to write. // It is possible to provide more values than can fit within either: // - the maxiumum send size of the client // - the maximum receive size of the server // // If this error occurs you must reduce the number of values sent. // See gRPC "maximum message size" documentation for more information. Values []*ApproveConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSetSomeRequest) Descriptor
deprecated
func (*ApproveConfigSetSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSetSomeRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigSetSomeRequest) GetValues ¶
func (x *ApproveConfigSetSomeRequest) GetValues() []*ApproveConfig
func (*ApproveConfigSetSomeRequest) ProtoMessage ¶
func (*ApproveConfigSetSomeRequest) ProtoMessage()
func (*ApproveConfigSetSomeRequest) ProtoReflect ¶
func (x *ApproveConfigSetSomeRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigSetSomeRequest) Reset ¶
func (x *ApproveConfigSetSomeRequest) Reset()
func (*ApproveConfigSetSomeRequest) String ¶
func (x *ApproveConfigSetSomeRequest) String() string
type ApproveConfigSetSomeResponse ¶
type ApproveConfigSetSomeResponse struct { Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSetSomeResponse) Descriptor
deprecated
func (*ApproveConfigSetSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSetSomeResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigSetSomeResponse) GetError ¶
func (x *ApproveConfigSetSomeResponse) GetError() string
func (*ApproveConfigSetSomeResponse) GetKey ¶
func (x *ApproveConfigSetSomeResponse) GetKey() *ChangeControlKey
func (*ApproveConfigSetSomeResponse) ProtoMessage ¶
func (*ApproveConfigSetSomeResponse) ProtoMessage()
func (*ApproveConfigSetSomeResponse) ProtoReflect ¶
func (x *ApproveConfigSetSomeResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigSetSomeResponse) Reset ¶
func (x *ApproveConfigSetSomeResponse) Reset()
func (*ApproveConfigSetSomeResponse) String ¶
func (x *ApproveConfigSetSomeResponse) String() string
type ApproveConfigSomeRequest ¶
type ApproveConfigSomeRequest struct { Keys []*ChangeControlKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSomeRequest) Descriptor
deprecated
func (*ApproveConfigSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSomeRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigSomeRequest) GetKeys ¶
func (x *ApproveConfigSomeRequest) GetKeys() []*ChangeControlKey
func (*ApproveConfigSomeRequest) GetTime ¶
func (x *ApproveConfigSomeRequest) GetTime() *timestamppb.Timestamp
func (*ApproveConfigSomeRequest) ProtoMessage ¶
func (*ApproveConfigSomeRequest) ProtoMessage()
func (*ApproveConfigSomeRequest) ProtoReflect ¶
func (x *ApproveConfigSomeRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigSomeRequest) Reset ¶
func (x *ApproveConfigSomeRequest) Reset()
func (*ApproveConfigSomeRequest) String ¶
func (x *ApproveConfigSomeRequest) String() string
type ApproveConfigSomeResponse ¶
type ApproveConfigSomeResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ApproveConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Error is an optional field. // It should be filled when there is an error in the GetSome process. Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigSomeResponse) Descriptor
deprecated
func (*ApproveConfigSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigSomeResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigSomeResponse) GetError ¶
func (x *ApproveConfigSomeResponse) GetError() *wrapperspb.StringValue
func (*ApproveConfigSomeResponse) GetTime ¶
func (x *ApproveConfigSomeResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigSomeResponse) GetValue ¶
func (x *ApproveConfigSomeResponse) GetValue() *ApproveConfig
func (*ApproveConfigSomeResponse) ProtoMessage ¶
func (*ApproveConfigSomeResponse) ProtoMessage()
func (*ApproveConfigSomeResponse) ProtoReflect ¶
func (x *ApproveConfigSomeResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigSomeResponse) Reset ¶
func (x *ApproveConfigSomeResponse) Reset()
func (*ApproveConfigSomeResponse) String ¶
func (x *ApproveConfigSomeResponse) String() string
type ApproveConfigStreamRequest ¶
type ApproveConfigStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ApproveConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ApproveConfig at end. // - Each ApproveConfig response is fully-specified (all fields set). // - start: Returns the state of each ApproveConfig at start, followed by updates until now. // - Each ApproveConfig response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ApproveConfig at start, followed by updates // until end. // - Each ApproveConfig response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigStreamRequest) Descriptor
deprecated
func (*ApproveConfigStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigStreamRequest.ProtoReflect.Descriptor instead.
func (*ApproveConfigStreamRequest) GetPartialEqFilter ¶
func (x *ApproveConfigStreamRequest) GetPartialEqFilter() []*ApproveConfig
func (*ApproveConfigStreamRequest) GetTime ¶
func (x *ApproveConfigStreamRequest) GetTime() *time.TimeBounds
func (*ApproveConfigStreamRequest) ProtoMessage ¶
func (*ApproveConfigStreamRequest) ProtoMessage()
func (*ApproveConfigStreamRequest) ProtoReflect ¶
func (x *ApproveConfigStreamRequest) ProtoReflect() protoreflect.Message
func (*ApproveConfigStreamRequest) Reset ¶
func (x *ApproveConfigStreamRequest) Reset()
func (*ApproveConfigStreamRequest) String ¶
func (x *ApproveConfigStreamRequest) String() string
type ApproveConfigStreamResponse ¶
type ApproveConfigStreamResponse struct { // Value is a value deemed relevant to the initiating request. // This structure will always have its key-field populated. Which other fields are // populated, and why, depends on the value of Operation and what triggered this notification. Value *ApproveConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time holds the timestamp of this ApproveConfig's last modification. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // Operation indicates how the ApproveConfig value in this response should be considered. // Under non-subscribe requests, this value should always be INITIAL. In a subscription, // once all initial data is streamed and the client begins to receive modification updates, // you should not see INITIAL again. Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ApproveConfigStreamResponse) Descriptor
deprecated
func (*ApproveConfigStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApproveConfigStreamResponse.ProtoReflect.Descriptor instead.
func (*ApproveConfigStreamResponse) GetTime ¶
func (x *ApproveConfigStreamResponse) GetTime() *timestamppb.Timestamp
func (*ApproveConfigStreamResponse) GetType ¶
func (x *ApproveConfigStreamResponse) GetType() subscriptions.Operation
func (*ApproveConfigStreamResponse) GetValue ¶
func (x *ApproveConfigStreamResponse) GetValue() *ApproveConfig
func (*ApproveConfigStreamResponse) ProtoMessage ¶
func (*ApproveConfigStreamResponse) ProtoMessage()
func (*ApproveConfigStreamResponse) ProtoReflect ¶
func (x *ApproveConfigStreamResponse) ProtoReflect() protoreflect.Message
func (*ApproveConfigStreamResponse) Reset ¶
func (x *ApproveConfigStreamResponse) Reset()
func (*ApproveConfigStreamResponse) String ¶
func (x *ApproveConfigStreamResponse) String() string
type Change ¶
type Change struct { // name is the name of the change. Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // root_stage_id is the ID of the root stage or the stage that // should execute first. RootStageId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=root_stage_id,json=rootStageId,proto3" json:"root_stage_id,omitempty"` // stages holds a configuration of stages and their statuses. Stages *StageMap `protobuf:"bytes,3,opt,name=stages,proto3" json:"stages,omitempty"` // notes are any notes associated with the change. Notes *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=notes,proto3" json:"notes,omitempty"` // time is the time at which the change was last updated. Time *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"` // user is the user by which the change was last updated. User *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
Change holds the configuration and status of the change of a change control.
func (*Change) Descriptor
deprecated
func (*Change) GetName ¶
func (x *Change) GetName() *wrapperspb.StringValue
func (*Change) GetNotes ¶
func (x *Change) GetNotes() *wrapperspb.StringValue
func (*Change) GetRootStageId ¶
func (x *Change) GetRootStageId() *wrapperspb.StringValue
func (*Change) GetTime ¶
func (x *Change) GetTime() *timestamppb.Timestamp
func (*Change) GetUser ¶
func (x *Change) GetUser() *wrapperspb.StringValue
func (*Change) ProtoMessage ¶
func (*Change) ProtoMessage()
func (*Change) ProtoReflect ¶
func (x *Change) ProtoReflect() protoreflect.Message
type ChangeConfig ¶
type ChangeConfig struct { // name is the name of the change. Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // root_stage_id is the ID of the root stage or the stage that // should execute first. RootStageId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=root_stage_id,json=rootStageId,proto3" json:"root_stage_id,omitempty"` // stages holds a configuration of stages. See `StageConfigMap` // description for more information. Stages *StageConfigMap `protobuf:"bytes,3,opt,name=stages,proto3" json:"stages,omitempty"` // notes are any notes associated with the change. Notes *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=notes,proto3" json:"notes,omitempty"` // contains filtered or unexported fields }
ChangeConfig holds a configuration for the change of a change control which is essentially a named configuration of stages.
func (*ChangeConfig) Descriptor
deprecated
func (*ChangeConfig) Descriptor() ([]byte, []int)
Deprecated: Use ChangeConfig.ProtoReflect.Descriptor instead.
func (*ChangeConfig) GetName ¶
func (x *ChangeConfig) GetName() *wrapperspb.StringValue
func (*ChangeConfig) GetNotes ¶
func (x *ChangeConfig) GetNotes() *wrapperspb.StringValue
func (*ChangeConfig) GetRootStageId ¶
func (x *ChangeConfig) GetRootStageId() *wrapperspb.StringValue
func (*ChangeConfig) GetStages ¶
func (x *ChangeConfig) GetStages() *StageConfigMap
func (*ChangeConfig) ProtoMessage ¶
func (*ChangeConfig) ProtoMessage()
func (*ChangeConfig) ProtoReflect ¶
func (x *ChangeConfig) ProtoReflect() protoreflect.Message
func (*ChangeConfig) Reset ¶
func (x *ChangeConfig) Reset()
func (*ChangeConfig) String ¶
func (x *ChangeConfig) String() string
type ChangeControl ¶
type ChangeControl struct { // key uniquely identifies the change control. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // change holds the configuration and status of the change of // the change control. Change *Change `protobuf:"bytes,2,opt,name=change,proto3" json:"change,omitempty"` // approve indicates whether the change control was flagged // as approved (`approve.value` set to `true`) or unapproved // (`approve.value` set to `false`). Approve *Flag `protobuf:"bytes,3,opt,name=approve,proto3" json:"approve,omitempty"` // start indicates whether the change control was flagged to // start (`start.value` set to `true`) or stop (`start.value` // set to `false`) execution. Start *Flag `protobuf:"bytes,4,opt,name=start,proto3" json:"start,omitempty"` // status is the execution status of the change control. Status ChangeControlStatus `protobuf:"varint,5,opt,name=status,proto3,enum=arista.changecontrol.v1.ChangeControlStatus" json:"status,omitempty"` // error is any error that occurred during the execution of the // change control. Error *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"` // schedule indicates whether the change control was flagged // to be scheduled (`schedule.value` set to some timestamp) or // unscheduled (`schedule.value` set to `nil`) for execution. Schedule *TimestampFlag `protobuf:"bytes,7,opt,name=schedule,proto3" json:"schedule,omitempty"` // device_ids is a list of device IDs on which the change control will operate. DeviceIds *fmp.RepeatedString `protobuf:"bytes,8,opt,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // device_id_to_stage_ids is a map of device IDs to the stages present in the // specified Change state. // This is not affected by the device ID based custom filtering and will contain // info about all the devices associated with a CC ID. DeviceIdToStageIds *DeviceToStageMap `protobuf:"bytes,9,opt,name=device_id_to_stage_ids,json=deviceIdToStageIds,proto3" json:"device_id_to_stage_ids,omitempty"` // contains filtered or unexported fields }
ChangeControl holds the configuration and status of a change control.
func (*ChangeControl) Descriptor
deprecated
func (*ChangeControl) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControl.ProtoReflect.Descriptor instead.
func (*ChangeControl) GetApprove ¶
func (x *ChangeControl) GetApprove() *Flag
func (*ChangeControl) GetChange ¶
func (x *ChangeControl) GetChange() *Change
func (*ChangeControl) GetDeviceIdToStageIds ¶
func (x *ChangeControl) GetDeviceIdToStageIds() *DeviceToStageMap
func (*ChangeControl) GetDeviceIds ¶
func (x *ChangeControl) GetDeviceIds() *fmp.RepeatedString
func (*ChangeControl) GetError ¶
func (x *ChangeControl) GetError() *wrapperspb.StringValue
func (*ChangeControl) GetKey ¶
func (x *ChangeControl) GetKey() *ChangeControlKey
func (*ChangeControl) GetSchedule ¶
func (x *ChangeControl) GetSchedule() *TimestampFlag
func (*ChangeControl) GetStart ¶
func (x *ChangeControl) GetStart() *Flag
func (*ChangeControl) GetStatus ¶
func (x *ChangeControl) GetStatus() ChangeControlStatus
func (*ChangeControl) ProtoMessage ¶
func (*ChangeControl) ProtoMessage()
func (*ChangeControl) ProtoReflect ¶
func (x *ChangeControl) ProtoReflect() protoreflect.Message
func (*ChangeControl) Reset ¶
func (x *ChangeControl) Reset()
func (*ChangeControl) String ¶
func (x *ChangeControl) String() string
type ChangeControlBatchedStreamRequest ¶
type ChangeControlBatchedStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ChangeControl `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // For each ChangeControl in the list, all populated fields are considered ANDed together // as a filtering operation. Similarly, the list itself is ORed such that any individual // filter that matches a given ChangeControl is streamed to the user. Filter *Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ChangeControl at end. // - Each ChangeControl response is fully-specified (all fields set). // - start: Returns the state of each ChangeControl at start, followed by updates until now. // - Each ChangeControl response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ChangeControl at start, followed by updates // until end. // - Each ChangeControl response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // MaxMessages limits the maximum number of messages that can be contained in one batch. // MaxMessages is required to be at least 1. // The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) // INTERNAL_BATCH_LIMIT is set based on the maximum message size. MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlBatchedStreamRequest) Descriptor
deprecated
func (*ChangeControlBatchedStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlBatchedStreamRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlBatchedStreamRequest) GetFilter ¶
func (x *ChangeControlBatchedStreamRequest) GetFilter() *Filter
func (*ChangeControlBatchedStreamRequest) GetMaxMessages ¶
func (x *ChangeControlBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
func (*ChangeControlBatchedStreamRequest) GetPartialEqFilter ¶
func (x *ChangeControlBatchedStreamRequest) GetPartialEqFilter() []*ChangeControl
func (*ChangeControlBatchedStreamRequest) GetTime ¶
func (x *ChangeControlBatchedStreamRequest) GetTime() *time.TimeBounds
func (*ChangeControlBatchedStreamRequest) ProtoMessage ¶
func (*ChangeControlBatchedStreamRequest) ProtoMessage()
func (*ChangeControlBatchedStreamRequest) ProtoReflect ¶
func (x *ChangeControlBatchedStreamRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlBatchedStreamRequest) Reset ¶
func (x *ChangeControlBatchedStreamRequest) Reset()
func (*ChangeControlBatchedStreamRequest) String ¶
func (x *ChangeControlBatchedStreamRequest) String() string
type ChangeControlBatchedStreamResponse ¶
type ChangeControlBatchedStreamResponse struct { // Values are the values deemed relevant to the initiating request. // The length of this structure is guaranteed to be between (inclusive) 1 and // min(req.max_messages, INTERNAL_BATCH_LIMIT). Responses []*ChangeControlStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlBatchedStreamResponse) Descriptor
deprecated
func (*ChangeControlBatchedStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlBatchedStreamResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlBatchedStreamResponse) GetResponses ¶
func (x *ChangeControlBatchedStreamResponse) GetResponses() []*ChangeControlStreamResponse
func (*ChangeControlBatchedStreamResponse) ProtoMessage ¶
func (*ChangeControlBatchedStreamResponse) ProtoMessage()
func (*ChangeControlBatchedStreamResponse) ProtoReflect ¶
func (x *ChangeControlBatchedStreamResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlBatchedStreamResponse) Reset ¶
func (x *ChangeControlBatchedStreamResponse) Reset()
func (*ChangeControlBatchedStreamResponse) String ¶
func (x *ChangeControlBatchedStreamResponse) String() string
type ChangeControlConfig ¶
type ChangeControlConfig struct { // key uniquely identifies the change control. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // change is the change subject to execution. Change *ChangeConfig `protobuf:"bytes,2,opt,name=change,proto3" json:"change,omitempty"` // start is the flag to start (`start.value` set to `true`) // or stop (`start.value` set to `false`) execution of the // change control. Start *FlagConfig `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"` // schedule is the flag to schedule (`schedule.value` set to // some timestamp) or unschedule (`schedule.value` set to // `nil`) the change control for execution. Schedule *TimestampFlagConfig `protobuf:"bytes,4,opt,name=schedule,proto3" json:"schedule,omitempty"` // contains filtered or unexported fields }
ChangeControlConfig holds the configuration of a change control.
func (*ChangeControlConfig) Descriptor
deprecated
func (*ChangeControlConfig) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfig.ProtoReflect.Descriptor instead.
func (*ChangeControlConfig) GetChange ¶
func (x *ChangeControlConfig) GetChange() *ChangeConfig
func (*ChangeControlConfig) GetKey ¶
func (x *ChangeControlConfig) GetKey() *ChangeControlKey
func (*ChangeControlConfig) GetSchedule ¶
func (x *ChangeControlConfig) GetSchedule() *TimestampFlagConfig
func (*ChangeControlConfig) GetStart ¶
func (x *ChangeControlConfig) GetStart() *FlagConfig
func (*ChangeControlConfig) ProtoMessage ¶
func (*ChangeControlConfig) ProtoMessage()
func (*ChangeControlConfig) ProtoReflect ¶
func (x *ChangeControlConfig) ProtoReflect() protoreflect.Message
func (*ChangeControlConfig) Reset ¶
func (x *ChangeControlConfig) Reset()
func (*ChangeControlConfig) String ¶
func (x *ChangeControlConfig) String() string
type ChangeControlConfigBatchedStreamRequest ¶
type ChangeControlConfigBatchedStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ChangeControlConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ChangeControlConfig at end. // - Each ChangeControlConfig response is fully-specified (all fields set). // - start: Returns the state of each ChangeControlConfig at start, followed by updates until now. // - Each ChangeControlConfig response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ChangeControlConfig at start, followed by updates // until end. // - Each ChangeControlConfig response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // MaxMessages limits the maximum number of messages that can be contained in one batch. // MaxMessages is required to be at least 1. // The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT) // INTERNAL_BATCH_LIMIT is set based on the maximum message size. MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigBatchedStreamRequest) Descriptor
deprecated
func (*ChangeControlConfigBatchedStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigBatchedStreamRequest) GetMaxMessages ¶
func (x *ChangeControlConfigBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value
func (*ChangeControlConfigBatchedStreamRequest) GetPartialEqFilter ¶
func (x *ChangeControlConfigBatchedStreamRequest) GetPartialEqFilter() []*ChangeControlConfig
func (*ChangeControlConfigBatchedStreamRequest) GetTime ¶
func (x *ChangeControlConfigBatchedStreamRequest) GetTime() *time.TimeBounds
func (*ChangeControlConfigBatchedStreamRequest) ProtoMessage ¶
func (*ChangeControlConfigBatchedStreamRequest) ProtoMessage()
func (*ChangeControlConfigBatchedStreamRequest) ProtoReflect ¶
func (x *ChangeControlConfigBatchedStreamRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigBatchedStreamRequest) Reset ¶
func (x *ChangeControlConfigBatchedStreamRequest) Reset()
func (*ChangeControlConfigBatchedStreamRequest) String ¶
func (x *ChangeControlConfigBatchedStreamRequest) String() string
type ChangeControlConfigBatchedStreamResponse ¶
type ChangeControlConfigBatchedStreamResponse struct { // Values are the values deemed relevant to the initiating request. // The length of this structure is guaranteed to be between (inclusive) 1 and // min(req.max_messages, INTERNAL_BATCH_LIMIT). Responses []*ChangeControlConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigBatchedStreamResponse) Descriptor
deprecated
func (*ChangeControlConfigBatchedStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigBatchedStreamResponse) GetResponses ¶
func (x *ChangeControlConfigBatchedStreamResponse) GetResponses() []*ChangeControlConfigStreamResponse
func (*ChangeControlConfigBatchedStreamResponse) ProtoMessage ¶
func (*ChangeControlConfigBatchedStreamResponse) ProtoMessage()
func (*ChangeControlConfigBatchedStreamResponse) ProtoReflect ¶
func (x *ChangeControlConfigBatchedStreamResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigBatchedStreamResponse) Reset ¶
func (x *ChangeControlConfigBatchedStreamResponse) Reset()
func (*ChangeControlConfigBatchedStreamResponse) String ¶
func (x *ChangeControlConfigBatchedStreamResponse) String() string
type ChangeControlConfigDeleteAllRequest ¶
type ChangeControlConfigDeleteAllRequest struct { // PartialEqFilter provides a way to server-side filter a DeleteAll. // This requires all provided fields to be equal to the response. // A filtered DeleteAll will use GetAll with filter to find things to delete. PartialEqFilter []*ChangeControlConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigDeleteAllRequest) Descriptor
deprecated
func (*ChangeControlConfigDeleteAllRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteAllRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteAllRequest) GetPartialEqFilter ¶
func (x *ChangeControlConfigDeleteAllRequest) GetPartialEqFilter() []*ChangeControlConfig
func (*ChangeControlConfigDeleteAllRequest) ProtoMessage ¶
func (*ChangeControlConfigDeleteAllRequest) ProtoMessage()
func (*ChangeControlConfigDeleteAllRequest) ProtoReflect ¶
func (x *ChangeControlConfigDeleteAllRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteAllRequest) Reset ¶
func (x *ChangeControlConfigDeleteAllRequest) Reset()
func (*ChangeControlConfigDeleteAllRequest) String ¶
func (x *ChangeControlConfigDeleteAllRequest) String() string
type ChangeControlConfigDeleteAllResponse ¶
type ChangeControlConfigDeleteAllResponse struct { // This describes the class of delete error. // A DeleteAllResponse is only sent when there is an error. Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"` // This indicates the error message from the delete failure. Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // This is the key of the ChangeControlConfig instance that failed to be deleted. Key *ChangeControlKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the (UTC) timestamp when the key was being deleted. Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigDeleteAllResponse) Descriptor
deprecated
func (*ChangeControlConfigDeleteAllResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteAllResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteAllResponse) GetError ¶
func (x *ChangeControlConfigDeleteAllResponse) GetError() *wrapperspb.StringValue
func (*ChangeControlConfigDeleteAllResponse) GetKey ¶
func (x *ChangeControlConfigDeleteAllResponse) GetKey() *ChangeControlKey
func (*ChangeControlConfigDeleteAllResponse) GetTime ¶
func (x *ChangeControlConfigDeleteAllResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigDeleteAllResponse) GetType ¶
func (x *ChangeControlConfigDeleteAllResponse) GetType() fmp.DeleteError
func (*ChangeControlConfigDeleteAllResponse) ProtoMessage ¶
func (*ChangeControlConfigDeleteAllResponse) ProtoMessage()
func (*ChangeControlConfigDeleteAllResponse) ProtoReflect ¶
func (x *ChangeControlConfigDeleteAllResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteAllResponse) Reset ¶
func (x *ChangeControlConfigDeleteAllResponse) Reset()
func (*ChangeControlConfigDeleteAllResponse) String ¶
func (x *ChangeControlConfigDeleteAllResponse) String() string
type ChangeControlConfigDeleteRequest ¶
type ChangeControlConfigDeleteRequest struct { // Key indicates which ChangeControlConfig instance to remove. // This field must always be set. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigDeleteRequest) Descriptor
deprecated
func (*ChangeControlConfigDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteRequest) GetKey ¶
func (x *ChangeControlConfigDeleteRequest) GetKey() *ChangeControlKey
func (*ChangeControlConfigDeleteRequest) ProtoMessage ¶
func (*ChangeControlConfigDeleteRequest) ProtoMessage()
func (*ChangeControlConfigDeleteRequest) ProtoReflect ¶
func (x *ChangeControlConfigDeleteRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteRequest) Reset ¶
func (x *ChangeControlConfigDeleteRequest) Reset()
func (*ChangeControlConfigDeleteRequest) String ¶
func (x *ChangeControlConfigDeleteRequest) String() string
type ChangeControlConfigDeleteResponse ¶
type ChangeControlConfigDeleteResponse struct { // Key echoes back the key of the deleted ChangeControlConfig instance. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the (UTC) timestamp at which the system recognizes the // deletion. The only guarantees made about this timestamp are: // // - it is after the time the request was received // - a time-ranged query with StartTime==DeletedAt will not include this instance. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigDeleteResponse) Descriptor
deprecated
func (*ChangeControlConfigDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteResponse) GetKey ¶
func (x *ChangeControlConfigDeleteResponse) GetKey() *ChangeControlKey
func (*ChangeControlConfigDeleteResponse) GetTime ¶
func (x *ChangeControlConfigDeleteResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigDeleteResponse) ProtoMessage ¶
func (*ChangeControlConfigDeleteResponse) ProtoMessage()
func (*ChangeControlConfigDeleteResponse) ProtoReflect ¶
func (x *ChangeControlConfigDeleteResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteResponse) Reset ¶
func (x *ChangeControlConfigDeleteResponse) Reset()
func (*ChangeControlConfigDeleteResponse) String ¶
func (x *ChangeControlConfigDeleteResponse) String() string
type ChangeControlConfigDeleteSomeRequest ¶
type ChangeControlConfigDeleteSomeRequest struct { // key contains a list of ChangeControlConfig keys to delete Keys []*ChangeControlKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigDeleteSomeRequest) Descriptor
deprecated
func (*ChangeControlConfigDeleteSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteSomeRequest) GetKeys ¶
func (x *ChangeControlConfigDeleteSomeRequest) GetKeys() []*ChangeControlKey
func (*ChangeControlConfigDeleteSomeRequest) ProtoMessage ¶
func (*ChangeControlConfigDeleteSomeRequest) ProtoMessage()
func (*ChangeControlConfigDeleteSomeRequest) ProtoReflect ¶
func (x *ChangeControlConfigDeleteSomeRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteSomeRequest) Reset ¶
func (x *ChangeControlConfigDeleteSomeRequest) Reset()
func (*ChangeControlConfigDeleteSomeRequest) String ¶
func (x *ChangeControlConfigDeleteSomeRequest) String() string
type ChangeControlConfigDeleteSomeResponse ¶
type ChangeControlConfigDeleteSomeResponse struct { Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
ChangeControlConfigDeleteSomeResponse is only sent when there is an error.
func (*ChangeControlConfigDeleteSomeResponse) Descriptor
deprecated
func (*ChangeControlConfigDeleteSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigDeleteSomeResponse) GetError ¶
func (x *ChangeControlConfigDeleteSomeResponse) GetError() string
func (*ChangeControlConfigDeleteSomeResponse) GetKey ¶
func (x *ChangeControlConfigDeleteSomeResponse) GetKey() *ChangeControlKey
func (*ChangeControlConfigDeleteSomeResponse) ProtoMessage ¶
func (*ChangeControlConfigDeleteSomeResponse) ProtoMessage()
func (*ChangeControlConfigDeleteSomeResponse) ProtoReflect ¶
func (x *ChangeControlConfigDeleteSomeResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigDeleteSomeResponse) Reset ¶
func (x *ChangeControlConfigDeleteSomeResponse) Reset()
func (*ChangeControlConfigDeleteSomeResponse) String ¶
func (x *ChangeControlConfigDeleteSomeResponse) String() string
type ChangeControlConfigRequest ¶
type ChangeControlConfigRequest struct { // Key uniquely identifies a ChangeControlConfig instance to retrieve. // This value must be populated. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigRequest) Descriptor
deprecated
func (*ChangeControlConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigRequest) GetKey ¶
func (x *ChangeControlConfigRequest) GetKey() *ChangeControlKey
func (*ChangeControlConfigRequest) GetTime ¶
func (x *ChangeControlConfigRequest) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigRequest) ProtoMessage ¶
func (*ChangeControlConfigRequest) ProtoMessage()
func (*ChangeControlConfigRequest) ProtoReflect ¶
func (x *ChangeControlConfigRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigRequest) Reset ¶
func (x *ChangeControlConfigRequest) Reset()
func (*ChangeControlConfigRequest) String ¶
func (x *ChangeControlConfigRequest) String() string
type ChangeControlConfigResponse ¶
type ChangeControlConfigResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ChangeControlConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time carries the (UTC) timestamp of the last-modification of the // ChangeControlConfig instance in this response. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigResponse) Descriptor
deprecated
func (*ChangeControlConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigResponse) GetTime ¶
func (x *ChangeControlConfigResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigResponse) GetValue ¶
func (x *ChangeControlConfigResponse) GetValue() *ChangeControlConfig
func (*ChangeControlConfigResponse) ProtoMessage ¶
func (*ChangeControlConfigResponse) ProtoMessage()
func (*ChangeControlConfigResponse) ProtoReflect ¶
func (x *ChangeControlConfigResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigResponse) Reset ¶
func (x *ChangeControlConfigResponse) Reset()
func (*ChangeControlConfigResponse) String ¶
func (x *ChangeControlConfigResponse) String() string
type ChangeControlConfigServiceClient ¶
type ChangeControlConfigServiceClient interface { GetOne(ctx context.Context, in *ChangeControlConfigRequest, opts ...grpc.CallOption) (*ChangeControlConfigResponse, error) GetSome(ctx context.Context, in *ChangeControlConfigSomeRequest, opts ...grpc.CallOption) (ChangeControlConfigService_GetSomeClient, error) GetAll(ctx context.Context, in *ChangeControlConfigStreamRequest, opts ...grpc.CallOption) (ChangeControlConfigService_GetAllClient, error) Subscribe(ctx context.Context, in *ChangeControlConfigStreamRequest, opts ...grpc.CallOption) (ChangeControlConfigService_SubscribeClient, error) GetMeta(ctx context.Context, in *ChangeControlConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error) SubscribeMeta(ctx context.Context, in *ChangeControlConfigStreamRequest, opts ...grpc.CallOption) (ChangeControlConfigService_SubscribeMetaClient, error) Set(ctx context.Context, in *ChangeControlConfigSetRequest, opts ...grpc.CallOption) (*ChangeControlConfigSetResponse, error) SetSome(ctx context.Context, in *ChangeControlConfigSetSomeRequest, opts ...grpc.CallOption) (ChangeControlConfigService_SetSomeClient, error) Delete(ctx context.Context, in *ChangeControlConfigDeleteRequest, opts ...grpc.CallOption) (*ChangeControlConfigDeleteResponse, error) DeleteSome(ctx context.Context, in *ChangeControlConfigDeleteSomeRequest, opts ...grpc.CallOption) (ChangeControlConfigService_DeleteSomeClient, error) DeleteAll(ctx context.Context, in *ChangeControlConfigDeleteAllRequest, opts ...grpc.CallOption) (ChangeControlConfigService_DeleteAllClient, error) GetAllBatched(ctx context.Context, in *ChangeControlConfigBatchedStreamRequest, opts ...grpc.CallOption) (ChangeControlConfigService_GetAllBatchedClient, error) SubscribeBatched(ctx context.Context, in *ChangeControlConfigBatchedStreamRequest, opts ...grpc.CallOption) (ChangeControlConfigService_SubscribeBatchedClient, error) }
ChangeControlConfigServiceClient is the client API for ChangeControlConfigService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewChangeControlConfigServiceClient ¶
func NewChangeControlConfigServiceClient(cc grpc.ClientConnInterface) ChangeControlConfigServiceClient
type ChangeControlConfigServiceServer ¶
type ChangeControlConfigServiceServer interface { GetOne(context.Context, *ChangeControlConfigRequest) (*ChangeControlConfigResponse, error) GetSome(*ChangeControlConfigSomeRequest, ChangeControlConfigService_GetSomeServer) error GetAll(*ChangeControlConfigStreamRequest, ChangeControlConfigService_GetAllServer) error Subscribe(*ChangeControlConfigStreamRequest, ChangeControlConfigService_SubscribeServer) error GetMeta(context.Context, *ChangeControlConfigStreamRequest) (*MetaResponse, error) SubscribeMeta(*ChangeControlConfigStreamRequest, ChangeControlConfigService_SubscribeMetaServer) error Set(context.Context, *ChangeControlConfigSetRequest) (*ChangeControlConfigSetResponse, error) SetSome(*ChangeControlConfigSetSomeRequest, ChangeControlConfigService_SetSomeServer) error Delete(context.Context, *ChangeControlConfigDeleteRequest) (*ChangeControlConfigDeleteResponse, error) DeleteSome(*ChangeControlConfigDeleteSomeRequest, ChangeControlConfigService_DeleteSomeServer) error DeleteAll(*ChangeControlConfigDeleteAllRequest, ChangeControlConfigService_DeleteAllServer) error GetAllBatched(*ChangeControlConfigBatchedStreamRequest, ChangeControlConfigService_GetAllBatchedServer) error SubscribeBatched(*ChangeControlConfigBatchedStreamRequest, ChangeControlConfigService_SubscribeBatchedServer) error // contains filtered or unexported methods }
ChangeControlConfigServiceServer is the server API for ChangeControlConfigService service. All implementations must embed UnimplementedChangeControlConfigServiceServer for forward compatibility
type ChangeControlConfigService_DeleteAllClient ¶
type ChangeControlConfigService_DeleteAllClient interface { Recv() (*ChangeControlConfigDeleteAllResponse, error) grpc.ClientStream }
type ChangeControlConfigService_DeleteAllServer ¶
type ChangeControlConfigService_DeleteAllServer interface { Send(*ChangeControlConfigDeleteAllResponse) error grpc.ServerStream }
type ChangeControlConfigService_DeleteSomeClient ¶
type ChangeControlConfigService_DeleteSomeClient interface { Recv() (*ChangeControlConfigDeleteSomeResponse, error) grpc.ClientStream }
type ChangeControlConfigService_DeleteSomeServer ¶
type ChangeControlConfigService_DeleteSomeServer interface { Send(*ChangeControlConfigDeleteSomeResponse) error grpc.ServerStream }
type ChangeControlConfigService_GetAllBatchedClient ¶
type ChangeControlConfigService_GetAllBatchedClient interface { Recv() (*ChangeControlConfigBatchedStreamResponse, error) grpc.ClientStream }
type ChangeControlConfigService_GetAllBatchedServer ¶
type ChangeControlConfigService_GetAllBatchedServer interface { Send(*ChangeControlConfigBatchedStreamResponse) error grpc.ServerStream }
type ChangeControlConfigService_GetAllClient ¶
type ChangeControlConfigService_GetAllClient interface { Recv() (*ChangeControlConfigStreamResponse, error) grpc.ClientStream }
type ChangeControlConfigService_GetAllServer ¶
type ChangeControlConfigService_GetAllServer interface { Send(*ChangeControlConfigStreamResponse) error grpc.ServerStream }
type ChangeControlConfigService_GetSomeClient ¶
type ChangeControlConfigService_GetSomeClient interface { Recv() (*ChangeControlConfigSomeResponse, error) grpc.ClientStream }
type ChangeControlConfigService_GetSomeServer ¶
type ChangeControlConfigService_GetSomeServer interface { Send(*ChangeControlConfigSomeResponse) error grpc.ServerStream }
type ChangeControlConfigService_SetSomeClient ¶
type ChangeControlConfigService_SetSomeClient interface { Recv() (*ChangeControlConfigSetSomeResponse, error) grpc.ClientStream }
type ChangeControlConfigService_SetSomeServer ¶
type ChangeControlConfigService_SetSomeServer interface { Send(*ChangeControlConfigSetSomeResponse) error grpc.ServerStream }
type ChangeControlConfigService_SubscribeBatchedClient ¶
type ChangeControlConfigService_SubscribeBatchedClient interface { Recv() (*ChangeControlConfigBatchedStreamResponse, error) grpc.ClientStream }
type ChangeControlConfigService_SubscribeBatchedServer ¶
type ChangeControlConfigService_SubscribeBatchedServer interface { Send(*ChangeControlConfigBatchedStreamResponse) error grpc.ServerStream }
type ChangeControlConfigService_SubscribeClient ¶
type ChangeControlConfigService_SubscribeClient interface { Recv() (*ChangeControlConfigStreamResponse, error) grpc.ClientStream }
type ChangeControlConfigService_SubscribeMetaClient ¶
type ChangeControlConfigService_SubscribeMetaClient interface { Recv() (*MetaResponse, error) grpc.ClientStream }
type ChangeControlConfigService_SubscribeMetaServer ¶
type ChangeControlConfigService_SubscribeMetaServer interface { Send(*MetaResponse) error grpc.ServerStream }
type ChangeControlConfigService_SubscribeServer ¶
type ChangeControlConfigService_SubscribeServer interface { Send(*ChangeControlConfigStreamResponse) error grpc.ServerStream }
type ChangeControlConfigSetRequest ¶
type ChangeControlConfigSetRequest struct { // ChangeControlConfig carries the value to set into the datastore. // See the documentation on the ChangeControlConfig struct for which fields are required. Value *ChangeControlConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSetRequest) Descriptor
deprecated
func (*ChangeControlConfigSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSetRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSetRequest) GetValue ¶
func (x *ChangeControlConfigSetRequest) GetValue() *ChangeControlConfig
func (*ChangeControlConfigSetRequest) ProtoMessage ¶
func (*ChangeControlConfigSetRequest) ProtoMessage()
func (*ChangeControlConfigSetRequest) ProtoReflect ¶
func (x *ChangeControlConfigSetRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSetRequest) Reset ¶
func (x *ChangeControlConfigSetRequest) Reset()
func (*ChangeControlConfigSetRequest) String ¶
func (x *ChangeControlConfigSetRequest) String() string
type ChangeControlConfigSetResponse ¶
type ChangeControlConfigSetResponse struct { // Value carries all the values given in the ChangeControlConfigSetRequest as well // as any server-generated values. Value *ChangeControlConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time indicates the (UTC) timestamp at which the system recognizes the // creation. The only guarantees made about this timestamp are: // // - it is after the time the request was received // - a time-ranged query with StartTime==CreatedAt will include this instance. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSetResponse) Descriptor
deprecated
func (*ChangeControlConfigSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSetResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSetResponse) GetTime ¶
func (x *ChangeControlConfigSetResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigSetResponse) GetValue ¶
func (x *ChangeControlConfigSetResponse) GetValue() *ChangeControlConfig
func (*ChangeControlConfigSetResponse) ProtoMessage ¶
func (*ChangeControlConfigSetResponse) ProtoMessage()
func (*ChangeControlConfigSetResponse) ProtoReflect ¶
func (x *ChangeControlConfigSetResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSetResponse) Reset ¶
func (x *ChangeControlConfigSetResponse) Reset()
func (*ChangeControlConfigSetResponse) String ¶
func (x *ChangeControlConfigSetResponse) String() string
type ChangeControlConfigSetSomeRequest ¶
type ChangeControlConfigSetSomeRequest struct { // value contains a list of ChangeControlConfig values to write. // It is possible to provide more values than can fit within either: // - the maxiumum send size of the client // - the maximum receive size of the server // // If this error occurs you must reduce the number of values sent. // See gRPC "maximum message size" documentation for more information. Values []*ChangeControlConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSetSomeRequest) Descriptor
deprecated
func (*ChangeControlConfigSetSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSetSomeRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSetSomeRequest) GetValues ¶
func (x *ChangeControlConfigSetSomeRequest) GetValues() []*ChangeControlConfig
func (*ChangeControlConfigSetSomeRequest) ProtoMessage ¶
func (*ChangeControlConfigSetSomeRequest) ProtoMessage()
func (*ChangeControlConfigSetSomeRequest) ProtoReflect ¶
func (x *ChangeControlConfigSetSomeRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSetSomeRequest) Reset ¶
func (x *ChangeControlConfigSetSomeRequest) Reset()
func (*ChangeControlConfigSetSomeRequest) String ¶
func (x *ChangeControlConfigSetSomeRequest) String() string
type ChangeControlConfigSetSomeResponse ¶
type ChangeControlConfigSetSomeResponse struct { Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSetSomeResponse) Descriptor
deprecated
func (*ChangeControlConfigSetSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSetSomeResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSetSomeResponse) GetError ¶
func (x *ChangeControlConfigSetSomeResponse) GetError() string
func (*ChangeControlConfigSetSomeResponse) GetKey ¶
func (x *ChangeControlConfigSetSomeResponse) GetKey() *ChangeControlKey
func (*ChangeControlConfigSetSomeResponse) ProtoMessage ¶
func (*ChangeControlConfigSetSomeResponse) ProtoMessage()
func (*ChangeControlConfigSetSomeResponse) ProtoReflect ¶
func (x *ChangeControlConfigSetSomeResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSetSomeResponse) Reset ¶
func (x *ChangeControlConfigSetSomeResponse) Reset()
func (*ChangeControlConfigSetSomeResponse) String ¶
func (x *ChangeControlConfigSetSomeResponse) String() string
type ChangeControlConfigSomeRequest ¶
type ChangeControlConfigSomeRequest struct { Keys []*ChangeControlKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSomeRequest) Descriptor
deprecated
func (*ChangeControlConfigSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSomeRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSomeRequest) GetKeys ¶
func (x *ChangeControlConfigSomeRequest) GetKeys() []*ChangeControlKey
func (*ChangeControlConfigSomeRequest) GetTime ¶
func (x *ChangeControlConfigSomeRequest) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigSomeRequest) ProtoMessage ¶
func (*ChangeControlConfigSomeRequest) ProtoMessage()
func (*ChangeControlConfigSomeRequest) ProtoReflect ¶
func (x *ChangeControlConfigSomeRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSomeRequest) Reset ¶
func (x *ChangeControlConfigSomeRequest) Reset()
func (*ChangeControlConfigSomeRequest) String ¶
func (x *ChangeControlConfigSomeRequest) String() string
type ChangeControlConfigSomeResponse ¶
type ChangeControlConfigSomeResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ChangeControlConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Error is an optional field. // It should be filled when there is an error in the GetSome process. Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigSomeResponse) Descriptor
deprecated
func (*ChangeControlConfigSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigSomeResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigSomeResponse) GetError ¶
func (x *ChangeControlConfigSomeResponse) GetError() *wrapperspb.StringValue
func (*ChangeControlConfigSomeResponse) GetTime ¶
func (x *ChangeControlConfigSomeResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigSomeResponse) GetValue ¶
func (x *ChangeControlConfigSomeResponse) GetValue() *ChangeControlConfig
func (*ChangeControlConfigSomeResponse) ProtoMessage ¶
func (*ChangeControlConfigSomeResponse) ProtoMessage()
func (*ChangeControlConfigSomeResponse) ProtoReflect ¶
func (x *ChangeControlConfigSomeResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigSomeResponse) Reset ¶
func (x *ChangeControlConfigSomeResponse) Reset()
func (*ChangeControlConfigSomeResponse) String ¶
func (x *ChangeControlConfigSomeResponse) String() string
type ChangeControlConfigStreamRequest ¶
type ChangeControlConfigStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ChangeControlConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ChangeControlConfig at end. // - Each ChangeControlConfig response is fully-specified (all fields set). // - start: Returns the state of each ChangeControlConfig at start, followed by updates until now. // - Each ChangeControlConfig response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ChangeControlConfig at start, followed by updates // until end. // - Each ChangeControlConfig response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigStreamRequest) Descriptor
deprecated
func (*ChangeControlConfigStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigStreamRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigStreamRequest) GetPartialEqFilter ¶
func (x *ChangeControlConfigStreamRequest) GetPartialEqFilter() []*ChangeControlConfig
func (*ChangeControlConfigStreamRequest) GetTime ¶
func (x *ChangeControlConfigStreamRequest) GetTime() *time.TimeBounds
func (*ChangeControlConfigStreamRequest) ProtoMessage ¶
func (*ChangeControlConfigStreamRequest) ProtoMessage()
func (*ChangeControlConfigStreamRequest) ProtoReflect ¶
func (x *ChangeControlConfigStreamRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigStreamRequest) Reset ¶
func (x *ChangeControlConfigStreamRequest) Reset()
func (*ChangeControlConfigStreamRequest) String ¶
func (x *ChangeControlConfigStreamRequest) String() string
type ChangeControlConfigStreamResponse ¶
type ChangeControlConfigStreamResponse struct { // Value is a value deemed relevant to the initiating request. // This structure will always have its key-field populated. Which other fields are // populated, and why, depends on the value of Operation and what triggered this notification. Value *ChangeControlConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time holds the timestamp of this ChangeControlConfig's last modification. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // Operation indicates how the ChangeControlConfig value in this response should be considered. // Under non-subscribe requests, this value should always be INITIAL. In a subscription, // once all initial data is streamed and the client begins to receive modification updates, // you should not see INITIAL again. Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlConfigStreamResponse) Descriptor
deprecated
func (*ChangeControlConfigStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlConfigStreamResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlConfigStreamResponse) GetTime ¶
func (x *ChangeControlConfigStreamResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlConfigStreamResponse) GetType ¶
func (x *ChangeControlConfigStreamResponse) GetType() subscriptions.Operation
func (*ChangeControlConfigStreamResponse) GetValue ¶
func (x *ChangeControlConfigStreamResponse) GetValue() *ChangeControlConfig
func (*ChangeControlConfigStreamResponse) ProtoMessage ¶
func (*ChangeControlConfigStreamResponse) ProtoMessage()
func (*ChangeControlConfigStreamResponse) ProtoReflect ¶
func (x *ChangeControlConfigStreamResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlConfigStreamResponse) Reset ¶
func (x *ChangeControlConfigStreamResponse) Reset()
func (*ChangeControlConfigStreamResponse) String ¶
func (x *ChangeControlConfigStreamResponse) String() string
type ChangeControlKey ¶
type ChangeControlKey struct { // id is the ID of the change control. Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
ChangeControlKey uniquely identifies a change control.
func (*ChangeControlKey) Descriptor
deprecated
func (*ChangeControlKey) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlKey.ProtoReflect.Descriptor instead.
func (*ChangeControlKey) GetId ¶
func (x *ChangeControlKey) GetId() *wrapperspb.StringValue
func (*ChangeControlKey) ProtoMessage ¶
func (*ChangeControlKey) ProtoMessage()
func (*ChangeControlKey) ProtoReflect ¶
func (x *ChangeControlKey) ProtoReflect() protoreflect.Message
func (*ChangeControlKey) Reset ¶
func (x *ChangeControlKey) Reset()
func (*ChangeControlKey) String ¶
func (x *ChangeControlKey) String() string
type ChangeControlRequest ¶
type ChangeControlRequest struct { // Key uniquely identifies a ChangeControl instance to retrieve. // This value must be populated. Key *ChangeControlKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlRequest) Descriptor
deprecated
func (*ChangeControlRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlRequest) GetKey ¶
func (x *ChangeControlRequest) GetKey() *ChangeControlKey
func (*ChangeControlRequest) GetTime ¶
func (x *ChangeControlRequest) GetTime() *timestamppb.Timestamp
func (*ChangeControlRequest) ProtoMessage ¶
func (*ChangeControlRequest) ProtoMessage()
func (*ChangeControlRequest) ProtoReflect ¶
func (x *ChangeControlRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlRequest) Reset ¶
func (x *ChangeControlRequest) Reset()
func (*ChangeControlRequest) String ¶
func (x *ChangeControlRequest) String() string
type ChangeControlResponse ¶
type ChangeControlResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ChangeControl `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time carries the (UTC) timestamp of the last-modification of the // ChangeControl instance in this response. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlResponse) Descriptor
deprecated
func (*ChangeControlResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlResponse) GetTime ¶
func (x *ChangeControlResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlResponse) GetValue ¶
func (x *ChangeControlResponse) GetValue() *ChangeControl
func (*ChangeControlResponse) ProtoMessage ¶
func (*ChangeControlResponse) ProtoMessage()
func (*ChangeControlResponse) ProtoReflect ¶
func (x *ChangeControlResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlResponse) Reset ¶
func (x *ChangeControlResponse) Reset()
func (*ChangeControlResponse) String ¶
func (x *ChangeControlResponse) String() string
type ChangeControlServiceClient ¶
type ChangeControlServiceClient interface { GetOne(ctx context.Context, in *ChangeControlRequest, opts ...grpc.CallOption) (*ChangeControlResponse, error) GetSome(ctx context.Context, in *ChangeControlSomeRequest, opts ...grpc.CallOption) (ChangeControlService_GetSomeClient, error) GetAll(ctx context.Context, in *ChangeControlStreamRequest, opts ...grpc.CallOption) (ChangeControlService_GetAllClient, error) Subscribe(ctx context.Context, in *ChangeControlStreamRequest, opts ...grpc.CallOption) (ChangeControlService_SubscribeClient, error) GetMeta(ctx context.Context, in *ChangeControlStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error) SubscribeMeta(ctx context.Context, in *ChangeControlStreamRequest, opts ...grpc.CallOption) (ChangeControlService_SubscribeMetaClient, error) GetAllBatched(ctx context.Context, in *ChangeControlBatchedStreamRequest, opts ...grpc.CallOption) (ChangeControlService_GetAllBatchedClient, error) SubscribeBatched(ctx context.Context, in *ChangeControlBatchedStreamRequest, opts ...grpc.CallOption) (ChangeControlService_SubscribeBatchedClient, error) }
ChangeControlServiceClient is the client API for ChangeControlService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewChangeControlServiceClient ¶
func NewChangeControlServiceClient(cc grpc.ClientConnInterface) ChangeControlServiceClient
type ChangeControlServiceServer ¶
type ChangeControlServiceServer interface { GetOne(context.Context, *ChangeControlRequest) (*ChangeControlResponse, error) GetSome(*ChangeControlSomeRequest, ChangeControlService_GetSomeServer) error GetAll(*ChangeControlStreamRequest, ChangeControlService_GetAllServer) error Subscribe(*ChangeControlStreamRequest, ChangeControlService_SubscribeServer) error GetMeta(context.Context, *ChangeControlStreamRequest) (*MetaResponse, error) SubscribeMeta(*ChangeControlStreamRequest, ChangeControlService_SubscribeMetaServer) error GetAllBatched(*ChangeControlBatchedStreamRequest, ChangeControlService_GetAllBatchedServer) error SubscribeBatched(*ChangeControlBatchedStreamRequest, ChangeControlService_SubscribeBatchedServer) error // contains filtered or unexported methods }
ChangeControlServiceServer is the server API for ChangeControlService service. All implementations must embed UnimplementedChangeControlServiceServer for forward compatibility
type ChangeControlService_GetAllBatchedClient ¶
type ChangeControlService_GetAllBatchedClient interface { Recv() (*ChangeControlBatchedStreamResponse, error) grpc.ClientStream }
type ChangeControlService_GetAllBatchedServer ¶
type ChangeControlService_GetAllBatchedServer interface { Send(*ChangeControlBatchedStreamResponse) error grpc.ServerStream }
type ChangeControlService_GetAllClient ¶
type ChangeControlService_GetAllClient interface { Recv() (*ChangeControlStreamResponse, error) grpc.ClientStream }
type ChangeControlService_GetAllServer ¶
type ChangeControlService_GetAllServer interface { Send(*ChangeControlStreamResponse) error grpc.ServerStream }
type ChangeControlService_GetSomeClient ¶
type ChangeControlService_GetSomeClient interface { Recv() (*ChangeControlSomeResponse, error) grpc.ClientStream }
type ChangeControlService_GetSomeServer ¶
type ChangeControlService_GetSomeServer interface { Send(*ChangeControlSomeResponse) error grpc.ServerStream }
type ChangeControlService_SubscribeBatchedClient ¶
type ChangeControlService_SubscribeBatchedClient interface { Recv() (*ChangeControlBatchedStreamResponse, error) grpc.ClientStream }
type ChangeControlService_SubscribeBatchedServer ¶
type ChangeControlService_SubscribeBatchedServer interface { Send(*ChangeControlBatchedStreamResponse) error grpc.ServerStream }
type ChangeControlService_SubscribeClient ¶
type ChangeControlService_SubscribeClient interface { Recv() (*ChangeControlStreamResponse, error) grpc.ClientStream }
type ChangeControlService_SubscribeMetaClient ¶
type ChangeControlService_SubscribeMetaClient interface { Recv() (*MetaResponse, error) grpc.ClientStream }
type ChangeControlService_SubscribeMetaServer ¶
type ChangeControlService_SubscribeMetaServer interface { Send(*MetaResponse) error grpc.ServerStream }
type ChangeControlService_SubscribeServer ¶
type ChangeControlService_SubscribeServer interface { Send(*ChangeControlStreamResponse) error grpc.ServerStream }
type ChangeControlSomeRequest ¶
type ChangeControlSomeRequest struct { Keys []*ChangeControlKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // Time indicates the time for which you are interested in the data. // If no time is given, the server will use the time at which it makes the request. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlSomeRequest) Descriptor
deprecated
func (*ChangeControlSomeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlSomeRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlSomeRequest) GetKeys ¶
func (x *ChangeControlSomeRequest) GetKeys() []*ChangeControlKey
func (*ChangeControlSomeRequest) GetTime ¶
func (x *ChangeControlSomeRequest) GetTime() *timestamppb.Timestamp
func (*ChangeControlSomeRequest) ProtoMessage ¶
func (*ChangeControlSomeRequest) ProtoMessage()
func (*ChangeControlSomeRequest) ProtoReflect ¶
func (x *ChangeControlSomeRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlSomeRequest) Reset ¶
func (x *ChangeControlSomeRequest) Reset()
func (*ChangeControlSomeRequest) String ¶
func (x *ChangeControlSomeRequest) String() string
type ChangeControlSomeResponse ¶
type ChangeControlSomeResponse struct { // Value is the value requested. // This structure will be fully-populated as it exists in the datastore. If // optional fields were not given at creation, these fields will be empty or // set to default values. Value *ChangeControl `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Error is an optional field. // It should be filled when there is an error in the GetSome process. Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlSomeResponse) Descriptor
deprecated
func (*ChangeControlSomeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlSomeResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlSomeResponse) GetError ¶
func (x *ChangeControlSomeResponse) GetError() *wrapperspb.StringValue
func (*ChangeControlSomeResponse) GetTime ¶
func (x *ChangeControlSomeResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlSomeResponse) GetValue ¶
func (x *ChangeControlSomeResponse) GetValue() *ChangeControl
func (*ChangeControlSomeResponse) ProtoMessage ¶
func (*ChangeControlSomeResponse) ProtoMessage()
func (*ChangeControlSomeResponse) ProtoReflect ¶
func (x *ChangeControlSomeResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlSomeResponse) Reset ¶
func (x *ChangeControlSomeResponse) Reset()
func (*ChangeControlSomeResponse) String ¶
func (x *ChangeControlSomeResponse) String() string
type ChangeControlStatus ¶
type ChangeControlStatus int32
ChangeControlStatus defines the possible execution statuses of a change control.
const ( // CHANGE_CONTROL_STATUS_UNSPECIFIED means the change control status is unknown. ChangeControlStatus_CHANGE_CONTROL_STATUS_UNSPECIFIED ChangeControlStatus = 0 // CHANGE_CONTROL_STATUS_RUNNING means the change control has begun // execution. ChangeControlStatus_CHANGE_CONTROL_STATUS_RUNNING ChangeControlStatus = 1 // CHANGE_CONTROL_STATUS_COMPLETED means the change control has ceased // execution. Success/failure of a change control cannot be inferred // from this status alone but rather this status plus the change control // error. That is, no error implies success and some error implies failure. ChangeControlStatus_CHANGE_CONTROL_STATUS_COMPLETED ChangeControlStatus = 2 // CHANGE_CONTROL_STATUS_SCHEDULED means the change control has been // scheduled for execution at some time. Any failure that occurs during // this process will cause a transition back to the unspecified status, // a reset of the schedule flag by the system, and an error on the change // control reporting the details of the failure. ChangeControlStatus_CHANGE_CONTROL_STATUS_SCHEDULED ChangeControlStatus = 3 // CHANGE_CONTROL_STATUS_NOT_STARTED means the change control has not been // started. This would include approved and not approved change controls. ChangeControlStatus_CHANGE_CONTROL_STATUS_NOT_STARTED ChangeControlStatus = 4 )
func (ChangeControlStatus) Descriptor ¶
func (ChangeControlStatus) Descriptor() protoreflect.EnumDescriptor
func (ChangeControlStatus) Enum ¶
func (x ChangeControlStatus) Enum() *ChangeControlStatus
func (ChangeControlStatus) EnumDescriptor
deprecated
func (ChangeControlStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChangeControlStatus.Descriptor instead.
func (ChangeControlStatus) Number ¶
func (x ChangeControlStatus) Number() protoreflect.EnumNumber
func (ChangeControlStatus) String ¶
func (x ChangeControlStatus) String() string
func (ChangeControlStatus) Type ¶
func (ChangeControlStatus) Type() protoreflect.EnumType
type ChangeControlStreamRequest ¶
type ChangeControlStreamRequest struct { // PartialEqFilter provides a way to server-side filter a GetAll/Subscribe. // This requires all provided fields to be equal to the response. // // While transparent to users, this field also allows services to optimize internal // subscriptions if filter(s) are sufficiently specific. PartialEqFilter []*ChangeControl `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"` // For each ChangeControl in the list, all populated fields are considered ANDed together // as a filtering operation. Similarly, the list itself is ORed such that any individual // filter that matches a given ChangeControl is streamed to the user. Filter *Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` // TimeRange allows limiting response data to within a specified time window. // If this field is populated, at least one of the two time fields are required. // // For GetAll, the fields start and end can be used as follows: // // - end: Returns the state of each ChangeControl at end. // - Each ChangeControl response is fully-specified (all fields set). // - start: Returns the state of each ChangeControl at start, followed by updates until now. // - Each ChangeControl response at start is fully-specified, but updates may be partial. // - start and end: Returns the state of each ChangeControl at start, followed by updates // until end. // - Each ChangeControl response at start is fully-specified, but updates until end may // be partial. // // This field is not allowed in the Subscribe RPC. Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlStreamRequest) Descriptor
deprecated
func (*ChangeControlStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlStreamRequest.ProtoReflect.Descriptor instead.
func (*ChangeControlStreamRequest) GetFilter ¶
func (x *ChangeControlStreamRequest) GetFilter() *Filter
func (*ChangeControlStreamRequest) GetPartialEqFilter ¶
func (x *ChangeControlStreamRequest) GetPartialEqFilter() []*ChangeControl
func (*ChangeControlStreamRequest) GetTime ¶
func (x *ChangeControlStreamRequest) GetTime() *time.TimeBounds
func (*ChangeControlStreamRequest) ProtoMessage ¶
func (*ChangeControlStreamRequest) ProtoMessage()
func (*ChangeControlStreamRequest) ProtoReflect ¶
func (x *ChangeControlStreamRequest) ProtoReflect() protoreflect.Message
func (*ChangeControlStreamRequest) Reset ¶
func (x *ChangeControlStreamRequest) Reset()
func (*ChangeControlStreamRequest) String ¶
func (x *ChangeControlStreamRequest) String() string
type ChangeControlStreamResponse ¶
type ChangeControlStreamResponse struct { // Value is a value deemed relevant to the initiating request. // This structure will always have its key-field populated. Which other fields are // populated, and why, depends on the value of Operation and what triggered this notification. Value *ChangeControl `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Time holds the timestamp of this ChangeControl's last modification. Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // Operation indicates how the ChangeControl value in this response should be considered. // Under non-subscribe requests, this value should always be INITIAL. In a subscription, // once all initial data is streamed and the client begins to receive modification updates, // you should not see INITIAL again. Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ChangeControlStreamResponse) Descriptor
deprecated
func (*ChangeControlStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChangeControlStreamResponse.ProtoReflect.Descriptor instead.
func (*ChangeControlStreamResponse) GetTime ¶
func (x *ChangeControlStreamResponse) GetTime() *timestamppb.Timestamp
func (*ChangeControlStreamResponse) GetType ¶
func (x *ChangeControlStreamResponse) GetType() subscriptions.Operation
func (*ChangeControlStreamResponse) GetValue ¶
func (x *ChangeControlStreamResponse) GetValue() *ChangeControl
func (*ChangeControlStreamResponse) ProtoMessage ¶
func (*ChangeControlStreamResponse) ProtoMessage()
func (*ChangeControlStreamResponse) ProtoReflect ¶
func (x *ChangeControlStreamResponse) ProtoReflect() protoreflect.Message
func (*ChangeControlStreamResponse) Reset ¶
func (x *ChangeControlStreamResponse) Reset()
func (*ChangeControlStreamResponse) String ¶
func (x *ChangeControlStreamResponse) String() string
type DeviceToStageMap ¶
type DeviceToStageMap struct { // values maps the device ID with the stages which are associated with a device // in a changecontrol state model. Values map[string]*fmp.RepeatedString `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
DeviceToStageMap is a map of a device ID and its list of corresponding stages.
func (*DeviceToStageMap) Descriptor
deprecated
func (*DeviceToStageMap) Descriptor() ([]byte, []int)
Deprecated: Use DeviceToStageMap.ProtoReflect.Descriptor instead.
func (*DeviceToStageMap) GetValues ¶
func (x *DeviceToStageMap) GetValues() map[string]*fmp.RepeatedString
func (*DeviceToStageMap) ProtoMessage ¶
func (*DeviceToStageMap) ProtoMessage()
func (*DeviceToStageMap) ProtoReflect ¶
func (x *DeviceToStageMap) ProtoReflect() protoreflect.Message
func (*DeviceToStageMap) Reset ¶
func (x *DeviceToStageMap) Reset()
func (*DeviceToStageMap) String ¶
func (x *DeviceToStageMap) String() string
type Filter ¶
type Filter struct { // device_ids includes the list of device ids to be matched with devices // in the changecontrol state model. // At least one of the provided device ids must be present in CC devices field. DeviceIds *fmp.RepeatedString `protobuf:"bytes,1,opt,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"` // contains filtered or unexported fields }
Filter is used to filter changecontrols for requested device ids.
func (*Filter) Descriptor
deprecated
func (*Filter) GetDeviceIds ¶
func (x *Filter) GetDeviceIds() *fmp.RepeatedString
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type Flag ¶
type Flag struct { // value is the value of the flag (`true` or `false`). Value *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // notes are any notes associated with the setting of the flag. Notes *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty"` // time is the time at which the flag was last updated. Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // user is the user by which the flag was last updated. User *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
Flag holds the configuration of a boolean flag plus some information about when and by whom it was set.
func (*Flag) Descriptor
deprecated
func (*Flag) GetNotes ¶
func (x *Flag) GetNotes() *wrapperspb.StringValue
func (*Flag) GetTime ¶
func (x *Flag) GetTime() *timestamppb.Timestamp
func (*Flag) GetUser ¶
func (x *Flag) GetUser() *wrapperspb.StringValue
func (*Flag) GetValue ¶
func (x *Flag) GetValue() *wrapperspb.BoolValue
func (*Flag) ProtoMessage ¶
func (*Flag) ProtoMessage()
func (*Flag) ProtoReflect ¶
func (x *Flag) ProtoReflect() protoreflect.Message
type FlagConfig ¶
type FlagConfig struct { // value is the value of the flag (`true` or `false`). Value *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // notes are any notes associated with the flag value. Notes *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty"` // contains filtered or unexported fields }
FlagConfig is used to set a flag on a change control that takes a boolean value (e.g. start/stop, approve/unapprove).
func (*FlagConfig) Descriptor
deprecated
func (*FlagConfig) Descriptor() ([]byte, []int)
Deprecated: Use FlagConfig.ProtoReflect.Descriptor instead.
func (*FlagConfig) GetNotes ¶
func (x *FlagConfig) GetNotes() *wrapperspb.StringValue
func (*FlagConfig) GetValue ¶
func (x *FlagConfig) GetValue() *wrapperspb.BoolValue
func (*FlagConfig) ProtoMessage ¶
func (*FlagConfig) ProtoMessage()
func (*FlagConfig) ProtoReflect ¶
func (x *FlagConfig) ProtoReflect() protoreflect.Message
func (*FlagConfig) Reset ¶
func (x *FlagConfig) Reset()
func (*FlagConfig) String ¶
func (x *FlagConfig) String() string
type MetaResponse ¶
type MetaResponse struct { // Time holds the timestamp of the last item included in the metadata calculation. Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` // Operation indicates how the value in this response should be considered. // Under non-subscribe requests, this value should always be INITIAL. In a subscription, // once all initial data is streamed and the client begins to receive modification updates, // you should not see INITIAL again. Type subscriptions.Operation `protobuf:"varint,2,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"` // Count is the number of items present under the conditions of the request. Count *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*MetaResponse) Descriptor
deprecated
func (*MetaResponse) Descriptor() ([]byte, []int)
Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.
func (*MetaResponse) GetCount ¶
func (x *MetaResponse) GetCount() *wrapperspb.UInt32Value
func (*MetaResponse) GetTime ¶
func (x *MetaResponse) GetTime() *timestamppb.Timestamp
func (*MetaResponse) GetType ¶
func (x *MetaResponse) GetType() subscriptions.Operation
func (*MetaResponse) ProtoMessage ¶
func (*MetaResponse) ProtoMessage()
func (*MetaResponse) ProtoReflect ¶
func (x *MetaResponse) ProtoReflect() protoreflect.Message
func (*MetaResponse) Reset ¶
func (x *MetaResponse) Reset()
func (*MetaResponse) String ¶
func (x *MetaResponse) String() string
type RepeatedRepeatedString ¶
type RepeatedRepeatedString struct { // values is a list of `fmp.RepeatedString`. Values []*fmp.RepeatedString `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
RepeatedRepeatedString wraps a repeated `fmp.RepeatedString` to define a string matrix which is used to represent stage rows (see `StageConfig`).
func (*RepeatedRepeatedString) Descriptor
deprecated
func (*RepeatedRepeatedString) Descriptor() ([]byte, []int)
Deprecated: Use RepeatedRepeatedString.ProtoReflect.Descriptor instead.
func (*RepeatedRepeatedString) GetValues ¶
func (x *RepeatedRepeatedString) GetValues() []*fmp.RepeatedString
func (*RepeatedRepeatedString) ProtoMessage ¶
func (*RepeatedRepeatedString) ProtoMessage()
func (*RepeatedRepeatedString) ProtoReflect ¶
func (x *RepeatedRepeatedString) ProtoReflect() protoreflect.Message
func (*RepeatedRepeatedString) Reset ¶
func (x *RepeatedRepeatedString) Reset()
func (*RepeatedRepeatedString) String ¶
func (x *RepeatedRepeatedString) String() string
type Stage ¶
type Stage struct { // name is the name of the stage. Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // action is the action to perform during the stage. Action *Action `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // rows is a series of rows of parallel stages referenced // by ID. See `StageConfig.rows` for more details. Rows *RepeatedRepeatedString `protobuf:"bytes,3,opt,name=rows,proto3" json:"rows,omitempty"` // status is the execution status of the stage. Status StageStatus `protobuf:"varint,4,opt,name=status,proto3,enum=arista.changecontrol.v1.StageStatus" json:"status,omitempty"` // error is any error that occured during the execution // of the stage. Error *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` // start_time is the time when status change to Running StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // end_time is the time when status change to Completed EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // contains filtered or unexported fields }
Stage holds the configuration and status of a stage.
func (*Stage) Descriptor
deprecated
func (*Stage) GetEndTime ¶
func (x *Stage) GetEndTime() *timestamppb.Timestamp
func (*Stage) GetError ¶
func (x *Stage) GetError() *wrapperspb.StringValue
func (*Stage) GetName ¶
func (x *Stage) GetName() *wrapperspb.StringValue
func (*Stage) GetRows ¶
func (x *Stage) GetRows() *RepeatedRepeatedString
func (*Stage) GetStartTime ¶
func (x *Stage) GetStartTime() *timestamppb.Timestamp
func (*Stage) GetStatus ¶
func (x *Stage) GetStatus() StageStatus
func (*Stage) ProtoMessage ¶
func (*Stage) ProtoMessage()
func (*Stage) ProtoReflect ¶
func (x *Stage) ProtoReflect() protoreflect.Message
type StageConfig ¶
type StageConfig struct { // name is the name of the stage. Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // action is the action to perform on stage execution. Action *Action `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // rows is a series of rows of parallel stages referenced // by ID. Each row is run one after the other and the // stages within each row are run in parallel. // // For example: // // “` // [["1a", "1b"], ["2"]] // “` // // This configures stage 1a and stage 1b to run at the // same time, and then stage 2 once both of them have // completed. Rows *RepeatedRepeatedString `protobuf:"bytes,3,opt,name=rows,proto3" json:"rows,omitempty"` // contains filtered or unexported fields }
StageConfig holds a configuration for a stage in a change control. Each stage generally defines either an action or a series of sub-stages.
func (*StageConfig) Descriptor
deprecated
func (*StageConfig) Descriptor() ([]byte, []int)
Deprecated: Use StageConfig.ProtoReflect.Descriptor instead.
func (*StageConfig) GetAction ¶
func (x *StageConfig) GetAction() *Action
func (*StageConfig) GetName ¶
func (x *StageConfig) GetName() *wrapperspb.StringValue
func (*StageConfig) GetRows ¶
func (x *StageConfig) GetRows() *RepeatedRepeatedString
func (*StageConfig) ProtoMessage ¶
func (*StageConfig) ProtoMessage()
func (*StageConfig) ProtoReflect ¶
func (x *StageConfig) ProtoReflect() protoreflect.Message
func (*StageConfig) Reset ¶
func (x *StageConfig) Reset()
func (*StageConfig) String ¶
func (x *StageConfig) String() string
type StageConfigMap ¶
type StageConfigMap struct { // values is a map from stage ID to `StageConfig`. Values map[string]*StageConfig `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
StageConfigMap wraps a map from stage ID to `StageConfig`. This defines the configuration and order of execution for the stages in a change control.
For example:
```
{ "root": { name: "root", rows: [["1-2"], ["3"]] }, "1-2": { name: "stages 1-2", rows: [["1"], ["2"]] }, "1": { name: "stage 1", rows: [["1a", "1b"]] }, "1a": { name: "stage 1a", action: { name: "task", args: { "TaskID": "101" } }, "1b": { name: "stage 1b", action: { name: "task", args: { "TaskID": "102" } }, "2": { name: "stage 2", action: { name: "task", args: { "TaskID": "103" } }, "3": { name: "stage 3", action: { name: "task", args: { "TaskID": "104" } } }
```
Assuming the root stage ID of the enclosing change control is "root", this would mean to do the following in sequence:
``` root |- stages 1-2 | |- stage 1 | | |- stage 1a, stage 1b (parallel) | |- stage 2 |- stage 3 ```
That is, execute tasks `101` and `102` in parallel, then task `103`, then task `104`.
func (*StageConfigMap) Descriptor
deprecated
func (*StageConfigMap) Descriptor() ([]byte, []int)
Deprecated: Use StageConfigMap.ProtoReflect.Descriptor instead.
func (*StageConfigMap) GetValues ¶
func (x *StageConfigMap) GetValues() map[string]*StageConfig
func (*StageConfigMap) ProtoMessage ¶
func (*StageConfigMap) ProtoMessage()
func (*StageConfigMap) ProtoReflect ¶
func (x *StageConfigMap) ProtoReflect() protoreflect.Message
func (*StageConfigMap) Reset ¶
func (x *StageConfigMap) Reset()
func (*StageConfigMap) String ¶
func (x *StageConfigMap) String() string
type StageMap ¶
type StageMap struct { // values is a map from stage ID to `Stage`. Values map[string]*Stage `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
StageMap is a map from stage ID to `Stage`. This has essentially the same structure as `StageConfigMap`, but with each ID mapping to a `Stage` instead of `StageConfig`.
func (*StageMap) Descriptor
deprecated
func (*StageMap) ProtoMessage ¶
func (*StageMap) ProtoMessage()
func (*StageMap) ProtoReflect ¶
func (x *StageMap) ProtoReflect() protoreflect.Message
type StageStatus ¶
type StageStatus int32
StageStatus defines the possible execution statuses of a stage.
const ( // STAGE_STATUS_UNSPECIFIED means unknown stage status. StageStatus_STAGE_STATUS_UNSPECIFIED StageStatus = 0 // STAGE_STATUS_RUNNING means the stage has begun execution. StageStatus_STAGE_STATUS_RUNNING StageStatus = 1 // STAGE_STATUS_COMPLETED means the stage has ceased execution. // Success/failure of a stage cannot be inferred from this status // alone but rather this status plus the stage error. That is, no // error implies success and some error implies failure. StageStatus_STAGE_STATUS_COMPLETED StageStatus = 2 // STAGE_STATUS_NOT_STARTED means the stage has not been started. StageStatus_STAGE_STATUS_NOT_STARTED StageStatus = 3 )
func (StageStatus) Descriptor ¶
func (StageStatus) Descriptor() protoreflect.EnumDescriptor
func (StageStatus) Enum ¶
func (x StageStatus) Enum() *StageStatus
func (StageStatus) EnumDescriptor
deprecated
func (StageStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use StageStatus.Descriptor instead.
func (StageStatus) Number ¶
func (x StageStatus) Number() protoreflect.EnumNumber
func (StageStatus) String ¶
func (x StageStatus) String() string
func (StageStatus) Type ¶
func (StageStatus) Type() protoreflect.EnumType
type TimestampFlag ¶
type TimestampFlag struct { // value is the value of the flag (some timestamp). Value *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // notes are any notes associated with the setting of the flag. Notes *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty"` // time is the time at which the flag was last updated. Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // user is the user by which the flag was last updated. User *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
TimestampFlag holds the configuration of a timestamp flag plus some information about when and by whom is was set.
func (*TimestampFlag) Descriptor
deprecated
func (*TimestampFlag) Descriptor() ([]byte, []int)
Deprecated: Use TimestampFlag.ProtoReflect.Descriptor instead.
func (*TimestampFlag) GetNotes ¶
func (x *TimestampFlag) GetNotes() *wrapperspb.StringValue
func (*TimestampFlag) GetTime ¶
func (x *TimestampFlag) GetTime() *timestamppb.Timestamp
func (*TimestampFlag) GetUser ¶
func (x *TimestampFlag) GetUser() *wrapperspb.StringValue
func (*TimestampFlag) GetValue ¶
func (x *TimestampFlag) GetValue() *timestamppb.Timestamp
func (*TimestampFlag) ProtoMessage ¶
func (*TimestampFlag) ProtoMessage()
func (*TimestampFlag) ProtoReflect ¶
func (x *TimestampFlag) ProtoReflect() protoreflect.Message
func (*TimestampFlag) Reset ¶
func (x *TimestampFlag) Reset()
func (*TimestampFlag) String ¶
func (x *TimestampFlag) String() string
type TimestampFlagConfig ¶
type TimestampFlagConfig struct { // value is the value of the flag (some timestamp). Value *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // notes are the notes associated with the flag value. Notes *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=notes,proto3" json:"notes,omitempty"` // contains filtered or unexported fields }
TimestampFlagConfig is used to set a flag on a change control that takes a timestamp value (e.g. schedule/unschedule).
func (*TimestampFlagConfig) Descriptor
deprecated
func (*TimestampFlagConfig) Descriptor() ([]byte, []int)
Deprecated: Use TimestampFlagConfig.ProtoReflect.Descriptor instead.
func (*TimestampFlagConfig) GetNotes ¶
func (x *TimestampFlagConfig) GetNotes() *wrapperspb.StringValue
func (*TimestampFlagConfig) GetValue ¶
func (x *TimestampFlagConfig) GetValue() *timestamppb.Timestamp
func (*TimestampFlagConfig) ProtoMessage ¶
func (*TimestampFlagConfig) ProtoMessage()
func (*TimestampFlagConfig) ProtoReflect ¶
func (x *TimestampFlagConfig) ProtoReflect() protoreflect.Message
func (*TimestampFlagConfig) Reset ¶
func (x *TimestampFlagConfig) Reset()
func (*TimestampFlagConfig) String ¶
func (x *TimestampFlagConfig) String() string
type UnimplementedApproveConfigServiceServer ¶
type UnimplementedApproveConfigServiceServer struct { }
UnimplementedApproveConfigServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedApproveConfigServiceServer) DeleteSome ¶
func (UnimplementedApproveConfigServiceServer) GetAllBatched ¶
func (UnimplementedApproveConfigServiceServer) GetMeta ¶
func (UnimplementedApproveConfigServiceServer) GetMeta(context.Context, *ApproveConfigStreamRequest) (*MetaResponse, error)
func (UnimplementedApproveConfigServiceServer) GetOne ¶
func (UnimplementedApproveConfigServiceServer) GetOne(context.Context, *ApproveConfigRequest) (*ApproveConfigResponse, error)
func (UnimplementedApproveConfigServiceServer) SubscribeBatched ¶
func (UnimplementedApproveConfigServiceServer) SubscribeBatched(*ApproveConfigBatchedStreamRequest, ApproveConfigService_SubscribeBatchedServer) error
func (UnimplementedApproveConfigServiceServer) SubscribeMeta ¶
type UnimplementedChangeControlConfigServiceServer ¶
type UnimplementedChangeControlConfigServiceServer struct { }
UnimplementedChangeControlConfigServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedChangeControlConfigServiceServer) DeleteSome ¶
func (UnimplementedChangeControlConfigServiceServer) GetAllBatched ¶
func (UnimplementedChangeControlConfigServiceServer) GetMeta ¶
func (UnimplementedChangeControlConfigServiceServer) GetMeta(context.Context, *ChangeControlConfigStreamRequest) (*MetaResponse, error)
func (UnimplementedChangeControlConfigServiceServer) SubscribeBatched ¶
func (UnimplementedChangeControlConfigServiceServer) SubscribeMeta ¶
type UnimplementedChangeControlServiceServer ¶
type UnimplementedChangeControlServiceServer struct { }
UnimplementedChangeControlServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedChangeControlServiceServer) GetAllBatched ¶
func (UnimplementedChangeControlServiceServer) GetMeta ¶
func (UnimplementedChangeControlServiceServer) GetMeta(context.Context, *ChangeControlStreamRequest) (*MetaResponse, error)
func (UnimplementedChangeControlServiceServer) GetOne ¶
func (UnimplementedChangeControlServiceServer) GetOne(context.Context, *ChangeControlRequest) (*ChangeControlResponse, error)
func (UnimplementedChangeControlServiceServer) SubscribeBatched ¶
func (UnimplementedChangeControlServiceServer) SubscribeBatched(*ChangeControlBatchedStreamRequest, ChangeControlService_SubscribeBatchedServer) error
func (UnimplementedChangeControlServiceServer) SubscribeMeta ¶
type UnsafeApproveConfigServiceServer ¶
type UnsafeApproveConfigServiceServer interface {
// contains filtered or unexported methods
}
UnsafeApproveConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApproveConfigServiceServer will result in compilation errors.
type UnsafeChangeControlConfigServiceServer ¶
type UnsafeChangeControlConfigServiceServer interface {
// contains filtered or unexported methods
}
UnsafeChangeControlConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChangeControlConfigServiceServer will result in compilation errors.
type UnsafeChangeControlServiceServer ¶
type UnsafeChangeControlServiceServer interface {
// contains filtered or unexported methods
}
UnsafeChangeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChangeControlServiceServer will result in compilation errors.