Documentation ¶
Index ¶
- Variables
- func RegisterCloudFormationReplyTopicServer(s grpc.ServiceRegistrar, srv CloudFormationReplyTopicServer)
- func RegisterCloudFormationRequestTopicServer(s grpc.ServiceRegistrar, srv CloudFormationRequestTopicServer)
- func RegisterDeployerInputTopicServer(s grpc.ServiceRegistrar, srv DeployerInputTopicServer)
- func RegisterECSReplyTopicServer(s grpc.ServiceRegistrar, srv ECSReplyTopicServer)
- func RegisterECSRequestTopicServer(s grpc.ServiceRegistrar, srv ECSRequestTopicServer)
- func RegisterPostgresReplyTopicServer(s grpc.ServiceRegistrar, srv PostgresReplyTopicServer)
- func RegisterPostgresRequestTopicServer(s grpc.ServiceRegistrar, srv PostgresRequestTopicServer)
- type ApplyChangeSetMessage
- func (*ApplyChangeSetMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyChangeSetMessage) GetChangeSetName() string
- func (x *ApplyChangeSetMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *ApplyChangeSetMessage) GetStackName() string
- func (msg *ApplyChangeSetMessage) MessagingHeaders() map[string]string
- func (msg *ApplyChangeSetMessage) MessagingTopic() string
- func (*ApplyChangeSetMessage) ProtoMessage()
- func (x *ApplyChangeSetMessage) ProtoReflect() protoreflect.Message
- func (x *ApplyChangeSetMessage) Reset()
- func (x *ApplyChangeSetMessage) String() string
- type CancelStackUpdateMessage
- func (*CancelStackUpdateMessage) Descriptor() ([]byte, []int)deprecated
- func (x *CancelStackUpdateMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *CancelStackUpdateMessage) GetStackName() string
- func (msg *CancelStackUpdateMessage) MessagingHeaders() map[string]string
- func (msg *CancelStackUpdateMessage) MessagingTopic() string
- func (*CancelStackUpdateMessage) ProtoMessage()
- func (x *CancelStackUpdateMessage) ProtoReflect() protoreflect.Message
- func (x *CancelStackUpdateMessage) Reset()
- func (x *CancelStackUpdateMessage) String() string
- type ChangeSetStatusChangedMessage
- func (*ChangeSetStatusChangedMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeSetStatusChangedMessage) GetChangeSetName() string
- func (x *ChangeSetStatusChangedMessage) GetEventId() string
- func (x *ChangeSetStatusChangedMessage) GetLifecycle() deployer_pb.CFChangesetLifecycle
- func (x *ChangeSetStatusChangedMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *ChangeSetStatusChangedMessage) GetStackName() string
- func (x *ChangeSetStatusChangedMessage) GetStatus() string
- func (msg *ChangeSetStatusChangedMessage) MessagingHeaders() map[string]string
- func (msg *ChangeSetStatusChangedMessage) MessagingTopic() string
- func (*ChangeSetStatusChangedMessage) ProtoMessage()
- func (x *ChangeSetStatusChangedMessage) ProtoReflect() protoreflect.Message
- func (x *ChangeSetStatusChangedMessage) Reset()
- func (x *ChangeSetStatusChangedMessage) String() string
- type CleanupPostgresDatabaseMessage
- func (*CleanupPostgresDatabaseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *CleanupPostgresDatabaseMessage) GetMigrationId() string
- func (x *CleanupPostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *CleanupPostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresCleanupSpec
- func (msg *CleanupPostgresDatabaseMessage) MessagingHeaders() map[string]string
- func (msg *CleanupPostgresDatabaseMessage) MessagingTopic() string
- func (*CleanupPostgresDatabaseMessage) ProtoMessage()
- func (x *CleanupPostgresDatabaseMessage) ProtoReflect() protoreflect.Message
- func (x *CleanupPostgresDatabaseMessage) Reset()
- func (x *CleanupPostgresDatabaseMessage) String() string
- type CloudFormationReplyTopicClient
- type CloudFormationReplyTopicServer
- type CloudFormationRequestTopicClient
- type CloudFormationRequestTopicServer
- type CreateChangeSetMessage
- func (*CreateChangeSetMessage) Descriptor() ([]byte, []int)deprecated
- func (x *CreateChangeSetMessage) GetImportResources() bool
- func (x *CreateChangeSetMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *CreateChangeSetMessage) GetSpec() *deployer_pb.CFStackInput
- func (msg *CreateChangeSetMessage) MessagingHeaders() map[string]string
- func (msg *CreateChangeSetMessage) MessagingTopic() string
- func (*CreateChangeSetMessage) ProtoMessage()
- func (x *CreateChangeSetMessage) ProtoReflect() protoreflect.Message
- func (x *CreateChangeSetMessage) Reset()
- func (x *CreateChangeSetMessage) String() string
- type CreateNewStackMessage
- func (*CreateNewStackMessage) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNewStackMessage) GetEmptyStack() bool
- func (x *CreateNewStackMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *CreateNewStackMessage) GetSpec() *deployer_pb.CFStackInput
- func (msg *CreateNewStackMessage) MessagingHeaders() map[string]string
- func (msg *CreateNewStackMessage) MessagingTopic() string
- func (*CreateNewStackMessage) ProtoMessage()
- func (x *CreateNewStackMessage) ProtoReflect() protoreflect.Message
- func (x *CreateNewStackMessage) Reset()
- func (x *CreateNewStackMessage) String() string
- type DeleteStackMessage
- func (*DeleteStackMessage) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteStackMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *DeleteStackMessage) GetStackName() string
- func (msg *DeleteStackMessage) MessagingHeaders() map[string]string
- func (msg *DeleteStackMessage) MessagingTopic() string
- func (*DeleteStackMessage) ProtoMessage()
- func (x *DeleteStackMessage) ProtoReflect() protoreflect.Message
- func (x *DeleteStackMessage) Reset()
- func (x *DeleteStackMessage) String() string
- type DeployerInputTopicClient
- type DeployerInputTopicServer
- type ECSReplyTopicClient
- type ECSReplyTopicServer
- type ECSRequestTopicClient
- type ECSRequestTopicServer
- type ECSTaskEventType
- func (*ECSTaskEventType) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTaskEventType) Get() IsECSTaskEventTypeWrappedType
- func (x *ECSTaskEventType) GetExited() *ECSTaskEventType_Exited
- func (x *ECSTaskEventType) GetFailed() *ECSTaskEventType_Failed
- func (x *ECSTaskEventType) GetPending() *ECSTaskEventType_Pending
- func (x *ECSTaskEventType) GetRunning() *ECSTaskEventType_Running
- func (x *ECSTaskEventType) GetStopped() *ECSTaskEventType_Stopped
- func (m *ECSTaskEventType) GetType() isECSTaskEventType_Type
- func (*ECSTaskEventType) ProtoMessage()
- func (x *ECSTaskEventType) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType) Reset()
- func (x *ECSTaskEventType) Set(val IsECSTaskEventTypeWrappedType)
- func (x *ECSTaskEventType) String() string
- func (x *ECSTaskEventType) TypeKey() (ECSTaskEventTypeKey, bool)
- type ECSTaskEventTypeKey
- type ECSTaskEventType_Exited
- func (*ECSTaskEventType_Exited) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTaskEventType_Exited) GetContainerName() string
- func (x *ECSTaskEventType_Exited) GetExitCode() int32
- func (*ECSTaskEventType_Exited) ProtoMessage()
- func (x *ECSTaskEventType_Exited) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType_Exited) Reset()
- func (x *ECSTaskEventType_Exited) String() string
- func (x *ECSTaskEventType_Exited) TypeKey() ECSTaskEventTypeKey
- type ECSTaskEventType_Exited_
- type ECSTaskEventType_Failed
- func (*ECSTaskEventType_Failed) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTaskEventType_Failed) GetContainerName() string
- func (x *ECSTaskEventType_Failed) GetReason() string
- func (*ECSTaskEventType_Failed) ProtoMessage()
- func (x *ECSTaskEventType_Failed) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType_Failed) Reset()
- func (x *ECSTaskEventType_Failed) String() string
- func (x *ECSTaskEventType_Failed) TypeKey() ECSTaskEventTypeKey
- type ECSTaskEventType_Failed_
- type ECSTaskEventType_Pending
- func (*ECSTaskEventType_Pending) Descriptor() ([]byte, []int)deprecated
- func (*ECSTaskEventType_Pending) ProtoMessage()
- func (x *ECSTaskEventType_Pending) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType_Pending) Reset()
- func (x *ECSTaskEventType_Pending) String() string
- func (x *ECSTaskEventType_Pending) TypeKey() ECSTaskEventTypeKey
- type ECSTaskEventType_Pending_
- type ECSTaskEventType_Running
- func (*ECSTaskEventType_Running) Descriptor() ([]byte, []int)deprecated
- func (*ECSTaskEventType_Running) ProtoMessage()
- func (x *ECSTaskEventType_Running) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType_Running) Reset()
- func (x *ECSTaskEventType_Running) String() string
- func (x *ECSTaskEventType_Running) TypeKey() ECSTaskEventTypeKey
- type ECSTaskEventType_Running_
- type ECSTaskEventType_Stopped
- func (*ECSTaskEventType_Stopped) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTaskEventType_Stopped) GetReason() string
- func (*ECSTaskEventType_Stopped) ProtoMessage()
- func (x *ECSTaskEventType_Stopped) ProtoReflect() protoreflect.Message
- func (x *ECSTaskEventType_Stopped) Reset()
- func (x *ECSTaskEventType_Stopped) String() string
- func (x *ECSTaskEventType_Stopped) TypeKey() ECSTaskEventTypeKey
- type ECSTaskEventType_Stopped_
- type ECSTaskStatusMessage
- func (*ECSTaskStatusMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ECSTaskStatusMessage) GetEvent() *ECSTaskEventType
- func (x *ECSTaskStatusMessage) GetEventId() string
- func (x *ECSTaskStatusMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *ECSTaskStatusMessage) GetTaskArn() string
- func (msg *ECSTaskStatusMessage) MessagingHeaders() map[string]string
- func (msg *ECSTaskStatusMessage) MessagingTopic() string
- func (*ECSTaskStatusMessage) ProtoMessage()
- func (x *ECSTaskStatusMessage) ProtoReflect() protoreflect.Message
- func (x *ECSTaskStatusMessage) Reset()
- func (x *ECSTaskStatusMessage) String() string
- type IsECSTaskEventTypeWrappedType
- type IsECSTaskEventType_Type
- type MigratePostgresDatabaseMessage
- func (*MigratePostgresDatabaseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *MigratePostgresDatabaseMessage) GetMigrationId() string
- func (x *MigratePostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *MigratePostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresMigrationSpec
- func (msg *MigratePostgresDatabaseMessage) MessagingHeaders() map[string]string
- func (msg *MigratePostgresDatabaseMessage) MessagingTopic() string
- func (*MigratePostgresDatabaseMessage) ProtoMessage()
- func (x *MigratePostgresDatabaseMessage) ProtoReflect() protoreflect.Message
- func (x *MigratePostgresDatabaseMessage) Reset()
- func (x *MigratePostgresDatabaseMessage) String() string
- type PostgresDatabaseStatusMessage
- func (*PostgresDatabaseStatusMessage) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresDatabaseStatusMessage) GetError() string
- func (x *PostgresDatabaseStatusMessage) GetEventId() string
- func (x *PostgresDatabaseStatusMessage) GetMigrationId() string
- func (x *PostgresDatabaseStatusMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *PostgresDatabaseStatusMessage) GetStatus() PostgresStatus
- func (msg *PostgresDatabaseStatusMessage) MessagingHeaders() map[string]string
- func (msg *PostgresDatabaseStatusMessage) MessagingTopic() string
- func (*PostgresDatabaseStatusMessage) ProtoMessage()
- func (x *PostgresDatabaseStatusMessage) ProtoReflect() protoreflect.Message
- func (x *PostgresDatabaseStatusMessage) Reset()
- func (x *PostgresDatabaseStatusMessage) String() string
- type PostgresReplyTopicClient
- type PostgresReplyTopicServer
- type PostgresRequestTopicClient
- type PostgresRequestTopicServer
- type PostgresStatus
- func (PostgresStatus) Descriptor() protoreflect.EnumDescriptor
- func (x PostgresStatus) Enum() *PostgresStatus
- func (PostgresStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x PostgresStatus) Number() protoreflect.EnumNumber
- func (x *PostgresStatus) Scan(value interface{}) error
- func (x PostgresStatus) ShortString() string
- func (x PostgresStatus) String() string
- func (PostgresStatus) Type() protoreflect.EnumType
- func (x PostgresStatus) Value() (driver.Value, error)
- type RequestDeploymentMessage
- func (*RequestDeploymentMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RequestDeploymentMessage) GetApplication() *application_pb.Application
- func (x *RequestDeploymentMessage) GetDeploymentId() string
- func (x *RequestDeploymentMessage) GetEnvironmentId() string
- func (x *RequestDeploymentMessage) GetFlags() *deployer_pb.DeploymentFlags
- func (x *RequestDeploymentMessage) GetSource() *deployer_pb.CodeSourceType
- func (x *RequestDeploymentMessage) GetVersion() string
- func (msg *RequestDeploymentMessage) MessagingHeaders() map[string]string
- func (msg *RequestDeploymentMessage) MessagingTopic() string
- func (*RequestDeploymentMessage) ProtoMessage()
- func (x *RequestDeploymentMessage) ProtoReflect() protoreflect.Message
- func (x *RequestDeploymentMessage) Reset()
- func (x *RequestDeploymentMessage) String() string
- type RunECSTaskMessage
- func (*RunECSTaskMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RunECSTaskMessage) GetCluster() string
- func (x *RunECSTaskMessage) GetCount() int32
- func (x *RunECSTaskMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *RunECSTaskMessage) GetTaskDefinition() string
- func (msg *RunECSTaskMessage) MessagingHeaders() map[string]string
- func (msg *RunECSTaskMessage) MessagingTopic() string
- func (*RunECSTaskMessage) ProtoMessage()
- func (x *RunECSTaskMessage) ProtoReflect() protoreflect.Message
- func (x *RunECSTaskMessage) Reset()
- func (x *RunECSTaskMessage) String() string
- type ScaleStackMessage
- func (*ScaleStackMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ScaleStackMessage) GetDesiredCount() int32
- func (x *ScaleStackMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *ScaleStackMessage) GetStackName() string
- func (msg *ScaleStackMessage) MessagingHeaders() map[string]string
- func (msg *ScaleStackMessage) MessagingTopic() string
- func (*ScaleStackMessage) ProtoMessage()
- func (x *ScaleStackMessage) ProtoReflect() protoreflect.Message
- func (x *ScaleStackMessage) Reset()
- func (x *ScaleStackMessage) String() string
- type StabalizeStackMessage
- func (*StabalizeStackMessage) Descriptor() ([]byte, []int)deprecated
- func (x *StabalizeStackMessage) GetCancelUpdate() bool
- func (x *StabalizeStackMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *StabalizeStackMessage) GetStackName() string
- func (msg *StabalizeStackMessage) MessagingHeaders() map[string]string
- func (msg *StabalizeStackMessage) MessagingTopic() string
- func (*StabalizeStackMessage) ProtoMessage()
- func (x *StabalizeStackMessage) ProtoReflect() protoreflect.Message
- func (x *StabalizeStackMessage) Reset()
- func (x *StabalizeStackMessage) String() string
- type StackStatusChangedMessage
- func (*StackStatusChangedMessage) Descriptor() ([]byte, []int)deprecated
- func (x *StackStatusChangedMessage) GetEventId() string
- func (x *StackStatusChangedMessage) GetLifecycle() deployer_pb.CFLifecycle
- func (x *StackStatusChangedMessage) GetOutputs() []*deployer_pb.KeyValue
- func (x *StackStatusChangedMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *StackStatusChangedMessage) GetStackName() string
- func (x *StackStatusChangedMessage) GetStatus() string
- func (msg *StackStatusChangedMessage) MessagingHeaders() map[string]string
- func (msg *StackStatusChangedMessage) MessagingTopic() string
- func (*StackStatusChangedMessage) ProtoMessage()
- func (x *StackStatusChangedMessage) ProtoReflect() protoreflect.Message
- func (x *StackStatusChangedMessage) Reset()
- func (x *StackStatusChangedMessage) String() string
- type UnimplementedCloudFormationReplyTopicServer
- type UnimplementedCloudFormationRequestTopicServer
- func (UnimplementedCloudFormationRequestTopicServer) ApplyChangeSet(context.Context, *ApplyChangeSetMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) CancelStackUpdate(context.Context, *CancelStackUpdateMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) CreateChangeSet(context.Context, *CreateChangeSetMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) CreateNewStack(context.Context, *CreateNewStackMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) DeleteStack(context.Context, *DeleteStackMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) ScaleStack(context.Context, *ScaleStackMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) StabalizeStack(context.Context, *StabalizeStackMessage) (*emptypb.Empty, error)
- func (UnimplementedCloudFormationRequestTopicServer) UpdateStack(context.Context, *UpdateStackMessage) (*emptypb.Empty, error)
- type UnimplementedDeployerInputTopicServer
- type UnimplementedECSReplyTopicServer
- type UnimplementedECSRequestTopicServer
- type UnimplementedPostgresReplyTopicServer
- type UnimplementedPostgresRequestTopicServer
- func (UnimplementedPostgresRequestTopicServer) CleanupPostgresDatabase(context.Context, *CleanupPostgresDatabaseMessage) (*emptypb.Empty, error)
- func (UnimplementedPostgresRequestTopicServer) MigratePostgresDatabase(context.Context, *MigratePostgresDatabaseMessage) (*emptypb.Empty, error)
- func (UnimplementedPostgresRequestTopicServer) UpsertPostgresDatabase(context.Context, *UpsertPostgresDatabaseMessage) (*emptypb.Empty, error)
- type UnsafeCloudFormationReplyTopicServer
- type UnsafeCloudFormationRequestTopicServer
- type UnsafeDeployerInputTopicServer
- type UnsafeECSReplyTopicServer
- type UnsafeECSRequestTopicServer
- type UnsafePostgresReplyTopicServer
- type UnsafePostgresRequestTopicServer
- type UpdateStackMessage
- func (*UpdateStackMessage) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateStackMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *UpdateStackMessage) GetSpec() *deployer_pb.CFStackInput
- func (msg *UpdateStackMessage) MessagingHeaders() map[string]string
- func (msg *UpdateStackMessage) MessagingTopic() string
- func (*UpdateStackMessage) ProtoMessage()
- func (x *UpdateStackMessage) ProtoReflect() protoreflect.Message
- func (x *UpdateStackMessage) Reset()
- func (x *UpdateStackMessage) String() string
- type UpsertPostgresDatabaseMessage
- func (*UpsertPostgresDatabaseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertPostgresDatabaseMessage) GetMigrationId() string
- func (x *UpsertPostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
- func (x *UpsertPostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresCreationSpec
- func (msg *UpsertPostgresDatabaseMessage) MessagingHeaders() map[string]string
- func (msg *UpsertPostgresDatabaseMessage) MessagingTopic() string
- func (*UpsertPostgresDatabaseMessage) ProtoMessage()
- func (x *UpsertPostgresDatabaseMessage) ProtoReflect() protoreflect.Message
- func (x *UpsertPostgresDatabaseMessage) Reset()
- func (x *UpsertPostgresDatabaseMessage) String() string
Constants ¶
This section is empty.
Variables ¶
var ( PostgresStatus_name = map[int32]string{ 0: "POSTGRES_STATUS_UNSPECIFIED", 1: "POSTGRES_STATUS_STARTED", 2: "POSTGRES_STATUS_DONE", 3: "POSTGRES_STATUS_ERROR", } PostgresStatus_value = map[string]int32{ "POSTGRES_STATUS_UNSPECIFIED": 0, "POSTGRES_STATUS_STARTED": 1, "POSTGRES_STATUS_DONE": 2, "POSTGRES_STATUS_ERROR": 3, } )
Enum value maps for PostgresStatus.
var ( PostgresStatus_name_short = map[int32]string{ 0: "UNSPECIFIED", 1: "STARTED", 2: "DONE", 3: "ERROR", } PostgresStatus_value_short = map[string]int32{ "UNSPECIFIED": 0, "STARTED": 1, "DONE": 2, "ERROR": 3, } PostgresStatus_value_either = map[string]int32{ "UNSPECIFIED": 0, "POSTGRES_STATUS_UNSPECIFIED": 0, "STARTED": 1, "POSTGRES_STATUS_STARTED": 1, "DONE": 2, "POSTGRES_STATUS_DONE": 2, "ERROR": 3, "POSTGRES_STATUS_ERROR": 3, } )
var CloudFormationReplyTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.CloudFormationReplyTopic", HandlerType: (*CloudFormationReplyTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StackStatusChanged", Handler: _CloudFormationReplyTopic_StackStatusChanged_Handler, }, { MethodName: "ChangeSetStatusChanged", Handler: _CloudFormationReplyTopic_ChangeSetStatusChanged_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_cf.proto", }
CloudFormationReplyTopic_ServiceDesc is the grpc.ServiceDesc for CloudFormationReplyTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var CloudFormationRequestTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.CloudFormationRequestTopic", HandlerType: (*CloudFormationRequestTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateNewStack", Handler: _CloudFormationRequestTopic_CreateNewStack_Handler, }, { MethodName: "UpdateStack", Handler: _CloudFormationRequestTopic_UpdateStack_Handler, }, { MethodName: "CreateChangeSet", Handler: _CloudFormationRequestTopic_CreateChangeSet_Handler, }, { MethodName: "ApplyChangeSet", Handler: _CloudFormationRequestTopic_ApplyChangeSet_Handler, }, { MethodName: "DeleteStack", Handler: _CloudFormationRequestTopic_DeleteStack_Handler, }, { MethodName: "ScaleStack", Handler: _CloudFormationRequestTopic_ScaleStack_Handler, }, { MethodName: "CancelStackUpdate", Handler: _CloudFormationRequestTopic_CancelStackUpdate_Handler, }, { MethodName: "StabalizeStack", Handler: _CloudFormationRequestTopic_StabalizeStack_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_cf.proto", }
CloudFormationRequestTopic_ServiceDesc is the grpc.ServiceDesc for CloudFormationRequestTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DeployerInputTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.DeployerInputTopic", HandlerType: (*DeployerInputTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RequestDeployment", Handler: _DeployerInputTopic_RequestDeployment_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/deployer_input.proto", }
DeployerInputTopic_ServiceDesc is the grpc.ServiceDesc for DeployerInputTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ECSReplyTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.ECSReplyTopic", HandlerType: (*ECSReplyTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ECSTaskStatus", Handler: _ECSReplyTopic_ECSTaskStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_ecs.proto", }
ECSReplyTopic_ServiceDesc is the grpc.ServiceDesc for ECSReplyTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ECSRequestTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.ECSRequestTopic", HandlerType: (*ECSRequestTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RunECSTask", Handler: _ECSRequestTopic_RunECSTask_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_ecs.proto", }
ECSRequestTopic_ServiceDesc is the grpc.ServiceDesc for ECSRequestTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_o5_deployer_v1_topic_aws_cf_proto protoreflect.FileDescriptor
var File_o5_deployer_v1_topic_aws_ecs_proto protoreflect.FileDescriptor
var File_o5_deployer_v1_topic_aws_pg_proto protoreflect.FileDescriptor
var File_o5_deployer_v1_topic_deployer_input_proto protoreflect.FileDescriptor
var PostgresReplyTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.PostgresReplyTopic", HandlerType: (*PostgresReplyTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PostgresDatabaseStatus", Handler: _PostgresReplyTopic_PostgresDatabaseStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_pg.proto", }
PostgresReplyTopic_ServiceDesc is the grpc.ServiceDesc for PostgresReplyTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PostgresRequestTopic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o5.deployer.v1.topic.PostgresRequestTopic", HandlerType: (*PostgresRequestTopicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpsertPostgresDatabase", Handler: _PostgresRequestTopic_UpsertPostgresDatabase_Handler, }, { MethodName: "MigratePostgresDatabase", Handler: _PostgresRequestTopic_MigratePostgresDatabase_Handler, }, { MethodName: "CleanupPostgresDatabase", Handler: _PostgresRequestTopic_CleanupPostgresDatabase_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "o5/deployer/v1/topic/aws_pg.proto", }
PostgresRequestTopic_ServiceDesc is the grpc.ServiceDesc for PostgresRequestTopic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterCloudFormationReplyTopicServer ¶
func RegisterCloudFormationReplyTopicServer(s grpc.ServiceRegistrar, srv CloudFormationReplyTopicServer)
func RegisterCloudFormationRequestTopicServer ¶
func RegisterCloudFormationRequestTopicServer(s grpc.ServiceRegistrar, srv CloudFormationRequestTopicServer)
func RegisterDeployerInputTopicServer ¶
func RegisterDeployerInputTopicServer(s grpc.ServiceRegistrar, srv DeployerInputTopicServer)
func RegisterECSReplyTopicServer ¶
func RegisterECSReplyTopicServer(s grpc.ServiceRegistrar, srv ECSReplyTopicServer)
func RegisterECSRequestTopicServer ¶
func RegisterECSRequestTopicServer(s grpc.ServiceRegistrar, srv ECSRequestTopicServer)
func RegisterPostgresReplyTopicServer ¶
func RegisterPostgresReplyTopicServer(s grpc.ServiceRegistrar, srv PostgresReplyTopicServer)
func RegisterPostgresRequestTopicServer ¶
func RegisterPostgresRequestTopicServer(s grpc.ServiceRegistrar, srv PostgresRequestTopicServer)
Types ¶
type ApplyChangeSetMessage ¶
type ApplyChangeSetMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` StackName string `protobuf:"bytes,2,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` ChangeSetName string `protobuf:"bytes,3,opt,name=change_set_name,json=changeSetName,proto3" json:"change_set_name,omitempty"` // contains filtered or unexported fields }
func (*ApplyChangeSetMessage) Descriptor
deprecated
func (*ApplyChangeSetMessage) Descriptor() ([]byte, []int)
Deprecated: Use ApplyChangeSetMessage.ProtoReflect.Descriptor instead.
func (*ApplyChangeSetMessage) GetChangeSetName ¶
func (x *ApplyChangeSetMessage) GetChangeSetName() string
func (*ApplyChangeSetMessage) GetRequest ¶
func (x *ApplyChangeSetMessage) GetRequest() *messaging_pb.RequestMetadata
func (*ApplyChangeSetMessage) GetStackName ¶
func (x *ApplyChangeSetMessage) GetStackName() string
func (*ApplyChangeSetMessage) MessagingHeaders ¶
func (msg *ApplyChangeSetMessage) MessagingHeaders() map[string]string
func (*ApplyChangeSetMessage) MessagingTopic ¶
func (msg *ApplyChangeSetMessage) MessagingTopic() string
func (*ApplyChangeSetMessage) ProtoMessage ¶
func (*ApplyChangeSetMessage) ProtoMessage()
func (*ApplyChangeSetMessage) ProtoReflect ¶
func (x *ApplyChangeSetMessage) ProtoReflect() protoreflect.Message
func (*ApplyChangeSetMessage) Reset ¶
func (x *ApplyChangeSetMessage) Reset()
func (*ApplyChangeSetMessage) String ¶
func (x *ApplyChangeSetMessage) String() string
type CancelStackUpdateMessage ¶
type CancelStackUpdateMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` StackName string `protobuf:"bytes,2,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` // contains filtered or unexported fields }
func (*CancelStackUpdateMessage) Descriptor
deprecated
func (*CancelStackUpdateMessage) Descriptor() ([]byte, []int)
Deprecated: Use CancelStackUpdateMessage.ProtoReflect.Descriptor instead.
func (*CancelStackUpdateMessage) GetRequest ¶
func (x *CancelStackUpdateMessage) GetRequest() *messaging_pb.RequestMetadata
func (*CancelStackUpdateMessage) GetStackName ¶
func (x *CancelStackUpdateMessage) GetStackName() string
func (*CancelStackUpdateMessage) MessagingHeaders ¶
func (msg *CancelStackUpdateMessage) MessagingHeaders() map[string]string
func (*CancelStackUpdateMessage) MessagingTopic ¶
func (msg *CancelStackUpdateMessage) MessagingTopic() string
func (*CancelStackUpdateMessage) ProtoMessage ¶
func (*CancelStackUpdateMessage) ProtoMessage()
func (*CancelStackUpdateMessage) ProtoReflect ¶
func (x *CancelStackUpdateMessage) ProtoReflect() protoreflect.Message
func (*CancelStackUpdateMessage) Reset ¶
func (x *CancelStackUpdateMessage) Reset()
func (*CancelStackUpdateMessage) String ¶
func (x *CancelStackUpdateMessage) String() string
type ChangeSetStatusChangedMessage ¶
type ChangeSetStatusChangedMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` StackName string `protobuf:"bytes,3,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` ChangeSetName string `protobuf:"bytes,4,opt,name=change_set_name,json=changeSetName,proto3" json:"change_set_name,omitempty"` Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` Lifecycle deployer_pb.CFChangesetLifecycle `protobuf:"varint,6,opt,name=lifecycle,proto3,enum=o5.deployer.v1.CFChangesetLifecycle" json:"lifecycle,omitempty"` // contains filtered or unexported fields }
func (*ChangeSetStatusChangedMessage) Descriptor
deprecated
func (*ChangeSetStatusChangedMessage) Descriptor() ([]byte, []int)
Deprecated: Use ChangeSetStatusChangedMessage.ProtoReflect.Descriptor instead.
func (*ChangeSetStatusChangedMessage) GetChangeSetName ¶
func (x *ChangeSetStatusChangedMessage) GetChangeSetName() string
func (*ChangeSetStatusChangedMessage) GetEventId ¶
func (x *ChangeSetStatusChangedMessage) GetEventId() string
func (*ChangeSetStatusChangedMessage) GetLifecycle ¶
func (x *ChangeSetStatusChangedMessage) GetLifecycle() deployer_pb.CFChangesetLifecycle
func (*ChangeSetStatusChangedMessage) GetRequest ¶
func (x *ChangeSetStatusChangedMessage) GetRequest() *messaging_pb.RequestMetadata
func (*ChangeSetStatusChangedMessage) GetStackName ¶
func (x *ChangeSetStatusChangedMessage) GetStackName() string
func (*ChangeSetStatusChangedMessage) GetStatus ¶
func (x *ChangeSetStatusChangedMessage) GetStatus() string
func (*ChangeSetStatusChangedMessage) MessagingHeaders ¶
func (msg *ChangeSetStatusChangedMessage) MessagingHeaders() map[string]string
func (*ChangeSetStatusChangedMessage) MessagingTopic ¶
func (msg *ChangeSetStatusChangedMessage) MessagingTopic() string
func (*ChangeSetStatusChangedMessage) ProtoMessage ¶
func (*ChangeSetStatusChangedMessage) ProtoMessage()
func (*ChangeSetStatusChangedMessage) ProtoReflect ¶
func (x *ChangeSetStatusChangedMessage) ProtoReflect() protoreflect.Message
func (*ChangeSetStatusChangedMessage) Reset ¶
func (x *ChangeSetStatusChangedMessage) Reset()
func (*ChangeSetStatusChangedMessage) String ¶
func (x *ChangeSetStatusChangedMessage) String() string
type CleanupPostgresDatabaseMessage ¶
type CleanupPostgresDatabaseMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` MigrationId string `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"` Spec *deployer_pb.PostgresCleanupSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*CleanupPostgresDatabaseMessage) Descriptor
deprecated
func (*CleanupPostgresDatabaseMessage) Descriptor() ([]byte, []int)
Deprecated: Use CleanupPostgresDatabaseMessage.ProtoReflect.Descriptor instead.
func (*CleanupPostgresDatabaseMessage) GetMigrationId ¶
func (x *CleanupPostgresDatabaseMessage) GetMigrationId() string
func (*CleanupPostgresDatabaseMessage) GetRequest ¶
func (x *CleanupPostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
func (*CleanupPostgresDatabaseMessage) GetSpec ¶
func (x *CleanupPostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresCleanupSpec
func (*CleanupPostgresDatabaseMessage) MessagingHeaders ¶
func (msg *CleanupPostgresDatabaseMessage) MessagingHeaders() map[string]string
func (*CleanupPostgresDatabaseMessage) MessagingTopic ¶
func (msg *CleanupPostgresDatabaseMessage) MessagingTopic() string
func (*CleanupPostgresDatabaseMessage) ProtoMessage ¶
func (*CleanupPostgresDatabaseMessage) ProtoMessage()
func (*CleanupPostgresDatabaseMessage) ProtoReflect ¶
func (x *CleanupPostgresDatabaseMessage) ProtoReflect() protoreflect.Message
func (*CleanupPostgresDatabaseMessage) Reset ¶
func (x *CleanupPostgresDatabaseMessage) Reset()
func (*CleanupPostgresDatabaseMessage) String ¶
func (x *CleanupPostgresDatabaseMessage) String() string
type CloudFormationReplyTopicClient ¶
type CloudFormationReplyTopicClient interface { StackStatusChanged(ctx context.Context, in *StackStatusChangedMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) ChangeSetStatusChanged(ctx context.Context, in *ChangeSetStatusChangedMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) }
CloudFormationReplyTopicClient is the client API for CloudFormationReplyTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCloudFormationReplyTopicClient ¶
func NewCloudFormationReplyTopicClient(cc grpc.ClientConnInterface) CloudFormationReplyTopicClient
type CloudFormationReplyTopicServer ¶
type CloudFormationReplyTopicServer interface { StackStatusChanged(context.Context, *StackStatusChangedMessage) (*emptypb.Empty, error) ChangeSetStatusChanged(context.Context, *ChangeSetStatusChangedMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
CloudFormationReplyTopicServer is the server API for CloudFormationReplyTopic service. All implementations must embed UnimplementedCloudFormationReplyTopicServer for forward compatibility
type CloudFormationRequestTopicClient ¶
type CloudFormationRequestTopicClient interface { CreateNewStack(ctx context.Context, in *CreateNewStackMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) UpdateStack(ctx context.Context, in *UpdateStackMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) CreateChangeSet(ctx context.Context, in *CreateChangeSetMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) ApplyChangeSet(ctx context.Context, in *ApplyChangeSetMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) DeleteStack(ctx context.Context, in *DeleteStackMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) ScaleStack(ctx context.Context, in *ScaleStackMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) CancelStackUpdate(ctx context.Context, in *CancelStackUpdateMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) StabalizeStack(ctx context.Context, in *StabalizeStackMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) }
CloudFormationRequestTopicClient is the client API for CloudFormationRequestTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCloudFormationRequestTopicClient ¶
func NewCloudFormationRequestTopicClient(cc grpc.ClientConnInterface) CloudFormationRequestTopicClient
type CloudFormationRequestTopicServer ¶
type CloudFormationRequestTopicServer interface { CreateNewStack(context.Context, *CreateNewStackMessage) (*emptypb.Empty, error) UpdateStack(context.Context, *UpdateStackMessage) (*emptypb.Empty, error) CreateChangeSet(context.Context, *CreateChangeSetMessage) (*emptypb.Empty, error) ApplyChangeSet(context.Context, *ApplyChangeSetMessage) (*emptypb.Empty, error) DeleteStack(context.Context, *DeleteStackMessage) (*emptypb.Empty, error) ScaleStack(context.Context, *ScaleStackMessage) (*emptypb.Empty, error) CancelStackUpdate(context.Context, *CancelStackUpdateMessage) (*emptypb.Empty, error) StabalizeStack(context.Context, *StabalizeStackMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
CloudFormationRequestTopicServer is the server API for CloudFormationRequestTopic service. All implementations must embed UnimplementedCloudFormationRequestTopicServer for forward compatibility
type CreateChangeSetMessage ¶
type CreateChangeSetMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Spec *deployer_pb.CFStackInput `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // When true, creates a filtered changeset that only includes resources which // are marked for retention and which already exist, e.g. s3 buckets and // secrets. It should not be used on existing stacks. ImportResources bool `protobuf:"varint,3,opt,name=import_resources,json=importResources,proto3" json:"import_resources,omitempty"` // contains filtered or unexported fields }
func (*CreateChangeSetMessage) Descriptor
deprecated
func (*CreateChangeSetMessage) Descriptor() ([]byte, []int)
Deprecated: Use CreateChangeSetMessage.ProtoReflect.Descriptor instead.
func (*CreateChangeSetMessage) GetImportResources ¶
func (x *CreateChangeSetMessage) GetImportResources() bool
func (*CreateChangeSetMessage) GetRequest ¶
func (x *CreateChangeSetMessage) GetRequest() *messaging_pb.RequestMetadata
func (*CreateChangeSetMessage) GetSpec ¶
func (x *CreateChangeSetMessage) GetSpec() *deployer_pb.CFStackInput
func (*CreateChangeSetMessage) MessagingHeaders ¶
func (msg *CreateChangeSetMessage) MessagingHeaders() map[string]string
func (*CreateChangeSetMessage) MessagingTopic ¶
func (msg *CreateChangeSetMessage) MessagingTopic() string
func (*CreateChangeSetMessage) ProtoMessage ¶
func (*CreateChangeSetMessage) ProtoMessage()
func (*CreateChangeSetMessage) ProtoReflect ¶
func (x *CreateChangeSetMessage) ProtoReflect() protoreflect.Message
func (*CreateChangeSetMessage) Reset ¶
func (x *CreateChangeSetMessage) Reset()
func (*CreateChangeSetMessage) String ¶
func (x *CreateChangeSetMessage) String() string
type CreateNewStackMessage ¶
type CreateNewStackMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Spec *deployer_pb.CFStackInput `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // Create a stack with no resources (uses a fake resource placeholder) EmptyStack bool `protobuf:"varint,3,opt,name=empty_stack,json=emptyStack,proto3" json:"empty_stack,omitempty"` // contains filtered or unexported fields }
func (*CreateNewStackMessage) Descriptor
deprecated
func (*CreateNewStackMessage) Descriptor() ([]byte, []int)
Deprecated: Use CreateNewStackMessage.ProtoReflect.Descriptor instead.
func (*CreateNewStackMessage) GetEmptyStack ¶
func (x *CreateNewStackMessage) GetEmptyStack() bool
func (*CreateNewStackMessage) GetRequest ¶
func (x *CreateNewStackMessage) GetRequest() *messaging_pb.RequestMetadata
func (*CreateNewStackMessage) GetSpec ¶
func (x *CreateNewStackMessage) GetSpec() *deployer_pb.CFStackInput
func (*CreateNewStackMessage) MessagingHeaders ¶
func (msg *CreateNewStackMessage) MessagingHeaders() map[string]string
func (*CreateNewStackMessage) MessagingTopic ¶
func (msg *CreateNewStackMessage) MessagingTopic() string
func (*CreateNewStackMessage) ProtoMessage ¶
func (*CreateNewStackMessage) ProtoMessage()
func (*CreateNewStackMessage) ProtoReflect ¶
func (x *CreateNewStackMessage) ProtoReflect() protoreflect.Message
func (*CreateNewStackMessage) Reset ¶
func (x *CreateNewStackMessage) Reset()
func (*CreateNewStackMessage) String ¶
func (x *CreateNewStackMessage) String() string
type DeleteStackMessage ¶
type DeleteStackMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` StackName string `protobuf:"bytes,2,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` // contains filtered or unexported fields }
func (*DeleteStackMessage) Descriptor
deprecated
func (*DeleteStackMessage) Descriptor() ([]byte, []int)
Deprecated: Use DeleteStackMessage.ProtoReflect.Descriptor instead.
func (*DeleteStackMessage) GetRequest ¶
func (x *DeleteStackMessage) GetRequest() *messaging_pb.RequestMetadata
func (*DeleteStackMessage) GetStackName ¶
func (x *DeleteStackMessage) GetStackName() string
func (*DeleteStackMessage) MessagingHeaders ¶
func (msg *DeleteStackMessage) MessagingHeaders() map[string]string
func (*DeleteStackMessage) MessagingTopic ¶
func (msg *DeleteStackMessage) MessagingTopic() string
func (*DeleteStackMessage) ProtoMessage ¶
func (*DeleteStackMessage) ProtoMessage()
func (*DeleteStackMessage) ProtoReflect ¶
func (x *DeleteStackMessage) ProtoReflect() protoreflect.Message
func (*DeleteStackMessage) Reset ¶
func (x *DeleteStackMessage) Reset()
func (*DeleteStackMessage) String ¶
func (x *DeleteStackMessage) String() string
type DeployerInputTopicClient ¶
type DeployerInputTopicClient interface {
RequestDeployment(ctx context.Context, in *RequestDeploymentMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
DeployerInputTopicClient is the client API for DeployerInputTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDeployerInputTopicClient ¶
func NewDeployerInputTopicClient(cc grpc.ClientConnInterface) DeployerInputTopicClient
type DeployerInputTopicServer ¶
type DeployerInputTopicServer interface { RequestDeployment(context.Context, *RequestDeploymentMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
DeployerInputTopicServer is the server API for DeployerInputTopic service. All implementations must embed UnimplementedDeployerInputTopicServer for forward compatibility
type ECSReplyTopicClient ¶
type ECSReplyTopicClient interface {
ECSTaskStatus(ctx context.Context, in *ECSTaskStatusMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
ECSReplyTopicClient is the client API for ECSReplyTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewECSReplyTopicClient ¶
func NewECSReplyTopicClient(cc grpc.ClientConnInterface) ECSReplyTopicClient
type ECSReplyTopicServer ¶
type ECSReplyTopicServer interface { ECSTaskStatus(context.Context, *ECSTaskStatusMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
ECSReplyTopicServer is the server API for ECSReplyTopic service. All implementations must embed UnimplementedECSReplyTopicServer for forward compatibility
type ECSRequestTopicClient ¶
type ECSRequestTopicClient interface {
RunECSTask(ctx context.Context, in *RunECSTaskMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
ECSRequestTopicClient is the client API for ECSRequestTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewECSRequestTopicClient ¶
func NewECSRequestTopicClient(cc grpc.ClientConnInterface) ECSRequestTopicClient
type ECSRequestTopicServer ¶
type ECSRequestTopicServer interface { RunECSTask(context.Context, *RunECSTaskMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
ECSRequestTopicServer is the server API for ECSRequestTopic service. All implementations must embed UnimplementedECSRequestTopicServer for forward compatibility
type ECSTaskEventType ¶
type ECSTaskEventType struct { // https://docs.aws.amazon.com/AmazonECS/latest/developerguide/scheduling_tasks.html#task-lifecycle // // Types that are assignable to Type: // // *ECSTaskEventType_Pending_ // *ECSTaskEventType_Running_ // *ECSTaskEventType_Failed_ // *ECSTaskEventType_Exited_ // *ECSTaskEventType_Stopped_ Type isECSTaskEventType_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*ECSTaskEventType) Descriptor
deprecated
func (*ECSTaskEventType) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType) Get ¶
func (x *ECSTaskEventType) Get() IsECSTaskEventTypeWrappedType
func (*ECSTaskEventType) GetExited ¶
func (x *ECSTaskEventType) GetExited() *ECSTaskEventType_Exited
func (*ECSTaskEventType) GetFailed ¶
func (x *ECSTaskEventType) GetFailed() *ECSTaskEventType_Failed
func (*ECSTaskEventType) GetPending ¶
func (x *ECSTaskEventType) GetPending() *ECSTaskEventType_Pending
func (*ECSTaskEventType) GetRunning ¶
func (x *ECSTaskEventType) GetRunning() *ECSTaskEventType_Running
func (*ECSTaskEventType) GetStopped ¶
func (x *ECSTaskEventType) GetStopped() *ECSTaskEventType_Stopped
func (*ECSTaskEventType) GetType ¶
func (m *ECSTaskEventType) GetType() isECSTaskEventType_Type
func (*ECSTaskEventType) ProtoMessage ¶
func (*ECSTaskEventType) ProtoMessage()
func (*ECSTaskEventType) ProtoReflect ¶
func (x *ECSTaskEventType) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType) Reset ¶
func (x *ECSTaskEventType) Reset()
func (*ECSTaskEventType) Set ¶
func (x *ECSTaskEventType) Set(val IsECSTaskEventTypeWrappedType)
func (*ECSTaskEventType) String ¶
func (x *ECSTaskEventType) String() string
func (*ECSTaskEventType) TypeKey ¶
func (x *ECSTaskEventType) TypeKey() (ECSTaskEventTypeKey, bool)
type ECSTaskEventTypeKey ¶
type ECSTaskEventTypeKey string
ECSTaskEventType is a oneof wrapper
const ( ECSTaskEvent_Pending ECSTaskEventTypeKey = "pending" ECSTaskEvent_Running ECSTaskEventTypeKey = "running" ECSTaskEvent_Failed ECSTaskEventTypeKey = "failed" ECSTaskEvent_Exited ECSTaskEventTypeKey = "exited" ECSTaskEvent_Stopped ECSTaskEventTypeKey = "stopped" )
type ECSTaskEventType_Exited ¶
type ECSTaskEventType_Exited struct { ContainerName string `protobuf:"bytes,1,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"` ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // contains filtered or unexported fields }
func (*ECSTaskEventType_Exited) Descriptor
deprecated
func (*ECSTaskEventType_Exited) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType_Exited.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType_Exited) GetContainerName ¶
func (x *ECSTaskEventType_Exited) GetContainerName() string
func (*ECSTaskEventType_Exited) GetExitCode ¶
func (x *ECSTaskEventType_Exited) GetExitCode() int32
func (*ECSTaskEventType_Exited) ProtoMessage ¶
func (*ECSTaskEventType_Exited) ProtoMessage()
func (*ECSTaskEventType_Exited) ProtoReflect ¶
func (x *ECSTaskEventType_Exited) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType_Exited) Reset ¶
func (x *ECSTaskEventType_Exited) Reset()
func (*ECSTaskEventType_Exited) String ¶
func (x *ECSTaskEventType_Exited) String() string
func (*ECSTaskEventType_Exited) TypeKey ¶
func (x *ECSTaskEventType_Exited) TypeKey() ECSTaskEventTypeKey
type ECSTaskEventType_Exited_ ¶
type ECSTaskEventType_Exited_ struct { // The code itself exited, after Running Exited *ECSTaskEventType_Exited `protobuf:"bytes,4,opt,name=exited,proto3,oneof"` }
type ECSTaskEventType_Failed ¶
type ECSTaskEventType_Failed struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` ContainerName *string `protobuf:"bytes,2,opt,name=container_name,json=containerName,proto3,oneof" json:"container_name,omitempty"` // contains filtered or unexported fields }
func (*ECSTaskEventType_Failed) Descriptor
deprecated
func (*ECSTaskEventType_Failed) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType_Failed.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType_Failed) GetContainerName ¶
func (x *ECSTaskEventType_Failed) GetContainerName() string
func (*ECSTaskEventType_Failed) GetReason ¶
func (x *ECSTaskEventType_Failed) GetReason() string
func (*ECSTaskEventType_Failed) ProtoMessage ¶
func (*ECSTaskEventType_Failed) ProtoMessage()
func (*ECSTaskEventType_Failed) ProtoReflect ¶
func (x *ECSTaskEventType_Failed) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType_Failed) Reset ¶
func (x *ECSTaskEventType_Failed) Reset()
func (*ECSTaskEventType_Failed) String ¶
func (x *ECSTaskEventType_Failed) String() string
func (*ECSTaskEventType_Failed) TypeKey ¶
func (x *ECSTaskEventType_Failed) TypeKey() ECSTaskEventTypeKey
type ECSTaskEventType_Failed_ ¶
type ECSTaskEventType_Failed_ struct { // Did not start, i.e. did not get to Running Failed *ECSTaskEventType_Failed `protobuf:"bytes,3,opt,name=failed,proto3,oneof"` }
type ECSTaskEventType_Pending ¶
type ECSTaskEventType_Pending struct {
// contains filtered or unexported fields
}
func (*ECSTaskEventType_Pending) Descriptor
deprecated
func (*ECSTaskEventType_Pending) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType_Pending.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType_Pending) ProtoMessage ¶
func (*ECSTaskEventType_Pending) ProtoMessage()
func (*ECSTaskEventType_Pending) ProtoReflect ¶
func (x *ECSTaskEventType_Pending) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType_Pending) Reset ¶
func (x *ECSTaskEventType_Pending) Reset()
func (*ECSTaskEventType_Pending) String ¶
func (x *ECSTaskEventType_Pending) String() string
func (*ECSTaskEventType_Pending) TypeKey ¶
func (x *ECSTaskEventType_Pending) TypeKey() ECSTaskEventTypeKey
type ECSTaskEventType_Pending_ ¶
type ECSTaskEventType_Pending_ struct { // Maps directly to the Pending state in ECS, indicates some level of // success Pending *ECSTaskEventType_Pending `protobuf:"bytes,1,opt,name=pending,proto3,oneof"` }
type ECSTaskEventType_Running ¶
type ECSTaskEventType_Running struct {
// contains filtered or unexported fields
}
func (*ECSTaskEventType_Running) Descriptor
deprecated
func (*ECSTaskEventType_Running) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType_Running.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType_Running) ProtoMessage ¶
func (*ECSTaskEventType_Running) ProtoMessage()
func (*ECSTaskEventType_Running) ProtoReflect ¶
func (x *ECSTaskEventType_Running) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType_Running) Reset ¶
func (x *ECSTaskEventType_Running) Reset()
func (*ECSTaskEventType_Running) String ¶
func (x *ECSTaskEventType_Running) String() string
func (*ECSTaskEventType_Running) TypeKey ¶
func (x *ECSTaskEventType_Running) TypeKey() ECSTaskEventTypeKey
type ECSTaskEventType_Running_ ¶
type ECSTaskEventType_Running_ struct { // Maps directly to the Running state in ECS Running *ECSTaskEventType_Running `protobuf:"bytes,2,opt,name=running,proto3,oneof"` }
type ECSTaskEventType_Stopped ¶
type ECSTaskEventType_Stopped struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*ECSTaskEventType_Stopped) Descriptor
deprecated
func (*ECSTaskEventType_Stopped) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskEventType_Stopped.ProtoReflect.Descriptor instead.
func (*ECSTaskEventType_Stopped) GetReason ¶
func (x *ECSTaskEventType_Stopped) GetReason() string
func (*ECSTaskEventType_Stopped) ProtoMessage ¶
func (*ECSTaskEventType_Stopped) ProtoMessage()
func (*ECSTaskEventType_Stopped) ProtoReflect ¶
func (x *ECSTaskEventType_Stopped) ProtoReflect() protoreflect.Message
func (*ECSTaskEventType_Stopped) Reset ¶
func (x *ECSTaskEventType_Stopped) Reset()
func (*ECSTaskEventType_Stopped) String ¶
func (x *ECSTaskEventType_Stopped) String() string
func (*ECSTaskEventType_Stopped) TypeKey ¶
func (x *ECSTaskEventType_Stopped) TypeKey() ECSTaskEventTypeKey
type ECSTaskEventType_Stopped_ ¶
type ECSTaskEventType_Stopped_ struct { // Deliberately stoped, e.g. by scaling, after Running Stopped *ECSTaskEventType_Stopped `protobuf:"bytes,5,opt,name=stopped,proto3,oneof"` }
type ECSTaskStatusMessage ¶
type ECSTaskStatusMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` Event *ECSTaskEventType `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"` TaskArn string `protobuf:"bytes,4,opt,name=task_arn,json=taskArn,proto3" json:"task_arn,omitempty"` // contains filtered or unexported fields }
func (*ECSTaskStatusMessage) Descriptor
deprecated
func (*ECSTaskStatusMessage) Descriptor() ([]byte, []int)
Deprecated: Use ECSTaskStatusMessage.ProtoReflect.Descriptor instead.
func (*ECSTaskStatusMessage) GetEvent ¶
func (x *ECSTaskStatusMessage) GetEvent() *ECSTaskEventType
func (*ECSTaskStatusMessage) GetEventId ¶
func (x *ECSTaskStatusMessage) GetEventId() string
func (*ECSTaskStatusMessage) GetRequest ¶
func (x *ECSTaskStatusMessage) GetRequest() *messaging_pb.RequestMetadata
func (*ECSTaskStatusMessage) GetTaskArn ¶
func (x *ECSTaskStatusMessage) GetTaskArn() string
func (*ECSTaskStatusMessage) MessagingHeaders ¶
func (msg *ECSTaskStatusMessage) MessagingHeaders() map[string]string
func (*ECSTaskStatusMessage) MessagingTopic ¶
func (msg *ECSTaskStatusMessage) MessagingTopic() string
func (*ECSTaskStatusMessage) ProtoMessage ¶
func (*ECSTaskStatusMessage) ProtoMessage()
func (*ECSTaskStatusMessage) ProtoReflect ¶
func (x *ECSTaskStatusMessage) ProtoReflect() protoreflect.Message
func (*ECSTaskStatusMessage) Reset ¶
func (x *ECSTaskStatusMessage) Reset()
func (*ECSTaskStatusMessage) String ¶
func (x *ECSTaskStatusMessage) String() string
type IsECSTaskEventTypeWrappedType ¶
type IsECSTaskEventTypeWrappedType interface {
TypeKey() ECSTaskEventTypeKey
}
type IsECSTaskEventType_Type ¶
type IsECSTaskEventType_Type = isECSTaskEventType_Type
type MigratePostgresDatabaseMessage ¶
type MigratePostgresDatabaseMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` MigrationId string `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"` Spec *deployer_pb.PostgresMigrationSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*MigratePostgresDatabaseMessage) Descriptor
deprecated
func (*MigratePostgresDatabaseMessage) Descriptor() ([]byte, []int)
Deprecated: Use MigratePostgresDatabaseMessage.ProtoReflect.Descriptor instead.
func (*MigratePostgresDatabaseMessage) GetMigrationId ¶
func (x *MigratePostgresDatabaseMessage) GetMigrationId() string
func (*MigratePostgresDatabaseMessage) GetRequest ¶
func (x *MigratePostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
func (*MigratePostgresDatabaseMessage) GetSpec ¶
func (x *MigratePostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresMigrationSpec
func (*MigratePostgresDatabaseMessage) MessagingHeaders ¶
func (msg *MigratePostgresDatabaseMessage) MessagingHeaders() map[string]string
func (*MigratePostgresDatabaseMessage) MessagingTopic ¶
func (msg *MigratePostgresDatabaseMessage) MessagingTopic() string
func (*MigratePostgresDatabaseMessage) ProtoMessage ¶
func (*MigratePostgresDatabaseMessage) ProtoMessage()
func (*MigratePostgresDatabaseMessage) ProtoReflect ¶
func (x *MigratePostgresDatabaseMessage) ProtoReflect() protoreflect.Message
func (*MigratePostgresDatabaseMessage) Reset ¶
func (x *MigratePostgresDatabaseMessage) Reset()
func (*MigratePostgresDatabaseMessage) String ¶
func (x *MigratePostgresDatabaseMessage) String() string
type PostgresDatabaseStatusMessage ¶
type PostgresDatabaseStatusMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` MigrationId string `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"` EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` Status PostgresStatus `protobuf:"varint,4,opt,name=status,proto3,enum=o5.deployer.v1.topic.PostgresStatus" json:"status,omitempty"` Error *string `protobuf:"bytes,5,opt,name=error,proto3,oneof" json:"error,omitempty"` // contains filtered or unexported fields }
func (*PostgresDatabaseStatusMessage) Descriptor
deprecated
func (*PostgresDatabaseStatusMessage) Descriptor() ([]byte, []int)
Deprecated: Use PostgresDatabaseStatusMessage.ProtoReflect.Descriptor instead.
func (*PostgresDatabaseStatusMessage) GetError ¶
func (x *PostgresDatabaseStatusMessage) GetError() string
func (*PostgresDatabaseStatusMessage) GetEventId ¶
func (x *PostgresDatabaseStatusMessage) GetEventId() string
func (*PostgresDatabaseStatusMessage) GetMigrationId ¶
func (x *PostgresDatabaseStatusMessage) GetMigrationId() string
func (*PostgresDatabaseStatusMessage) GetRequest ¶
func (x *PostgresDatabaseStatusMessage) GetRequest() *messaging_pb.RequestMetadata
func (*PostgresDatabaseStatusMessage) GetStatus ¶
func (x *PostgresDatabaseStatusMessage) GetStatus() PostgresStatus
func (*PostgresDatabaseStatusMessage) MessagingHeaders ¶
func (msg *PostgresDatabaseStatusMessage) MessagingHeaders() map[string]string
func (*PostgresDatabaseStatusMessage) MessagingTopic ¶
func (msg *PostgresDatabaseStatusMessage) MessagingTopic() string
func (*PostgresDatabaseStatusMessage) ProtoMessage ¶
func (*PostgresDatabaseStatusMessage) ProtoMessage()
func (*PostgresDatabaseStatusMessage) ProtoReflect ¶
func (x *PostgresDatabaseStatusMessage) ProtoReflect() protoreflect.Message
func (*PostgresDatabaseStatusMessage) Reset ¶
func (x *PostgresDatabaseStatusMessage) Reset()
func (*PostgresDatabaseStatusMessage) String ¶
func (x *PostgresDatabaseStatusMessage) String() string
type PostgresReplyTopicClient ¶
type PostgresReplyTopicClient interface {
PostgresDatabaseStatus(ctx context.Context, in *PostgresDatabaseStatusMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
PostgresReplyTopicClient is the client API for PostgresReplyTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPostgresReplyTopicClient ¶
func NewPostgresReplyTopicClient(cc grpc.ClientConnInterface) PostgresReplyTopicClient
type PostgresReplyTopicServer ¶
type PostgresReplyTopicServer interface { PostgresDatabaseStatus(context.Context, *PostgresDatabaseStatusMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
PostgresReplyTopicServer is the server API for PostgresReplyTopic service. All implementations must embed UnimplementedPostgresReplyTopicServer for forward compatibility
type PostgresRequestTopicClient ¶
type PostgresRequestTopicClient interface { UpsertPostgresDatabase(ctx context.Context, in *UpsertPostgresDatabaseMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) MigratePostgresDatabase(ctx context.Context, in *MigratePostgresDatabaseMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) CleanupPostgresDatabase(ctx context.Context, in *CleanupPostgresDatabaseMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) }
PostgresRequestTopicClient is the client API for PostgresRequestTopic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPostgresRequestTopicClient ¶
func NewPostgresRequestTopicClient(cc grpc.ClientConnInterface) PostgresRequestTopicClient
type PostgresRequestTopicServer ¶
type PostgresRequestTopicServer interface { UpsertPostgresDatabase(context.Context, *UpsertPostgresDatabaseMessage) (*emptypb.Empty, error) MigratePostgresDatabase(context.Context, *MigratePostgresDatabaseMessage) (*emptypb.Empty, error) CleanupPostgresDatabase(context.Context, *CleanupPostgresDatabaseMessage) (*emptypb.Empty, error) // contains filtered or unexported methods }
PostgresRequestTopicServer is the server API for PostgresRequestTopic service. All implementations must embed UnimplementedPostgresRequestTopicServer for forward compatibility
type PostgresStatus ¶
type PostgresStatus int32
const ( PostgresStatus_POSTGRES_STATUS_UNSPECIFIED PostgresStatus = 0 PostgresStatus_POSTGRES_STATUS_STARTED PostgresStatus = 1 PostgresStatus_POSTGRES_STATUS_DONE PostgresStatus = 2 PostgresStatus_POSTGRES_STATUS_ERROR PostgresStatus = 3 )
const ( PostgresStatus_UNSPECIFIED PostgresStatus = 0 PostgresStatus_STARTED PostgresStatus = 1 PostgresStatus_DONE PostgresStatus = 2 PostgresStatus_ERROR PostgresStatus = 3 )
PostgresStatus
func (PostgresStatus) Descriptor ¶
func (PostgresStatus) Descriptor() protoreflect.EnumDescriptor
func (PostgresStatus) Enum ¶
func (x PostgresStatus) Enum() *PostgresStatus
func (PostgresStatus) EnumDescriptor
deprecated
func (PostgresStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use PostgresStatus.Descriptor instead.
func (PostgresStatus) Number ¶
func (x PostgresStatus) Number() protoreflect.EnumNumber
func (*PostgresStatus) Scan ¶
func (x *PostgresStatus) Scan(value interface{}) error
func (PostgresStatus) ShortString ¶
func (x PostgresStatus) ShortString() string
ShortString returns the un-prefixed string representation of the enum value
func (PostgresStatus) String ¶
func (x PostgresStatus) String() string
func (PostgresStatus) Type ¶
func (PostgresStatus) Type() protoreflect.EnumType
type RequestDeploymentMessage ¶
type RequestDeploymentMessage struct { DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` Application *application_pb.Application `protobuf:"bytes,2,opt,name=application,proto3" json:"application,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` EnvironmentId string `protobuf:"bytes,4,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"` Flags *deployer_pb.DeploymentFlags `protobuf:"bytes,5,opt,name=flags,proto3" json:"flags,omitempty"` Source *deployer_pb.CodeSourceType `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*RequestDeploymentMessage) Descriptor
deprecated
func (*RequestDeploymentMessage) Descriptor() ([]byte, []int)
Deprecated: Use RequestDeploymentMessage.ProtoReflect.Descriptor instead.
func (*RequestDeploymentMessage) GetApplication ¶
func (x *RequestDeploymentMessage) GetApplication() *application_pb.Application
func (*RequestDeploymentMessage) GetDeploymentId ¶
func (x *RequestDeploymentMessage) GetDeploymentId() string
func (*RequestDeploymentMessage) GetEnvironmentId ¶
func (x *RequestDeploymentMessage) GetEnvironmentId() string
func (*RequestDeploymentMessage) GetFlags ¶
func (x *RequestDeploymentMessage) GetFlags() *deployer_pb.DeploymentFlags
func (*RequestDeploymentMessage) GetSource ¶
func (x *RequestDeploymentMessage) GetSource() *deployer_pb.CodeSourceType
func (*RequestDeploymentMessage) GetVersion ¶
func (x *RequestDeploymentMessage) GetVersion() string
func (*RequestDeploymentMessage) MessagingHeaders ¶
func (msg *RequestDeploymentMessage) MessagingHeaders() map[string]string
func (*RequestDeploymentMessage) MessagingTopic ¶
func (msg *RequestDeploymentMessage) MessagingTopic() string
func (*RequestDeploymentMessage) ProtoMessage ¶
func (*RequestDeploymentMessage) ProtoMessage()
func (*RequestDeploymentMessage) ProtoReflect ¶
func (x *RequestDeploymentMessage) ProtoReflect() protoreflect.Message
func (*RequestDeploymentMessage) Reset ¶
func (x *RequestDeploymentMessage) Reset()
func (*RequestDeploymentMessage) String ¶
func (x *RequestDeploymentMessage) String() string
type RunECSTaskMessage ¶
type RunECSTaskMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` TaskDefinition string `protobuf:"bytes,2,opt,name=task_definition,json=taskDefinition,proto3" json:"task_definition,omitempty"` Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` Cluster string `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*RunECSTaskMessage) Descriptor
deprecated
func (*RunECSTaskMessage) Descriptor() ([]byte, []int)
Deprecated: Use RunECSTaskMessage.ProtoReflect.Descriptor instead.
func (*RunECSTaskMessage) GetCluster ¶
func (x *RunECSTaskMessage) GetCluster() string
func (*RunECSTaskMessage) GetCount ¶
func (x *RunECSTaskMessage) GetCount() int32
func (*RunECSTaskMessage) GetRequest ¶
func (x *RunECSTaskMessage) GetRequest() *messaging_pb.RequestMetadata
func (*RunECSTaskMessage) GetTaskDefinition ¶
func (x *RunECSTaskMessage) GetTaskDefinition() string
func (*RunECSTaskMessage) MessagingHeaders ¶
func (msg *RunECSTaskMessage) MessagingHeaders() map[string]string
func (*RunECSTaskMessage) MessagingTopic ¶
func (msg *RunECSTaskMessage) MessagingTopic() string
func (*RunECSTaskMessage) ProtoMessage ¶
func (*RunECSTaskMessage) ProtoMessage()
func (*RunECSTaskMessage) ProtoReflect ¶
func (x *RunECSTaskMessage) ProtoReflect() protoreflect.Message
func (*RunECSTaskMessage) Reset ¶
func (x *RunECSTaskMessage) Reset()
func (*RunECSTaskMessage) String ¶
func (x *RunECSTaskMessage) String() string
type ScaleStackMessage ¶
type ScaleStackMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` StackName string `protobuf:"bytes,2,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` DesiredCount int32 `protobuf:"varint,3,opt,name=desired_count,json=desiredCount,proto3" json:"desired_count,omitempty"` // contains filtered or unexported fields }
func (*ScaleStackMessage) Descriptor
deprecated
func (*ScaleStackMessage) Descriptor() ([]byte, []int)
Deprecated: Use ScaleStackMessage.ProtoReflect.Descriptor instead.
func (*ScaleStackMessage) GetDesiredCount ¶
func (x *ScaleStackMessage) GetDesiredCount() int32
func (*ScaleStackMessage) GetRequest ¶
func (x *ScaleStackMessage) GetRequest() *messaging_pb.RequestMetadata
func (*ScaleStackMessage) GetStackName ¶
func (x *ScaleStackMessage) GetStackName() string
func (*ScaleStackMessage) MessagingHeaders ¶
func (msg *ScaleStackMessage) MessagingHeaders() map[string]string
func (*ScaleStackMessage) MessagingTopic ¶
func (msg *ScaleStackMessage) MessagingTopic() string
func (*ScaleStackMessage) ProtoMessage ¶
func (*ScaleStackMessage) ProtoMessage()
func (*ScaleStackMessage) ProtoReflect ¶
func (x *ScaleStackMessage) ProtoReflect() protoreflect.Message
func (*ScaleStackMessage) Reset ¶
func (x *ScaleStackMessage) Reset()
func (*ScaleStackMessage) String ¶
func (x *ScaleStackMessage) String() string
type StabalizeStackMessage ¶
type StabalizeStackMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` StackName string `protobuf:"bytes,2,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` CancelUpdate bool `protobuf:"varint,3,opt,name=cancel_update,json=cancelUpdate,proto3" json:"cancel_update,omitempty"` // contains filtered or unexported fields }
func (*StabalizeStackMessage) Descriptor
deprecated
func (*StabalizeStackMessage) Descriptor() ([]byte, []int)
Deprecated: Use StabalizeStackMessage.ProtoReflect.Descriptor instead.
func (*StabalizeStackMessage) GetCancelUpdate ¶
func (x *StabalizeStackMessage) GetCancelUpdate() bool
func (*StabalizeStackMessage) GetRequest ¶
func (x *StabalizeStackMessage) GetRequest() *messaging_pb.RequestMetadata
func (*StabalizeStackMessage) GetStackName ¶
func (x *StabalizeStackMessage) GetStackName() string
func (*StabalizeStackMessage) MessagingHeaders ¶
func (msg *StabalizeStackMessage) MessagingHeaders() map[string]string
func (*StabalizeStackMessage) MessagingTopic ¶
func (msg *StabalizeStackMessage) MessagingTopic() string
func (*StabalizeStackMessage) ProtoMessage ¶
func (*StabalizeStackMessage) ProtoMessage()
func (*StabalizeStackMessage) ProtoReflect ¶
func (x *StabalizeStackMessage) ProtoReflect() protoreflect.Message
func (*StabalizeStackMessage) Reset ¶
func (x *StabalizeStackMessage) Reset()
func (*StabalizeStackMessage) String ¶
func (x *StabalizeStackMessage) String() string
type StackStatusChangedMessage ¶
type StackStatusChangedMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` EventId string `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` StackName string `protobuf:"bytes,3,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"` Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` Outputs []*deployer_pb.KeyValue `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"` Lifecycle deployer_pb.CFLifecycle `protobuf:"varint,6,opt,name=lifecycle,proto3,enum=o5.deployer.v1.CFLifecycle" json:"lifecycle,omitempty"` // contains filtered or unexported fields }
func (*StackStatusChangedMessage) Descriptor
deprecated
func (*StackStatusChangedMessage) Descriptor() ([]byte, []int)
Deprecated: Use StackStatusChangedMessage.ProtoReflect.Descriptor instead.
func (*StackStatusChangedMessage) GetEventId ¶
func (x *StackStatusChangedMessage) GetEventId() string
func (*StackStatusChangedMessage) GetLifecycle ¶
func (x *StackStatusChangedMessage) GetLifecycle() deployer_pb.CFLifecycle
func (*StackStatusChangedMessage) GetOutputs ¶
func (x *StackStatusChangedMessage) GetOutputs() []*deployer_pb.KeyValue
func (*StackStatusChangedMessage) GetRequest ¶
func (x *StackStatusChangedMessage) GetRequest() *messaging_pb.RequestMetadata
func (*StackStatusChangedMessage) GetStackName ¶
func (x *StackStatusChangedMessage) GetStackName() string
func (*StackStatusChangedMessage) GetStatus ¶
func (x *StackStatusChangedMessage) GetStatus() string
func (*StackStatusChangedMessage) MessagingHeaders ¶
func (msg *StackStatusChangedMessage) MessagingHeaders() map[string]string
func (*StackStatusChangedMessage) MessagingTopic ¶
func (msg *StackStatusChangedMessage) MessagingTopic() string
func (*StackStatusChangedMessage) ProtoMessage ¶
func (*StackStatusChangedMessage) ProtoMessage()
func (*StackStatusChangedMessage) ProtoReflect ¶
func (x *StackStatusChangedMessage) ProtoReflect() protoreflect.Message
func (*StackStatusChangedMessage) Reset ¶
func (x *StackStatusChangedMessage) Reset()
func (*StackStatusChangedMessage) String ¶
func (x *StackStatusChangedMessage) String() string
type UnimplementedCloudFormationReplyTopicServer ¶
type UnimplementedCloudFormationReplyTopicServer struct { }
UnimplementedCloudFormationReplyTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedCloudFormationReplyTopicServer) ChangeSetStatusChanged ¶
func (UnimplementedCloudFormationReplyTopicServer) ChangeSetStatusChanged(context.Context, *ChangeSetStatusChangedMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationReplyTopicServer) StackStatusChanged ¶
func (UnimplementedCloudFormationReplyTopicServer) StackStatusChanged(context.Context, *StackStatusChangedMessage) (*emptypb.Empty, error)
type UnimplementedCloudFormationRequestTopicServer ¶
type UnimplementedCloudFormationRequestTopicServer struct { }
UnimplementedCloudFormationRequestTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedCloudFormationRequestTopicServer) ApplyChangeSet ¶
func (UnimplementedCloudFormationRequestTopicServer) ApplyChangeSet(context.Context, *ApplyChangeSetMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) CancelStackUpdate ¶
func (UnimplementedCloudFormationRequestTopicServer) CancelStackUpdate(context.Context, *CancelStackUpdateMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) CreateChangeSet ¶
func (UnimplementedCloudFormationRequestTopicServer) CreateChangeSet(context.Context, *CreateChangeSetMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) CreateNewStack ¶
func (UnimplementedCloudFormationRequestTopicServer) CreateNewStack(context.Context, *CreateNewStackMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) DeleteStack ¶
func (UnimplementedCloudFormationRequestTopicServer) DeleteStack(context.Context, *DeleteStackMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) ScaleStack ¶
func (UnimplementedCloudFormationRequestTopicServer) ScaleStack(context.Context, *ScaleStackMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) StabalizeStack ¶
func (UnimplementedCloudFormationRequestTopicServer) StabalizeStack(context.Context, *StabalizeStackMessage) (*emptypb.Empty, error)
func (UnimplementedCloudFormationRequestTopicServer) UpdateStack ¶
func (UnimplementedCloudFormationRequestTopicServer) UpdateStack(context.Context, *UpdateStackMessage) (*emptypb.Empty, error)
type UnimplementedDeployerInputTopicServer ¶
type UnimplementedDeployerInputTopicServer struct { }
UnimplementedDeployerInputTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedDeployerInputTopicServer) RequestDeployment ¶
func (UnimplementedDeployerInputTopicServer) RequestDeployment(context.Context, *RequestDeploymentMessage) (*emptypb.Empty, error)
type UnimplementedECSReplyTopicServer ¶
type UnimplementedECSReplyTopicServer struct { }
UnimplementedECSReplyTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedECSReplyTopicServer) ECSTaskStatus ¶
func (UnimplementedECSReplyTopicServer) ECSTaskStatus(context.Context, *ECSTaskStatusMessage) (*emptypb.Empty, error)
type UnimplementedECSRequestTopicServer ¶
type UnimplementedECSRequestTopicServer struct { }
UnimplementedECSRequestTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedECSRequestTopicServer) RunECSTask ¶
func (UnimplementedECSRequestTopicServer) RunECSTask(context.Context, *RunECSTaskMessage) (*emptypb.Empty, error)
type UnimplementedPostgresReplyTopicServer ¶
type UnimplementedPostgresReplyTopicServer struct { }
UnimplementedPostgresReplyTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedPostgresReplyTopicServer) PostgresDatabaseStatus ¶
func (UnimplementedPostgresReplyTopicServer) PostgresDatabaseStatus(context.Context, *PostgresDatabaseStatusMessage) (*emptypb.Empty, error)
type UnimplementedPostgresRequestTopicServer ¶
type UnimplementedPostgresRequestTopicServer struct { }
UnimplementedPostgresRequestTopicServer must be embedded to have forward compatible implementations.
func (UnimplementedPostgresRequestTopicServer) CleanupPostgresDatabase ¶
func (UnimplementedPostgresRequestTopicServer) CleanupPostgresDatabase(context.Context, *CleanupPostgresDatabaseMessage) (*emptypb.Empty, error)
func (UnimplementedPostgresRequestTopicServer) MigratePostgresDatabase ¶
func (UnimplementedPostgresRequestTopicServer) MigratePostgresDatabase(context.Context, *MigratePostgresDatabaseMessage) (*emptypb.Empty, error)
func (UnimplementedPostgresRequestTopicServer) UpsertPostgresDatabase ¶
func (UnimplementedPostgresRequestTopicServer) UpsertPostgresDatabase(context.Context, *UpsertPostgresDatabaseMessage) (*emptypb.Empty, error)
type UnsafeCloudFormationReplyTopicServer ¶
type UnsafeCloudFormationReplyTopicServer interface {
// contains filtered or unexported methods
}
UnsafeCloudFormationReplyTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloudFormationReplyTopicServer will result in compilation errors.
type UnsafeCloudFormationRequestTopicServer ¶
type UnsafeCloudFormationRequestTopicServer interface {
// contains filtered or unexported methods
}
UnsafeCloudFormationRequestTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloudFormationRequestTopicServer will result in compilation errors.
type UnsafeDeployerInputTopicServer ¶
type UnsafeDeployerInputTopicServer interface {
// contains filtered or unexported methods
}
UnsafeDeployerInputTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeployerInputTopicServer will result in compilation errors.
type UnsafeECSReplyTopicServer ¶
type UnsafeECSReplyTopicServer interface {
// contains filtered or unexported methods
}
UnsafeECSReplyTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ECSReplyTopicServer will result in compilation errors.
type UnsafeECSRequestTopicServer ¶
type UnsafeECSRequestTopicServer interface {
// contains filtered or unexported methods
}
UnsafeECSRequestTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ECSRequestTopicServer will result in compilation errors.
type UnsafePostgresReplyTopicServer ¶
type UnsafePostgresReplyTopicServer interface {
// contains filtered or unexported methods
}
UnsafePostgresReplyTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PostgresReplyTopicServer will result in compilation errors.
type UnsafePostgresRequestTopicServer ¶
type UnsafePostgresRequestTopicServer interface {
// contains filtered or unexported methods
}
UnsafePostgresRequestTopicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PostgresRequestTopicServer will result in compilation errors.
type UpdateStackMessage ¶
type UpdateStackMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Spec *deployer_pb.CFStackInput `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*UpdateStackMessage) Descriptor
deprecated
func (*UpdateStackMessage) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStackMessage.ProtoReflect.Descriptor instead.
func (*UpdateStackMessage) GetRequest ¶
func (x *UpdateStackMessage) GetRequest() *messaging_pb.RequestMetadata
func (*UpdateStackMessage) GetSpec ¶
func (x *UpdateStackMessage) GetSpec() *deployer_pb.CFStackInput
func (*UpdateStackMessage) MessagingHeaders ¶
func (msg *UpdateStackMessage) MessagingHeaders() map[string]string
func (*UpdateStackMessage) MessagingTopic ¶
func (msg *UpdateStackMessage) MessagingTopic() string
func (*UpdateStackMessage) ProtoMessage ¶
func (*UpdateStackMessage) ProtoMessage()
func (*UpdateStackMessage) ProtoReflect ¶
func (x *UpdateStackMessage) ProtoReflect() protoreflect.Message
func (*UpdateStackMessage) Reset ¶
func (x *UpdateStackMessage) Reset()
func (*UpdateStackMessage) String ¶
func (x *UpdateStackMessage) String() string
type UpsertPostgresDatabaseMessage ¶
type UpsertPostgresDatabaseMessage struct { Request *messaging_pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` MigrationId string `protobuf:"bytes,2,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"` Spec *deployer_pb.PostgresCreationSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"` // contains filtered or unexported fields }
func (*UpsertPostgresDatabaseMessage) Descriptor
deprecated
func (*UpsertPostgresDatabaseMessage) Descriptor() ([]byte, []int)
Deprecated: Use UpsertPostgresDatabaseMessage.ProtoReflect.Descriptor instead.
func (*UpsertPostgresDatabaseMessage) GetMigrationId ¶
func (x *UpsertPostgresDatabaseMessage) GetMigrationId() string
func (*UpsertPostgresDatabaseMessage) GetRequest ¶
func (x *UpsertPostgresDatabaseMessage) GetRequest() *messaging_pb.RequestMetadata
func (*UpsertPostgresDatabaseMessage) GetSpec ¶
func (x *UpsertPostgresDatabaseMessage) GetSpec() *deployer_pb.PostgresCreationSpec
func (*UpsertPostgresDatabaseMessage) MessagingHeaders ¶
func (msg *UpsertPostgresDatabaseMessage) MessagingHeaders() map[string]string
func (*UpsertPostgresDatabaseMessage) MessagingTopic ¶
func (msg *UpsertPostgresDatabaseMessage) MessagingTopic() string
func (*UpsertPostgresDatabaseMessage) ProtoMessage ¶
func (*UpsertPostgresDatabaseMessage) ProtoMessage()
func (*UpsertPostgresDatabaseMessage) ProtoReflect ¶
func (x *UpsertPostgresDatabaseMessage) ProtoReflect() protoreflect.Message
func (*UpsertPostgresDatabaseMessage) Reset ¶
func (x *UpsertPostgresDatabaseMessage) Reset()
func (*UpsertPostgresDatabaseMessage) String ¶
func (x *UpsertPostgresDatabaseMessage) String() string
Source Files ¶
- aws_cf.pb.go
- aws_cf_grpc.pb.go
- aws_cf_messaging.pb.go
- aws_cf_sugar.pb.go
- aws_ecs.pb.go
- aws_ecs_grpc.pb.go
- aws_ecs_messaging.pb.go
- aws_ecs_sugar.pb.go
- aws_pg.pb.go
- aws_pg_grpc.pb.go
- aws_pg_messaging.pb.go
- aws_pg_sugar.pb.go
- deployer_input.pb.go
- deployer_input_grpc.pb.go
- deployer_input_messaging.pb.go
- deployer_input_sugar.pb.go