server

Documentation

Index

• type MessageClientServer
  • func NewMessageClientServer(svcCtx *svc.ServiceContext) *MessageClientServer
  • func (s *MessageClientServer) Pull(ctx context.Context, in *msg.PullRequest) (*msg.PullResponse, error)
  • func (s *MessageClientServer) Upload(ctx context.Context, in *msg.UploadRequest) (*msg.UploadResponse, error)

Types

type MessageClientServer

type MessageClientServer struct {
	msg.UnimplementedMessageClientServer
	// contains filtered or unexported fields
}

func NewMessageClientServer

func NewMessageClientServer(svcCtx *svc.ServiceContext) *MessageClientServer

func (*MessageClientServer) Pull

func (s *MessageClientServer) Pull(ctx context.Context, in *msg.PullRequest) (*msg.PullResponse, error)

func (*MessageClientServer) Upload

func (s *MessageClientServer) Upload(ctx context.Context, in *msg.UploadRequest) (*msg.UploadResponse, error)