core

Documentation

Index

• type Server
  • func NewServer(api *api.API, ss *systemservices.SystemServices) *Server
  • func (s *Server) CreateWorkflow(ctx context.Context, request *coreapi.CreateWorkflowRequest) (*coreapi.CreateWorkflowReply, error)
  • func (s *Server) DeleteService(ctx context.Context, request *coreapi.DeleteServiceRequest) (*coreapi.DeleteServiceReply, error)
  • func (s *Server) DeleteWorkflow(ctx context.Context, request *coreapi.DeleteWorkflowRequest) (*coreapi.DeleteWorkflowReply, error)
  • func (s *Server) DeployService(stream coreapi.Core_DeployServiceServer) error
  • func (s *Server) ExecuteTask(ctx context.Context, request *coreapi.ExecuteTaskRequest) (*coreapi.ExecuteTaskReply, error)
  • func (s *Server) GetService(ctx context.Context, request *coreapi.GetServiceRequest) (*coreapi.GetServiceReply, error)
  • func (s *Server) ListServices(ctx context.Context, request *coreapi.ListServicesRequest) (*coreapi.ListServicesReply, error)
  • func (s *Server) ListenEvent(request *coreapi.ListenEventRequest, stream coreapi.Core_ListenEventServer) error
  • func (s *Server) ListenResult(request *coreapi.ListenResultRequest, stream coreapi.Core_ListenResultServer) error
  • func (s *Server) ServiceLogs(request *coreapi.ServiceLogsRequest, stream coreapi.Core_ServiceLogsServer) error
  • func (s *Server) StartService(ctx context.Context, request *coreapi.StartServiceRequest) (*coreapi.StartServiceReply, error)
  • func (s *Server) StopService(ctx context.Context, request *coreapi.StopServiceRequest) (*coreapi.StopServiceReply, error)

Types

type Server

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

Server is the type to aggregate all the APIs.

func NewServer

func NewServer(api *api.API, ss *systemservices.SystemServices) *Server

NewServer creates a new Server.

func (*Server) CreateWorkflow

func (s *Server) CreateWorkflow(ctx context.Context, request *coreapi.CreateWorkflowRequest) (*coreapi.CreateWorkflowReply, error)

CreateWorkflow creates and runs a new workflow.

func (*Server) DeleteService

func (s *Server) DeleteService(ctx context.Context, request *coreapi.DeleteServiceRequest) (*coreapi.DeleteServiceReply, error)

DeleteService stops and deletes service serviceID.

func (*Server) DeleteWorkflow

func (s *Server) DeleteWorkflow(ctx context.Context, request *coreapi.DeleteWorkflowRequest) (*coreapi.DeleteWorkflowReply, error)

DeleteWorkflow stops and deletes a workflow.

func (*Server) DeployService

func (s *Server) DeployService(stream coreapi.Core_DeployServiceServer) error

DeployService deploys a service from Git URL or service.tar.gz file. It'll send status events during the process and finish with sending service id or validation error.

func (*Server) ExecuteTask

func (s *Server) ExecuteTask(ctx context.Context, request *coreapi.ExecuteTaskRequest) (*coreapi.ExecuteTaskReply, error)

ExecuteTask executes a task for a given service.

func (*Server) GetService

func (s *Server) GetService(ctx context.Context, request *coreapi.GetServiceRequest) (*coreapi.GetServiceReply, error)

GetService returns service serviceID.

func (*Server) ListServices

func (s *Server) ListServices(ctx context.Context, request *coreapi.ListServicesRequest) (*coreapi.ListServicesReply, error)

ListServices lists services.

func (*Server) ListenEvent

func (s *Server) ListenEvent(request *coreapi.ListenEventRequest, stream coreapi.Core_ListenEventServer) error

ListenEvent listens events matches with eventFilter on serviceID.

func (*Server) ListenResult

func (s *Server) ListenResult(request *coreapi.ListenResultRequest, stream coreapi.Core_ListenResultServer) error

ListenResult listens for results from a services.

func (*Server) ServiceLogs

func (s *Server) ServiceLogs(request *coreapi.ServiceLogsRequest, stream coreapi.Core_ServiceLogsServer) error

ServiceLogs gives logs of service with the applied dependency filters.

func (*Server) StartService

func (s *Server) StartService(ctx context.Context, request *coreapi.StartServiceRequest) (*coreapi.StartServiceReply, error)

StartService starts a service.

func (*Server) StopService

func (s *Server) StopService(ctx context.Context, request *coreapi.StopServiceRequest) (*coreapi.StopServiceReply, error)

StopService stops a service.