grpc

Documentation

Index

• type Controller
• type Handler
  • func New(ctrl Controller) *Handler
  • func (h *Handler) DeleteMessage(ctx context.Context, req *api.DeleteMessageRequest) (*api.DeleteMessageResponse, error)
  • func (h *Handler) GetServers(ctx context.Context, _ *api.GetServersRequest) (*api.GetServersResponse, error)
  • func (h *Handler) ReadUserMessages(ctx context.Context, req *api.ReadUserMessagesRequest) (*api.ReadUserMessagesResponse, error)
  • func (h *Handler) SaveMessage(ctx context.Context, req *api.SaveMessageRequest) (*api.SaveMessageResponse, error)
  • func (h *Handler) UpdateMessage(ctx context.Context, req *api.UpdateMessageRequest) (*api.UpdateMessageResponse, error)

Types

type Controller

type Controller interface {
	SaveMessage(ctx context.Context, log *logger.Logger, params *model.SaveMessageParams) error
	UpdateMessage(ctx context.Context, log *logger.Logger, params *model.UpdateMessageParams) error
	DeleteMessage(ctx context.Context, log *logger.Logger, params *model.DeleteMessageParams) error
	ReadUserMessages(ctx context.Context, log *logger.Logger, params *model.ReadUserMessagesParams) (*model.ReadUserMessagesResult, error)
	GetServers(ctx context.Context, log *logger.Logger) ([]*api.Server, error)
}

type Handler

type Handler struct {
	api.UnimplementedMessagesServer
	// contains filtered or unexported fields
}

func New

func New(ctrl Controller) *Handler

func (*Handler) DeleteMessage

func (h *Handler) DeleteMessage(ctx context.Context, req *api.DeleteMessageRequest) (
	*api.DeleteMessageResponse, error,
)

func (*Handler) GetServers

func (h *Handler) GetServers(ctx context.Context, _ *api.GetServersRequest) (
	*api.GetServersResponse, error,
)

func (*Handler) ReadUserMessages

func (h *Handler) ReadUserMessages(ctx context.Context, req *api.ReadUserMessagesRequest) (
	*api.ReadUserMessagesResponse, error,
)

func (*Handler) SaveMessage

func (h *Handler) SaveMessage(ctx context.Context, req *api.SaveMessageRequest) (
	*api.SaveMessageResponse, error,
)

func (*Handler) UpdateMessage

func (h *Handler) UpdateMessage(ctx context.Context, req *api.UpdateMessageRequest) (
	*api.UpdateMessageResponse, error,
)