executor

Documentation

Index

• type Config
• type Server
  • func NewServer(syslog *zap.SugaredLogger, config Config) *Server
  • func (s *Server) Close(ctx context.Context, req *executorv1.CloseRequest) (*executorv1.CloseResponse, error)
  • func (s *Server) Events(req *executorv1.EventsRequest, stream executorv1.Executor_EventsServer) error
  • func (s *Server) Exec(ctx context.Context, req *executorv1.ExecRequest) (*executorv1.ExecResponse, error)
  • func (s *Server) Export(req *executorv1.ExportRequest, stream executorv1.Executor_ExportServer) error
  • func (s *Server) Heartbeat(ctx context.Context, req *executorv1.HeartbeatRequest) (*executorv1.HeartbeatResponse, error)
  • func (s *Server) Import(stream executorv1.Executor_ImportServer) error
  • func (s *Server) Introspect(ctx context.Context, req *executorv1.IntrospectRequest) (*executorv1.IntrospectResponse, error)
  • func (s *Server) Open(ctx context.Context, req *executorv1.OpenRequest) (*executorv1.OpenResponse, error)
  • func (s *Server) Stop()

Types

type Config

type Config struct {
	// Name is the name of the executor.
	Name string
	// Labels the executor will advertise to the broker.
	Labels []string
}

type Server

type Server struct {
	executorv1.UnimplementedExecutorServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(syslog *zap.SugaredLogger, config Config) *Server

func (*Server) Close

func (s *Server) Close(ctx context.Context, req *executorv1.CloseRequest) (*executorv1.CloseResponse, error)

func (*Server) Events

func (s *Server) Events(req *executorv1.EventsRequest, stream executorv1.Executor_EventsServer) error

func (*Server) Exec

func (s *Server) Exec(ctx context.Context, req *executorv1.ExecRequest) (*executorv1.ExecResponse, error)

func (*Server) Export

func (s *Server) Export(req *executorv1.ExportRequest, stream executorv1.Executor_ExportServer) error

func (*Server) Heartbeat

func (s *Server) Heartbeat(ctx context.Context, req *executorv1.HeartbeatRequest) (*executorv1.HeartbeatResponse, error)

func (*Server) Import

func (s *Server) Import(stream executorv1.Executor_ImportServer) error

func (*Server) Introspect

func (s *Server) Introspect(ctx context.Context, req *executorv1.IntrospectRequest) (*executorv1.IntrospectResponse, error)

func (*Server) Open

func (s *Server) Open(ctx context.Context, req *executorv1.OpenRequest) (*executorv1.OpenResponse, error)

func (*Server) Stop

func (s *Server) Stop()