api

Documentation

Index

• func FromProtoService(s *definition.Service) *service.Service
• type Server
  • func NewServer(sdk *sdk.SDK) *Server
  • func (s *Server) Get(ctx context.Context, req *api.GetExecutionRequest) (*definition.Execution, error)
  • func (s *Server) Stream(req *api.StreamExecutionRequest, resp api.Execution_StreamServer) error

Functions

func FromProtoService

func FromProtoService(s *definition.Service) *service.Service

Types

type Server

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

Server serve execution functions.

func NewServer

func NewServer(sdk *sdk.SDK) *Server

NewServer creates a new Server.

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *api.GetExecutionRequest) (*definition.Execution, error)

Get returns execution from given hash.

func (*Server) Stream

func (s *Server) Stream(req *api.StreamExecutionRequest, resp api.Execution_StreamServer) error

Stream returns stream of executions.