grpcmgmt

Documentation

Index

• type Server
  • func NewServer(parentCtx context.Context, pool *pgxpool.Pool, updater *updater.Updater, ...) *Server
  • func (s *Server) RegisterWorkload(ctx context.Context, request *management.RegisterWorkloadRequest) (*management.RegisterWorkloadResponse, error)
  • func (s *Server) TriggerSync(_ context.Context, _ *management.TriggerSyncRequest) (*management.TriggerSyncResponse, error)

Types

type Server

type Server struct {
	management.UnimplementedManagementServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(parentCtx context.Context, pool *pgxpool.Pool, updater *updater.Updater, field *logrus.Entry) *Server

func (*Server) RegisterWorkload

func (s *Server) RegisterWorkload(ctx context.Context, request *management.RegisterWorkloadRequest) (*management.RegisterWorkloadResponse, error)

func (*Server) TriggerSync

func (s *Server) TriggerSync(_ context.Context, _ *management.TriggerSyncRequest) (*management.TriggerSyncResponse, error)