service

Documentation

Overview

Package service is a generated protocol buffer package.

It is generated from these files:

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

It has these top-level messages:

EmitEventRequest
ListenTaskRequest
SubmitResultRequest
EmitEventReply
TaskData
SubmitResultReply

Index

• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type EmitEventReply
  • func (*EmitEventReply) Descriptor() ([]byte, []int)
  • func (*EmitEventReply) ProtoMessage()
  • func (m *EmitEventReply) Reset()
  • func (m *EmitEventReply) String() string
• type EmitEventRequest
  • func (*EmitEventRequest) Descriptor() ([]byte, []int)
  • func (m *EmitEventRequest) GetEventData() string
  • func (m *EmitEventRequest) GetEventKey() string
  • func (m *EmitEventRequest) GetToken() string
  • func (*EmitEventRequest) ProtoMessage()
  • func (m *EmitEventRequest) Reset()
  • func (m *EmitEventRequest) String() string
• type ListenTaskRequest
  • func (*ListenTaskRequest) Descriptor() ([]byte, []int)
  • func (m *ListenTaskRequest) GetToken() string
  • func (*ListenTaskRequest) ProtoMessage()
  • func (m *ListenTaskRequest) Reset()
  • func (m *ListenTaskRequest) String() string
• type Server
  • func (s *Server) EmitEvent(context context.Context, request *EmitEventRequest) (reply *EmitEventReply, err error)
  • func (s *Server) ListenTask(request *ListenTaskRequest, stream Service_ListenTaskServer) (err error)
  • func (s *Server) SubmitResult(context context.Context, request *SubmitResultRequest) (reply *SubmitResultReply, err error)
• type ServiceClient
  • func NewServiceClient(cc *grpc.ClientConn) ServiceClient
• type ServiceServer
• type Service_ListenTaskClient
• type Service_ListenTaskServer
• type SubmitResultReply
  • func (*SubmitResultReply) Descriptor() ([]byte, []int)
  • func (*SubmitResultReply) ProtoMessage()
  • func (m *SubmitResultReply) Reset()
  • func (m *SubmitResultReply) String() string
• type SubmitResultRequest
  • func (*SubmitResultRequest) Descriptor() ([]byte, []int)
  • func (m *SubmitResultRequest) GetExecutionID() string
  • func (m *SubmitResultRequest) GetOutputData() string
  • func (m *SubmitResultRequest) GetOutputKey() string
  • func (*SubmitResultRequest) ProtoMessage()
  • func (m *SubmitResultRequest) Reset()
  • func (m *SubmitResultRequest) String() string
• type TaskData
  • func (*TaskData) Descriptor() ([]byte, []int)
  • func (m *TaskData) GetExecutionID() string
  • func (m *TaskData) GetInputData() string
  • func (m *TaskData) GetTaskKey() string
  • func (*TaskData) ProtoMessage()
  • func (m *TaskData) Reset()
  • func (m *TaskData) String() string

Functions

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type EmitEventReply

type EmitEventReply struct {
}

func (*EmitEventReply) Descriptor

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

func (*EmitEventReply) ProtoMessage

func (*EmitEventReply) ProtoMessage()

func (*EmitEventReply) Reset

func (m *EmitEventReply) Reset()

func (*EmitEventReply) String

func (m *EmitEventReply) String() string

type EmitEventRequest

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

func (*EmitEventRequest) Descriptor

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

func (*EmitEventRequest) GetEventData

func (m *EmitEventRequest) GetEventData() string

func (*EmitEventRequest) GetEventKey

func (m *EmitEventRequest) GetEventKey() string

func (*EmitEventRequest) GetToken

func (m *EmitEventRequest) GetToken() string

func (*EmitEventRequest) ProtoMessage

func (*EmitEventRequest) ProtoMessage()

func (*EmitEventRequest) Reset

func (m *EmitEventRequest) Reset()

func (*EmitEventRequest) String

func (m *EmitEventRequest) String() string

type ListenTaskRequest

type ListenTaskRequest struct {
	Token string `protobuf:"bytes,1,opt,name=token" json:"token,omitempty"`
}

func (*ListenTaskRequest) Descriptor

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

func (*ListenTaskRequest) GetToken

func (m *ListenTaskRequest) GetToken() string

func (*ListenTaskRequest) ProtoMessage

func (*ListenTaskRequest) ProtoMessage()

func (*ListenTaskRequest) Reset

func (m *ListenTaskRequest) Reset()

func (*ListenTaskRequest) String

func (m *ListenTaskRequest) String() string

type Server

type Server struct{}

Server is the struct to bind all the api functions

func (*Server) EmitEvent

func (s *Server) EmitEvent(context context.Context, request *EmitEventRequest) (reply *EmitEventReply, err error)

EmitEvent permits to send and event to anyone who subscribed to it

func (*Server) ListenTask

func (s *Server) ListenTask(request *ListenTaskRequest, stream Service_ListenTaskServer) (err error)

ListenTask create a stream that will send data for every task to execute

func (*Server) SubmitResult

func (s *Server) SubmitResult(context context.Context, request *SubmitResultRequest) (reply *SubmitResultReply, err error)

SubmitResult of an execution

type ServiceClient

type ServiceClient interface {
	EmitEvent(ctx context.Context, in *EmitEventRequest, opts ...grpc.CallOption) (*EmitEventReply, error)
	ListenTask(ctx context.Context, in *ListenTaskRequest, opts ...grpc.CallOption) (Service_ListenTaskClient, error)
	SubmitResult(ctx context.Context, in *SubmitResultRequest, opts ...grpc.CallOption) (*SubmitResultReply, error)
}

func NewServiceClient

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceServer

type ServiceServer interface {
	EmitEvent(context.Context, *EmitEventRequest) (*EmitEventReply, error)
	ListenTask(*ListenTaskRequest, Service_ListenTaskServer) error
	SubmitResult(context.Context, *SubmitResultRequest) (*SubmitResultReply, error)
}

type Service_ListenTaskClient

type Service_ListenTaskClient interface {
	Recv() (*TaskData, error)
	grpc.ClientStream
}

type Service_ListenTaskServer

type Service_ListenTaskServer interface {
	Send(*TaskData) error
	grpc.ServerStream
}

type SubmitResultReply

type SubmitResultReply struct {
}

func (*SubmitResultReply) Descriptor

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

func (*SubmitResultReply) ProtoMessage

func (*SubmitResultReply) ProtoMessage()

func (*SubmitResultReply) Reset

func (m *SubmitResultReply) Reset()

func (*SubmitResultReply) String

func (m *SubmitResultReply) String() string

type SubmitResultRequest

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

func (*SubmitResultRequest) Descriptor

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

func (*SubmitResultRequest) GetExecutionID

func (m *SubmitResultRequest) GetExecutionID() string

func (*SubmitResultRequest) GetOutputData

func (m *SubmitResultRequest) GetOutputData() string

func (*SubmitResultRequest) GetOutputKey

func (m *SubmitResultRequest) GetOutputKey() string

func (*SubmitResultRequest) ProtoMessage

func (*SubmitResultRequest) ProtoMessage()

func (*SubmitResultRequest) Reset

func (m *SubmitResultRequest) Reset()

func (*SubmitResultRequest) String

func (m *SubmitResultRequest) String() string

type TaskData

type TaskData struct {
	ExecutionID string `protobuf:"bytes,1,opt,name=executionID" json:"executionID,omitempty"`
	TaskKey     string `protobuf:"bytes,2,opt,name=taskKey" json:"taskKey,omitempty"`
	InputData   string `protobuf:"bytes,3,opt,name=inputData" json:"inputData,omitempty"`
}

func (*TaskData) Descriptor

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

func (*TaskData) GetExecutionID

func (m *TaskData) GetExecutionID() string

func (*TaskData) GetInputData

func (m *TaskData) GetInputData() string

func (*TaskData) GetTaskKey

func (m *TaskData) GetTaskKey() string

func (*TaskData) ProtoMessage

func (*TaskData) ProtoMessage()

func (*TaskData) Reset

func (m *TaskData) Reset()

func (*TaskData) String

func (m *TaskData) String() string