grpc_agent

Documentation

Index

• func NewValidator() *validator.Validate
• type AuthToken
  • func NewAuthToken(token string, secure bool) *AuthToken
  • func (a *AuthToken) GetRequestMetadata(context.Context, ...string) (map[string]string, error)
  • func (a *AuthToken) RequireTransportSecurity() bool
• type CreateDatabaseRequest
  • func NewCreateDatabaseRequest(job *proto.DbJob) *CreateDatabaseRequest
  • func (r *CreateDatabaseRequest) Process(h *GrpcAgentHandler) error
• type DbStatusSender
  • func (s *DbStatusSender) Handle(msg server.NamedElement) error
  • func (s *DbStatusSender) Init(setter server.GlobalSetter) error
  • func (s *DbStatusSender) PostInit(getter server.GlobalGetter) error
• type GrpcAgentHandler
  • func NewGrpcAgentHandler(dbApi *db.DbApi, grpcClient proto.DbJobSvcClient, jobProducer server.Producer, ...) *GrpcAgentHandler
• type GrpcAgentServer
  • func NewGrpcAgentServer(grpcConfig *config.GrpcClientConfig, quitCtx context.Context) *GrpcAgentServer
  • func (s *GrpcAgentServer) Init(setter server.GlobalSetter) error
  • func (s *GrpcAgentServer) PostInit(getter server.GlobalGetter) error
  • func (s *GrpcAgentServer) Run()
  • func (s *GrpcAgentServer) Shutdown(ctx context.Context)
• type MigrateOutDatabaseRequest
  • func NewMigrateOutDatabaseRequest(task *proto.DbJob) *MigrateOutDatabaseRequest
  • func (r *MigrateOutDatabaseRequest) Process(h *GrpcAgentHandler) error

Functions

func NewValidator

func NewValidator() *validator.Validate

Types

type AuthToken

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

func NewAuthToken

func NewAuthToken(token string, secure bool) *AuthToken

func (*AuthToken) GetRequestMetadata

func (a *AuthToken) GetRequestMetadata(context.Context, ...string) (map[string]string, error)

func (*AuthToken) RequireTransportSecurity

func (a *AuthToken) RequireTransportSecurity() bool

type CreateDatabaseRequest

type CreateDatabaseRequest struct {
	*proto.CreateDatabaseJob
	JobId uuid.UUID
}

func NewCreateDatabaseRequest

func NewCreateDatabaseRequest(job *proto.DbJob) *CreateDatabaseRequest

func (*CreateDatabaseRequest) Process

func (r *CreateDatabaseRequest) Process(h *GrpcAgentHandler) error

type DbStatusSender

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

func (*DbStatusSender) Handle

func (s *DbStatusSender) Handle(msg server.NamedElement) error

func (*DbStatusSender) Init

func (s *DbStatusSender) Init(setter server.GlobalSetter) error

func (*DbStatusSender) PostInit

func (s *DbStatusSender) PostInit(getter server.GlobalGetter) error

type GrpcAgentHandler

type GrpcAgentHandler struct {
	DbApi *db.DbApi

	GrpcClient proto.DbJobSvcClient
	QuitCtx    context.Context

	JobProducer server.Producer
	Validator   *validator.Validate
}

func NewGrpcAgentHandler

func NewGrpcAgentHandler(dbApi *db.DbApi, grpcClient proto.DbJobSvcClient, jobProducer server.Producer, quitCtx context.Context) *GrpcAgentHandler

type GrpcAgentServer

type GrpcAgentServer struct {
	GrpcConfig *config.GrpcClientConfig
	GrpcClient proto.DbJobSvcClient

	QuitCtx context.Context

	DbApi *db.DbApi
	// contains filtered or unexported fields
}

func NewGrpcAgentServer

func NewGrpcAgentServer(grpcConfig *config.GrpcClientConfig, quitCtx context.Context) *GrpcAgentServer

func (*GrpcAgentServer) Init

func (s *GrpcAgentServer) Init(setter server.GlobalSetter) error

func (*GrpcAgentServer) PostInit

func (s *GrpcAgentServer) PostInit(getter server.GlobalGetter) error

func (*GrpcAgentServer) Run

func (s *GrpcAgentServer) Run()

func (*GrpcAgentServer) Shutdown

func (s *GrpcAgentServer) Shutdown(ctx context.Context)

type MigrateOutDatabaseRequest

type MigrateOutDatabaseRequest struct {
	*proto.MigrateOutDatabaseJob
	JobId uuid.UUID
}

func NewMigrateOutDatabaseRequest

func NewMigrateOutDatabaseRequest(task *proto.DbJob) *MigrateOutDatabaseRequest

func (*MigrateOutDatabaseRequest) Process

func (r *MigrateOutDatabaseRequest) Process(h *GrpcAgentHandler) error