core

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 20, 2018

Changes in this version

type ExecuteTaskRequest

+ ExecutionTags []string

+ func (m *ExecuteTaskRequest) GetExecutionTags() []string

type ListenResultRequest

+ TagFilters []string

+ func (m *ListenResultRequest) GetTagFilters() []string

+ type NotRunningServiceError struct

+ ServiceID string

+ func (e *NotRunningServiceError) Error() string

type ResultData

+ ExecutionTags []string

+ func (m *ResultData) GetExecutionTags() []string

v0.1.0

Jul 4, 2018

Changes in this version

+ func RegisterCoreServer(s *grpc.Server, srv CoreServer)

+ type CoreClient interface

+ DeleteService func(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceReply, error)

+ DeployService func(ctx context.Context, in *DeployServiceRequest, opts ...grpc.CallOption) (*DeployServiceReply, error)

+ ExecuteTask func(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskReply, error)

+ GetService func(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceReply, error)

+ ListServices func(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesReply, error)

+ ListenEvent func(ctx context.Context, in *ListenEventRequest, opts ...grpc.CallOption) (Core_ListenEventClient, error)

+ ListenResult func(ctx context.Context, in *ListenResultRequest, opts ...grpc.CallOption) (Core_ListenResultClient, error)

+ StartService func(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*StartServiceReply, error)

+ StopService func(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*StopServiceReply, error)

+ func NewCoreClient(cc *grpc.ClientConn) CoreClient

+ type CoreServer interface

+ DeleteService func(context.Context, *DeleteServiceRequest) (*DeleteServiceReply, error)

+ DeployService func(context.Context, *DeployServiceRequest) (*DeployServiceReply, error)

+ ExecuteTask func(context.Context, *ExecuteTaskRequest) (*ExecuteTaskReply, error)

+ GetService func(context.Context, *GetServiceRequest) (*GetServiceReply, error)

+ ListServices func(context.Context, *ListServicesRequest) (*ListServicesReply, error)

+ ListenEvent func(*ListenEventRequest, Core_ListenEventServer) error

+ ListenResult func(*ListenResultRequest, Core_ListenResultServer) error

+ StartService func(context.Context, *StartServiceRequest) (*StartServiceReply, error)

+ StopService func(context.Context, *StopServiceRequest) (*StopServiceReply, error)

+ type Core_ListenEventClient interface

+ Recv func() (*EventData, error)

+ type Core_ListenEventServer interface

+ Send func(*EventData) error

+ type Core_ListenResultClient interface

+ Recv func() (*ResultData, error)

+ type Core_ListenResultServer interface

+ Send func(*ResultData) error

+ type DeleteServiceReply struct

+ func (*DeleteServiceReply) Descriptor() ([]byte, []int)

+ func (*DeleteServiceReply) ProtoMessage()

+ func (m *DeleteServiceReply) Reset()

+ func (m *DeleteServiceReply) String() string

+ type DeleteServiceRequest struct

+ ServiceID string

+ func (*DeleteServiceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteServiceRequest) ProtoMessage()

+ func (m *DeleteServiceRequest) GetServiceID() string

+ func (m *DeleteServiceRequest) Reset()

+ func (m *DeleteServiceRequest) String() string

+ type DeployServiceReply struct

+ ServiceID string

+ func (*DeployServiceReply) Descriptor() ([]byte, []int)

+ func (*DeployServiceReply) ProtoMessage()

+ func (m *DeployServiceReply) GetServiceID() string

+ func (m *DeployServiceReply) Reset()

+ func (m *DeployServiceReply) String() string

+ type DeployServiceRequest struct

+ Service *service.Service

+ func (*DeployServiceRequest) Descriptor() ([]byte, []int)

+ func (*DeployServiceRequest) ProtoMessage()

+ func (m *DeployServiceRequest) GetService() *service.Service

+ func (m *DeployServiceRequest) Reset()

+ func (m *DeployServiceRequest) String() string

+ type EventData struct

+ EventData string

+ EventKey string

+ func (*EventData) Descriptor() ([]byte, []int)

+ func (*EventData) ProtoMessage()

+ func (m *EventData) GetEventData() string

+ func (m *EventData) GetEventKey() string

+ func (m *EventData) Reset()

+ func (m *EventData) String() string

+ type ExecuteTaskReply struct

+ ExecutionID string

+ func (*ExecuteTaskReply) Descriptor() ([]byte, []int)

+ func (*ExecuteTaskReply) ProtoMessage()

+ func (m *ExecuteTaskReply) GetExecutionID() string

+ func (m *ExecuteTaskReply) Reset()

+ func (m *ExecuteTaskReply) String() string

+ type ExecuteTaskRequest struct

+ InputData string

+ ServiceID string

+ TaskKey string

+ func (*ExecuteTaskRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteTaskRequest) ProtoMessage()

+ func (m *ExecuteTaskRequest) GetInputData() string

+ func (m *ExecuteTaskRequest) GetServiceID() string

+ func (m *ExecuteTaskRequest) GetTaskKey() string

+ func (m *ExecuteTaskRequest) Reset()

+ func (m *ExecuteTaskRequest) String() string

+ type GetServiceReply struct

+ Service *service.Service

+ func (*GetServiceReply) Descriptor() ([]byte, []int)

+ func (*GetServiceReply) ProtoMessage()

+ func (m *GetServiceReply) GetService() *service.Service

+ func (m *GetServiceReply) Reset()

+ func (m *GetServiceReply) String() string

+ type GetServiceRequest struct

+ ServiceID string

+ func (*GetServiceRequest) Descriptor() ([]byte, []int)

+ func (*GetServiceRequest) ProtoMessage()

+ func (m *GetServiceRequest) GetServiceID() string

+ func (m *GetServiceRequest) Reset()

+ func (m *GetServiceRequest) String() string

+ type ListServicesReply struct

+ Services []*service.Service

+ func (*ListServicesReply) Descriptor() ([]byte, []int)

+ func (*ListServicesReply) ProtoMessage()

+ func (m *ListServicesReply) GetServices() []*service.Service

+ func (m *ListServicesReply) Reset()

+ func (m *ListServicesReply) String() string

+ type ListServicesRequest struct

+ func (*ListServicesRequest) Descriptor() ([]byte, []int)

+ func (*ListServicesRequest) ProtoMessage()

+ func (m *ListServicesRequest) Reset()

+ func (m *ListServicesRequest) String() string

+ type ListenEventRequest struct

+ EventFilter string

+ ServiceID string

+ func (*ListenEventRequest) Descriptor() ([]byte, []int)

+ func (*ListenEventRequest) ProtoMessage()

+ func (m *ListenEventRequest) GetEventFilter() string

+ func (m *ListenEventRequest) GetServiceID() string

+ func (m *ListenEventRequest) Reset()

+ func (m *ListenEventRequest) String() string

+ type ListenResultRequest struct

+ OutputFilter string

+ ServiceID string

+ TaskFilter string

+ func (*ListenResultRequest) Descriptor() ([]byte, []int)

+ func (*ListenResultRequest) ProtoMessage()

+ func (m *ListenResultRequest) GetOutputFilter() string

+ func (m *ListenResultRequest) GetServiceID() string

+ func (m *ListenResultRequest) GetTaskFilter() string

+ func (m *ListenResultRequest) Reset()

+ func (m *ListenResultRequest) String() string

+ type ResultData struct

+ ExecutionID string

+ OutputData string

+ OutputKey string

+ TaskKey string

+ func (*ResultData) Descriptor() ([]byte, []int)

+ func (*ResultData) ProtoMessage()

+ func (m *ResultData) GetExecutionID() string

+ func (m *ResultData) GetOutputData() string

+ func (m *ResultData) GetOutputKey() string

+ func (m *ResultData) GetTaskKey() string

+ func (m *ResultData) Reset()

+ func (m *ResultData) String() string

+ type Server struct

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

+ func (s *Server) DeployService(ctx context.Context, request *DeployServiceRequest) (reply *DeployServiceReply, err error)

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

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

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

+ func (s *Server) ListenEvent(request *ListenEventRequest, stream Core_ListenEventServer) (err error)

+ func (s *Server) ListenResult(request *ListenResultRequest, stream Core_ListenResultServer) (err error)

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

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

+ type StartServiceReply struct

+ func (*StartServiceReply) Descriptor() ([]byte, []int)

+ func (*StartServiceReply) ProtoMessage()

+ func (m *StartServiceReply) Reset()

+ func (m *StartServiceReply) String() string

+ type StartServiceRequest struct

+ ServiceID string

+ func (*StartServiceRequest) Descriptor() ([]byte, []int)

+ func (*StartServiceRequest) ProtoMessage()

+ func (m *StartServiceRequest) GetServiceID() string

+ func (m *StartServiceRequest) Reset()

+ func (m *StartServiceRequest) String() string

+ type StopServiceReply struct

+ func (*StopServiceReply) Descriptor() ([]byte, []int)

+ func (*StopServiceReply) ProtoMessage()

+ func (m *StopServiceReply) Reset()

+ func (m *StopServiceReply) String() string

+ type StopServiceRequest struct

+ ServiceID string

+ func (*StopServiceRequest) Descriptor() ([]byte, []int)

+ func (*StopServiceRequest) ProtoMessage()

+ func (m *StopServiceRequest) GetServiceID() string

+ func (m *StopServiceRequest) Reset()

+ func (m *StopServiceRequest) String() string

v0.1.0-beta3

Jun 28, 2018

v0.1.0-beta2

Jun 20, 2018

v0.1.0-beta

Jun 7, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL