executor

Documentation

Index

• type Server
  • func New(publisher pulsarutils.Publisher[*controlplaneevents.Event], ...) *Server
  • func (s *Server) CancelOnExecutor(grpcCtx context.Context, req *api.ExecutorCancelRequest) (*types.Empty, error)
  • func (s *Server) DeleteExecutorSettings(grpcCtx context.Context, req *api.ExecutorSettingsDeleteRequest) (*types.Empty, error)
  • func (s *Server) PreemptOnExecutor(grpcCtx context.Context, req *api.ExecutorPreemptRequest) (*types.Empty, error)
  • func (s *Server) UpsertExecutorSettings(grpcCtx context.Context, req *api.ExecutorSettingsUpsertRequest) (*types.Empty, error)

Types

type Server

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

func New

func New(
	publisher pulsarutils.Publisher[*controlplaneevents.Event],
	authorizer auth.ActionAuthorizer,
) *Server

func (*Server) CancelOnExecutor

func (s *Server) CancelOnExecutor(grpcCtx context.Context, req *api.ExecutorCancelRequest) (*types.Empty, error)

func (*Server) DeleteExecutorSettings

func (s *Server) DeleteExecutorSettings(grpcCtx context.Context, req *api.ExecutorSettingsDeleteRequest) (*types.Empty, error)

func (*Server) PreemptOnExecutor

func (s *Server) PreemptOnExecutor(grpcCtx context.Context, req *api.ExecutorPreemptRequest) (*types.Empty, error)

func (*Server) UpsertExecutorSettings

func (s *Server) UpsertExecutorSettings(grpcCtx context.Context, req *api.ExecutorSettingsUpsertRequest) (*types.Empty, error)