service

package
v0.0.0-...-cdab844 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2025 License: MIT Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ChangeSetStatusToEvent 

func ChangeSetStatusToEvent(msg *awsinfra_tpb.ChangeSetStatusChangedMessage) (*awsdeployer_pb.DeploymentPSMEventSpec, error)

func ECSDeploymentStatusToEvent 

func ECSDeploymentStatusToEvent(msg *awsinfra_tpb.ECSDeploymentStatusMessage) (*awsdeployer_pb.DeploymentPSMEventSpec, error)

func ECSTaskStatusToEvent 

func ECSTaskStatusToEvent(msg *awsinfra_tpb.ECSTaskStatusMessage) (*awsdeployer_pb.DeploymentPSMEventSpec, error)

func GRPCMiddleware 

func GRPCMiddleware() []grpc.UnaryServerInterceptor

func PostgresMigrationToEvent 

func PostgresMigrationToEvent(msg *awsinfra_tpb.PostgresDatabaseStatusMessage) (*awsdeployer_pb.DeploymentPSMEventSpec, error)

func StackStatusToEvent 

func StackStatusToEvent(msg *awsinfra_tpb.StackStatusChangedMessage) (*awsdeployer_pb.DeploymentPSMEventSpec, error)

Types

type App 

type App struct {
	DeployerWorker *DeployerWorker
	CommandService *CommandService
	QueryService   *QueryService
}

func NewApp 

func NewApp(deps AppDeps) (*App, error)

func (*App) RegisterGRPC 

func (app *App) RegisterGRPC(server *grpc.Server)

type AppDeps 

type AppDeps struct {
	SpecBuilder  *deployer.SpecBuilder
	GithubClient GithubClient
	DB           sqrlx.Transactor
}

type CommandService 

type CommandService struct {
	*LookupProvider

	awsdeployer_spb.UnsafeDeploymentCommandServiceServer
	// contains filtered or unexported fields
}

func NewCommandService 

func NewCommandService(db sqrlx.Transactor, github GithubClient, stateMachines *states.StateMachines) (*CommandService, error)

func (*CommandService) SetClusterOverride 

func (ds *CommandService) SetClusterOverride(ctx context.Context, req *awsdeployer_spb.SetClusterOverrideRequest) (*awsdeployer_spb.SetClusterOverrideResponse, error)

func (*CommandService) TerminateDeployment 

func (ds *CommandService) TerminateDeployment(ctx context.Context, req *awsdeployer_spb.TerminateDeploymentRequest) (*awsdeployer_spb.TerminateDeploymentResponse, error)

func (*CommandService) TriggerDeployment 

func (ds *CommandService) TriggerDeployment(ctx context.Context, req *awsdeployer_spb.TriggerDeploymentRequest) (*awsdeployer_spb.TriggerDeploymentResponse, error)

func (*CommandService) UpsertCluster 

func (ds *CommandService) UpsertCluster(ctx context.Context, req *awsdeployer_spb.UpsertClusterRequest) (*awsdeployer_spb.UpsertClusterResponse, error)

func (*CommandService) UpsertEnvironment 

func (ds *CommandService) UpsertEnvironment(ctx context.Context, req *awsdeployer_spb.UpsertEnvironmentRequest) (*awsdeployer_spb.UpsertEnvironmentResponse, error)

func (*CommandService) UpsertStack 

func (ds *CommandService) UpsertStack(ctx context.Context, req *awsdeployer_spb.UpsertStackRequest) (*awsdeployer_spb.UpsertStackResponse, error)

type DeployerWorker 

type DeployerWorker struct {
	awsdeployer_tpb.UnsafeDeploymentRequestTopicServer
	awsinfra_tpb.UnsafeCloudFormationReplyTopicServer
	awsinfra_tpb.UnsafePostgresReplyTopicServer
	awsinfra_tpb.UnsafeECSReplyTopicServer
	// contains filtered or unexported fields
}

func NewDeployerWorker 

func NewDeployerWorker(db sqrlx.Transactor, specBuilder *deployer.SpecBuilder, states *states.StateMachines) (*DeployerWorker, error)

func (*DeployerWorker) ChangeSetStatusChanged 

func (dw *DeployerWorker) ChangeSetStatusChanged(ctx context.Context, msg *awsinfra_tpb.ChangeSetStatusChangedMessage) (*emptypb.Empty, error)

func (*DeployerWorker) ECSDeploymentStatus 

func (dw *DeployerWorker) ECSDeploymentStatus(ctx context.Context, msg *awsinfra_tpb.ECSDeploymentStatusMessage) (*emptypb.Empty, error)

func (*DeployerWorker) ECSTaskStatus 

func (dw *DeployerWorker) ECSTaskStatus(ctx context.Context, msg *awsinfra_tpb.ECSTaskStatusMessage) (*emptypb.Empty, error)

func (*DeployerWorker) PostgresDatabaseStatus 

func (dw *DeployerWorker) PostgresDatabaseStatus(ctx context.Context, msg *awsinfra_tpb.PostgresDatabaseStatusMessage) (*emptypb.Empty, error)

func (*DeployerWorker) RequestDeployment 

func (dw *DeployerWorker) RequestDeployment(ctx context.Context, msg *awsdeployer_tpb.RequestDeploymentMessage) (*emptypb.Empty, error)

func (*DeployerWorker) StackStatusChanged 

func (dw *DeployerWorker) StackStatusChanged(ctx context.Context, msg *awsinfra_tpb.StackStatusChangedMessage) (*emptypb.Empty, error)

type GithubClient 

type GithubClient interface {
	PullO5Configs(ctx context.Context, owner, repo, commit string) ([]*application_pb.Application, error)
}

type LookupProvider 

type LookupProvider struct {
	// contains filtered or unexported fields
}

LookupProvider allows API calls to be requested with names rather than UUIDs for the state machines.

func NewLookupProvider 

func NewLookupProvider(db sqrlx.Transactor) (*LookupProvider, error)

type QueryService 

type QueryService struct {
	*awsdeployer_spb.UnimplementedDeploymentQueryServiceServer

	*awsdeployer_spb.UnimplementedStackQueryServiceServer

	*awsdeployer_spb.UnimplementedEnvironmentQueryServiceServer

	*awsdeployer_spb.UnimplementedClusterQueryServiceServer
	// contains filtered or unexported fields
}

func NewQueryService 

func NewQueryService(db sqrlx.Transactor, stateMachines *states.StateMachines) (*QueryService, error)

func (*QueryService) GetCluster 

func (ds *QueryService) GetCluster(ctx context.Context, req *awsdeployer_spb.GetClusterRequest) (*awsdeployer_spb.GetClusterResponse, error)

func (*QueryService) GetDeployment 

func (ds *QueryService) GetDeployment(ctx context.Context, req *awsdeployer_spb.GetDeploymentRequest) (*awsdeployer_spb.GetDeploymentResponse, error)

func (*QueryService) GetEnvironment 

func (ds *QueryService) GetEnvironment(ctx context.Context, req *awsdeployer_spb.GetEnvironmentRequest) (*awsdeployer_spb.GetEnvironmentResponse, error)

func (*QueryService) GetStack 

func (ds *QueryService) GetStack(ctx context.Context, req *awsdeployer_spb.GetStackRequest) (*awsdeployer_spb.GetStackResponse, error)

func (*QueryService) ListClusterEvents 

func (ds *QueryService) ListClusterEvents(ctx context.Context, req *awsdeployer_spb.ListClusterEventsRequest) (*awsdeployer_spb.ListClusterEventsResponse, error)

func (*QueryService) ListClusters 

func (ds *QueryService) ListClusters(ctx context.Context, req *awsdeployer_spb.ListClustersRequest) (*awsdeployer_spb.ListClustersResponse, error)

func (*QueryService) ListDeploymentEvents 

func (ds *QueryService) ListDeploymentEvents(ctx context.Context, req *awsdeployer_spb.ListDeploymentEventsRequest) (*awsdeployer_spb.ListDeploymentEventsResponse, error)

func (*QueryService) ListDeployments 

func (ds *QueryService) ListDeployments(ctx context.Context, req *awsdeployer_spb.ListDeploymentsRequest) (*awsdeployer_spb.ListDeploymentsResponse, error)

func (*QueryService) ListEnvironmentEvents 

func (ds *QueryService) ListEnvironmentEvents(ctx context.Context, req *awsdeployer_spb.ListEnvironmentEventsRequest) (*awsdeployer_spb.ListEnvironmentEventsResponse, error)

func (*QueryService) ListEnvironments 

func (ds *QueryService) ListEnvironments(ctx context.Context, req *awsdeployer_spb.ListEnvironmentsRequest) (*awsdeployer_spb.ListEnvironmentsResponse, error)

func (*QueryService) ListStackEvents 

func (ds *QueryService) ListStackEvents(ctx context.Context, req *awsdeployer_spb.ListStackEventsRequest) (*awsdeployer_spb.ListStackEventsResponse, error)

func (*QueryService) ListStacks 

func (ds *QueryService) ListStacks(ctx context.Context, req *awsdeployer_spb.ListStacksRequest) (*awsdeployer_spb.ListStacksResponse, error)

func (*QueryService) RegisterGRPC 

func (ds *QueryService) RegisterGRPC(s *grpc.Server)

Source Files

View all Source files

Directories

Path Synopsis
internal
states

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.