core

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 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

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)
}

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)
}

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 {
	Error     string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	EventKey  string `protobuf:"bytes,2,opt,name=eventKey" json:"eventKey,omitempty"`
	EventData string `protobuf:"bytes,3,opt,name=eventData" json:"eventData,omitempty"`
}

func (*EventData) Descriptor 

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

func (*EventData) GetError 

func (m *EventData) GetError() string

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"`
	Error       string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*ExecuteTaskReply) Descriptor 

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

func (*ExecuteTaskReply) GetError 

func (m *ExecuteTaskReply) GetError() string

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"`
	TaskData  string `protobuf:"bytes,3,opt,name=taskData" json:"taskData,omitempty"`
}

func (*ExecuteTaskRequest) Descriptor 

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

func (*ExecuteTaskRequest) GetServiceID 

func (m *ExecuteTaskRequest) GetServiceID() string

func (*ExecuteTaskRequest) GetTaskData 

func (m *ExecuteTaskRequest) GetTaskData() 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 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 {
	Error       string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	ExecutionID string `protobuf:"bytes,2,opt,name=executionID" json:"executionID,omitempty"`
	TaskKey     string `protobuf:"bytes,3,opt,name=taskKey" json:"taskKey,omitempty"`
	OutputKey   string `protobuf:"bytes,4,opt,name=outputKey" json:"outputKey,omitempty"`
	OutputData  string `protobuf:"bytes,5,opt,name=outputData" json:"outputData,omitempty"`
}

func (*ResultData) Descriptor 

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

func (*ResultData) GetError 

func (m *ResultData) GetError() string

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

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) 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 {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*StartServiceReply) Descriptor 

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

func (*StartServiceReply) GetError 

func (m *StartServiceReply) GetError() string

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 {
	Error string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*StopServiceReply) Descriptor 

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

func (*StopServiceReply) GetError 

func (m *StopServiceReply) GetError() string

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.