deployer_tpb

package
v0.0.0-...-082e34f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 23, 2024 License: MIT Imports: 15 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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,
	}
)
View Source
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)

View Source
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)

View Source
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)

View Source
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)

View Source
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)

View Source
var File_o5_deployer_v1_topic_aws_cf_proto protoreflect.FileDescriptor
View Source
var File_o5_deployer_v1_topic_aws_ecs_proto protoreflect.FileDescriptor
View Source
var File_o5_deployer_v1_topic_aws_pg_proto protoreflect.FileDescriptor
View Source
var File_o5_deployer_v1_topic_deployer_input_proto protoreflect.FileDescriptor
View Source
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)

View Source
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 (*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 (*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 (*ChangeSetStatusChangedMessage) GetRequest

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 (*ChangeSetStatusChangedMessage) Reset

func (x *ChangeSetStatusChangedMessage) Reset()

func (*ChangeSetStatusChangedMessage) 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 (*CleanupPostgresDatabaseMessage) GetSpec

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 (*CleanupPostgresDatabaseMessage) Reset

func (x *CleanupPostgresDatabaseMessage) Reset()

func (*CleanupPostgresDatabaseMessage) 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.

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.

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 (*CreateChangeSetMessage) GetSpec

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 (*CreateNewStackMessage) GetSpec

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 (*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.

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.

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.

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 (*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 (*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

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

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

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

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

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 (*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 (*MigratePostgresDatabaseMessage) GetSpec

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 (*MigratePostgresDatabaseMessage) Reset

func (x *MigratePostgresDatabaseMessage) Reset()

func (*MigratePostgresDatabaseMessage) 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 (*PostgresDatabaseStatusMessage) GetStatus

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 (*PostgresDatabaseStatusMessage) Reset

func (x *PostgresDatabaseStatusMessage) Reset()

func (*PostgresDatabaseStatusMessage) 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.

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.

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) Enum

func (x PostgresStatus) Enum() *PostgresStatus

func (PostgresStatus) EnumDescriptor deprecated

func (PostgresStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use PostgresStatus.Descriptor instead.

func (PostgresStatus) Number

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) Value

func (x PostgresStatus) Value() (driver.Value, error)

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 (*RequestDeploymentMessage) GetDeploymentId

func (x *RequestDeploymentMessage) GetDeploymentId() string

func (*RequestDeploymentMessage) GetEnvironmentId

func (x *RequestDeploymentMessage) GetEnvironmentId() string

func (*RequestDeploymentMessage) GetFlags

func (*RequestDeploymentMessage) GetSource

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 (*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 (*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 (*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 (*StackStatusChangedMessage) GetOutputs

func (x *StackStatusChangedMessage) GetOutputs() []*deployer_pb.KeyValue

func (*StackStatusChangedMessage) GetRequest

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 (*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) StackStatusChanged

type UnimplementedCloudFormationRequestTopicServer

type UnimplementedCloudFormationRequestTopicServer struct {
}

UnimplementedCloudFormationRequestTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedCloudFormationRequestTopicServer) ApplyChangeSet

func (UnimplementedCloudFormationRequestTopicServer) CancelStackUpdate

func (UnimplementedCloudFormationRequestTopicServer) CreateChangeSet

func (UnimplementedCloudFormationRequestTopicServer) CreateNewStack

func (UnimplementedCloudFormationRequestTopicServer) DeleteStack

func (UnimplementedCloudFormationRequestTopicServer) ScaleStack

func (UnimplementedCloudFormationRequestTopicServer) StabalizeStack

func (UnimplementedCloudFormationRequestTopicServer) UpdateStack

type UnimplementedDeployerInputTopicServer

type UnimplementedDeployerInputTopicServer struct {
}

UnimplementedDeployerInputTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedDeployerInputTopicServer) RequestDeployment

type UnimplementedECSReplyTopicServer

type UnimplementedECSReplyTopicServer struct {
}

UnimplementedECSReplyTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedECSReplyTopicServer) ECSTaskStatus

type UnimplementedECSRequestTopicServer

type UnimplementedECSRequestTopicServer struct {
}

UnimplementedECSRequestTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedECSRequestTopicServer) RunECSTask

type UnimplementedPostgresReplyTopicServer

type UnimplementedPostgresReplyTopicServer struct {
}

UnimplementedPostgresReplyTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedPostgresReplyTopicServer) PostgresDatabaseStatus

type UnimplementedPostgresRequestTopicServer

type UnimplementedPostgresRequestTopicServer struct {
}

UnimplementedPostgresRequestTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedPostgresRequestTopicServer) CleanupPostgresDatabase

func (UnimplementedPostgresRequestTopicServer) MigratePostgresDatabase

func (UnimplementedPostgresRequestTopicServer) UpsertPostgresDatabase

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 (*UpdateStackMessage) GetSpec

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 (*UpsertPostgresDatabaseMessage) GetSpec

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 (*UpsertPostgresDatabaseMessage) Reset

func (x *UpsertPostgresDatabaseMessage) Reset()

func (*UpsertPostgresDatabaseMessage) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL