core

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package core is a generated protocol buffer package.

It is generated from these files: 

github.com/mesg-foundation/core/api/core/api.proto

It has these top-level messages: 

ListenEventRequest
ExecuteTaskRequest
ListenResultRequest
StartServiceRequest
StopServiceRequest
EventData
ExecuteTaskReply
ResultData
StartServiceReply
StopServiceReply
DeployServiceRequest
DeployServiceReply
DeleteServiceRequest
DeleteServiceReply
ListServicesRequest
ListServicesReply
GetServiceRequest
GetServiceReply

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCoreServer 

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

Types

type CoreClient 

type CoreClient interface {
	ListenEvent(ctx context.Context, in *ListenEventRequest, opts ...grpc.CallOption) (Core_ListenEventClient, error)
	ExecuteTask(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskReply, error)
	ListenResult(ctx context.Context, in *ListenResultRequest, opts ...grpc.CallOption) (Core_ListenResultClient, error)
	StartService(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*StartServiceReply, error)
	StopService(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*StopServiceReply, error)
	DeployService(ctx context.Context, in *DeployServiceRequest, opts ...grpc.CallOption) (*DeployServiceReply, error)
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceReply, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesReply, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceReply, error)
}

func NewCoreClient 

func NewCoreClient(cc *grpc.ClientConn) CoreClient

type CoreServer 

type CoreServer interface {
	ListenEvent(*ListenEventRequest, Core_ListenEventServer) error
	ExecuteTask(context.Context, *ExecuteTaskRequest) (*ExecuteTaskReply, error)
	ListenResult(*ListenResultRequest, Core_ListenResultServer) error
	StartService(context.Context, *StartServiceRequest) (*StartServiceReply, error)
	StopService(context.Context, *StopServiceRequest) (*StopServiceReply, error)
	DeployService(context.Context, *DeployServiceRequest) (*DeployServiceReply, error)
	DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceReply, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesReply, error)
	GetService(context.Context, *GetServiceRequest) (*GetServiceReply, error)
}

type Core_ListenEventClient 

type Core_ListenEventClient interface {
	Recv() (*EventData, error)
	grpc.ClientStream
}

type Core_ListenEventServer 

type Core_ListenEventServer interface {
	Send(*EventData) error
	grpc.ServerStream
}

type Core_ListenResultClient 

type Core_ListenResultClient interface {
	Recv() (*ResultData, error)
	grpc.ClientStream
}

type Core_ListenResultServer 

type Core_ListenResultServer interface {
	Send(*ResultData) error
	grpc.ServerStream
}

type DeleteServiceReply 

type DeleteServiceReply struct {
}

func (*DeleteServiceReply) Descriptor 

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

func (*DeleteServiceReply) ProtoMessage 

func (*DeleteServiceReply) ProtoMessage()

func (*DeleteServiceReply) Reset 

func (m *DeleteServiceReply) Reset()

func (*DeleteServiceReply) String 

func (m *DeleteServiceReply) String() string

type DeleteServiceRequest 

type DeleteServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
}

func (*DeleteServiceRequest) Descriptor 

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

func (*DeleteServiceRequest) GetServiceID 

func (m *DeleteServiceRequest) GetServiceID() string

func (*DeleteServiceRequest) ProtoMessage 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) Reset 

func (m *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String 

func (m *DeleteServiceRequest) String() string

type DeployServiceReply 

type DeployServiceReply struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
}

func (*DeployServiceReply) Descriptor 

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

func (*DeployServiceReply) GetServiceID 

func (m *DeployServiceReply) GetServiceID() string

func (*DeployServiceReply) ProtoMessage 

func (*DeployServiceReply) ProtoMessage()

func (*DeployServiceReply) Reset 

func (m *DeployServiceReply) Reset()

func (*DeployServiceReply) String 

func (m *DeployServiceReply) String() string

type DeployServiceRequest 

type DeployServiceRequest struct {
	Service *service.Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*DeployServiceRequest) Descriptor 

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

func (*DeployServiceRequest) GetService 

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

func (*DeployServiceRequest) ProtoMessage 

func (*DeployServiceRequest) ProtoMessage()

func (*DeployServiceRequest) Reset 

func (m *DeployServiceRequest) Reset()

func (*DeployServiceRequest) String 

func (m *DeployServiceRequest) String() string

type EventData 

type EventData struct {
	EventKey  string `protobuf:"bytes,1,opt,name=eventKey" json:"eventKey,omitempty"`
	EventData string `protobuf:"bytes,2,opt,name=eventData" json:"eventData,omitempty"`
}

func (*EventData) Descriptor 

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

func (*EventData) GetEventData 

func (m *EventData) GetEventData() string

func (*EventData) GetEventKey 

func (m *EventData) GetEventKey() string

func (*EventData) ProtoMessage 

func (*EventData) ProtoMessage()

func (*EventData) Reset 

func (m *EventData) Reset()

func (*EventData) String 

func (m *EventData) String() string

type ExecuteTaskReply 

type ExecuteTaskReply struct {
	ExecutionID string `protobuf:"bytes,1,opt,name=executionID" json:"executionID,omitempty"`
}

func (*ExecuteTaskReply) Descriptor 

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

func (*ExecuteTaskReply) GetExecutionID 

func (m *ExecuteTaskReply) GetExecutionID() string

func (*ExecuteTaskReply) ProtoMessage 

func (*ExecuteTaskReply) ProtoMessage()

func (*ExecuteTaskReply) Reset 

func (m *ExecuteTaskReply) Reset()

func (*ExecuteTaskReply) String 

func (m *ExecuteTaskReply) String() string

type ExecuteTaskRequest 

type ExecuteTaskRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
	TaskKey   string `protobuf:"bytes,2,opt,name=taskKey" json:"taskKey,omitempty"`
	InputData string `protobuf:"bytes,3,opt,name=inputData" json:"inputData,omitempty"`
}

func (*ExecuteTaskRequest) Descriptor 

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

func (*ExecuteTaskRequest) GetInputData added in v1.0.0 

func (m *ExecuteTaskRequest) GetInputData() string

func (*ExecuteTaskRequest) GetServiceID 

func (m *ExecuteTaskRequest) GetServiceID() string

func (*ExecuteTaskRequest) GetTaskKey 

func (m *ExecuteTaskRequest) GetTaskKey() string

func (*ExecuteTaskRequest) ProtoMessage 

func (*ExecuteTaskRequest) ProtoMessage()

func (*ExecuteTaskRequest) Reset 

func (m *ExecuteTaskRequest) Reset()

func (*ExecuteTaskRequest) String 

func (m *ExecuteTaskRequest) String() string

type GetServiceReply added in v1.0.0 

type GetServiceReply struct {
	Service *service.Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*GetServiceReply) Descriptor added in v1.0.0 

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

func (*GetServiceReply) GetService added in v1.0.0 

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

func (*GetServiceReply) ProtoMessage added in v1.0.0 

func (*GetServiceReply) ProtoMessage()

func (*GetServiceReply) Reset added in v1.0.0 

func (m *GetServiceReply) Reset()

func (*GetServiceReply) String added in v1.0.0 

func (m *GetServiceReply) String() string

type GetServiceRequest added in v1.0.0 

type GetServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
}

func (*GetServiceRequest) Descriptor added in v1.0.0 

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

func (*GetServiceRequest) GetServiceID added in v1.0.0 

func (m *GetServiceRequest) GetServiceID() string

func (*GetServiceRequest) ProtoMessage added in v1.0.0 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset added in v1.0.0 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String added in v1.0.0 

func (m *GetServiceRequest) String() string

type ListServicesReply added in v1.0.0 

type ListServicesReply struct {
	Services []*service.Service `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`
}

func (*ListServicesReply) Descriptor added in v1.0.0 

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

func (*ListServicesReply) GetServices added in v1.0.0 

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

func (*ListServicesReply) ProtoMessage added in v1.0.0 

func (*ListServicesReply) ProtoMessage()

func (*ListServicesReply) Reset added in v1.0.0 

func (m *ListServicesReply) Reset()

func (*ListServicesReply) String added in v1.0.0 

func (m *ListServicesReply) String() string

type ListServicesRequest added in v1.0.0 

type ListServicesRequest struct {
}

func (*ListServicesRequest) Descriptor added in v1.0.0 

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

func (*ListServicesRequest) ProtoMessage added in v1.0.0 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) Reset added in v1.0.0 

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) String added in v1.0.0 

func (m *ListServicesRequest) String() string

type ListenEventRequest 

type ListenEventRequest struct {
	ServiceID   string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
	EventFilter string `protobuf:"bytes,2,opt,name=eventFilter" json:"eventFilter,omitempty"`
}

func (*ListenEventRequest) Descriptor 

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

func (*ListenEventRequest) GetEventFilter 

func (m *ListenEventRequest) GetEventFilter() string

func (*ListenEventRequest) GetServiceID 

func (m *ListenEventRequest) GetServiceID() string

func (*ListenEventRequest) ProtoMessage 

func (*ListenEventRequest) ProtoMessage()

func (*ListenEventRequest) Reset 

func (m *ListenEventRequest) Reset()

func (*ListenEventRequest) String 

func (m *ListenEventRequest) String() string

type ListenResultRequest 

type ListenResultRequest struct {
	ServiceID    string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
	TaskFilter   string `protobuf:"bytes,2,opt,name=taskFilter" json:"taskFilter,omitempty"`
	OutputFilter string `protobuf:"bytes,3,opt,name=outputFilter" json:"outputFilter,omitempty"`
}

func (*ListenResultRequest) Descriptor 

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

func (*ListenResultRequest) GetOutputFilter 

func (m *ListenResultRequest) GetOutputFilter() string

func (*ListenResultRequest) GetServiceID 

func (m *ListenResultRequest) GetServiceID() string

func (*ListenResultRequest) GetTaskFilter 

func (m *ListenResultRequest) GetTaskFilter() string

func (*ListenResultRequest) ProtoMessage 

func (*ListenResultRequest) ProtoMessage()

func (*ListenResultRequest) Reset 

func (m *ListenResultRequest) Reset()

func (*ListenResultRequest) String 

func (m *ListenResultRequest) String() string

type ResultData 

type ResultData struct {
	ExecutionID string `protobuf:"bytes,1,opt,name=executionID" json:"executionID,omitempty"`
	TaskKey     string `protobuf:"bytes,2,opt,name=taskKey" json:"taskKey,omitempty"`
	OutputKey   string `protobuf:"bytes,3,opt,name=outputKey" json:"outputKey,omitempty"`
	OutputData  string `protobuf:"bytes,4,opt,name=outputData" json:"outputData,omitempty"`
}

func (*ResultData) Descriptor 

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

func (*ResultData) GetExecutionID 

func (m *ResultData) GetExecutionID() string

func (*ResultData) GetOutputData 

func (m *ResultData) GetOutputData() string

func (*ResultData) GetOutputKey 

func (m *ResultData) GetOutputKey() string

func (*ResultData) GetTaskKey 

func (m *ResultData) GetTaskKey() string

func (*ResultData) ProtoMessage 

func (*ResultData) ProtoMessage()

func (*ResultData) Reset 

func (m *ResultData) Reset()

func (*ResultData) String 

func (m *ResultData) String() string

type Server 

type Server struct{}

Server is the type to aggregate all the apis

func (*Server) DeleteService 

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

DeleteService delete a service in the database and eventually stop the docker of this service

func (*Server) DeployService 

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

DeployService save a service in the database and return the hash of this service

func (*Server) ExecuteTask 

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

ExecuteTask will execute a task for a given service

func (*Server) GetService added in v1.0.0 

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

GetService fetch a service in the db and return ot

func (*Server) ListServices added in v1.0.0 

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

ListServices return all services from the database

func (*Server) ListenEvent 

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

ListenEvent for listen event from a specific service services

func (*Server) ListenResult 

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

ListenResult will listen for results from a services

func (*Server) StartService 

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

StartService fetch a service in the db and starts it

func (*Server) StopService 

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

StopService fetch a service in db and stop it

type StartServiceReply 

type StartServiceReply struct {
}

func (*StartServiceReply) Descriptor 

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

func (*StartServiceReply) ProtoMessage 

func (*StartServiceReply) ProtoMessage()

func (*StartServiceReply) Reset 

func (m *StartServiceReply) Reset()

func (*StartServiceReply) String 

func (m *StartServiceReply) String() string

type StartServiceRequest 

type StartServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
}

func (*StartServiceRequest) Descriptor 

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

func (*StartServiceRequest) GetServiceID 

func (m *StartServiceRequest) GetServiceID() string

func (*StartServiceRequest) ProtoMessage 

func (*StartServiceRequest) ProtoMessage()

func (*StartServiceRequest) Reset 

func (m *StartServiceRequest) Reset()

func (*StartServiceRequest) String 

func (m *StartServiceRequest) String() string

type StopServiceReply 

type StopServiceReply struct {
}

func (*StopServiceReply) Descriptor 

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

func (*StopServiceReply) ProtoMessage 

func (*StopServiceReply) ProtoMessage()

func (*StopServiceReply) Reset 

func (m *StopServiceReply) Reset()

func (*StopServiceReply) String 

func (m *StopServiceReply) String() string

type StopServiceRequest 

type StopServiceRequest struct {
	ServiceID string `protobuf:"bytes,1,opt,name=serviceID" json:"serviceID,omitempty"`
}

func (*StopServiceRequest) Descriptor 

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

func (*StopServiceRequest) GetServiceID 

func (m *StopServiceRequest) GetServiceID() string

func (*StopServiceRequest) ProtoMessage 

func (*StopServiceRequest) ProtoMessage()

func (*StopServiceRequest) Reset 

func (m *StopServiceRequest) Reset()

func (*StopServiceRequest) String 

func (m *StopServiceRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.