services

Documentation

Overview

Package services is a generated protocol buffer package.

It is generated from these files:

github.com/GoCollaborate/src/collaborator/services/rpc_services.proto

It has these top-level messages:

Index

• func Decode(payload *TaskPayload) (maps *map[int]*Task, err error)
• func Encode(maps *map[int]*Task) (payload *TaskPayload, err error)
• func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)
• type RPCServiceClient
  • func NewRPCServiceClient(cc *grpc.ClientConn) RPCServiceClient
• type RPCServiceServer

Functions

func Decode

func Decode(payload *TaskPayload) (maps *map[int]*Task, err error)

func Encode

func Encode(maps *map[int]*Task) (payload *TaskPayload, err error)

func RegisterRPCServiceServer

func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)

Types

type RPCServiceClient

type RPCServiceClient interface {
	Distribute(ctx context.Context, in *task.TaskPayload, opts ...grpc.CallOption) (*task.TaskPayload, error)
	Exchange(ctx context.Context, in *message.CardMessage, opts ...grpc.CallOption) (*message.CardMessage, error)
}

func NewRPCServiceClient

func NewRPCServiceClient(cc *grpc.ClientConn) RPCServiceClient

type RPCServiceServer

type RPCServiceServer interface {
	Distribute(context.Context, *task.TaskPayload) (*task.TaskPayload, error)
	Exchange(context.Context, *message.CardMessage) (*message.CardMessage, error)
}