grpc

Documentation

Index

• func NewGRPCServer(params grpcServerParams) *fxgrpc.GRPCServer
• func NewGatewayHandler() *fxgrpc.HTTPGatewayHandler
• func NewLivenessGateway() *fxgrpc.LivenessGatewayHandler
• func RunHTTPGateway(lc fx.Lifecycle, s fx.Shutdowner, logger *zap.Logger, config *fxgrpc.Config, ...) error
• type Handler
  • func NewHandler(params handlerParams) *Handler
  • func (h *Handler) FollowChannel(ctx context.Context, _ *pbv1.CoreServiceFollowChannelRequest) (*pbv1.CoreServiceFollowChannelResponse, error)
  • func (h *Handler) GetChannelByID(ctx context.Context, _ *pbv1.CoreServiceGetChannelByIDRequest) (*pbv1.CoreServiceGetChannelByIDResponse, error)
  • func (h *Handler) GetChannelPublications(ctx context.Context, _ *pbv1.CoreServiceGetChannelPublicationsRequest) (*pbv1.CoreServiceGetChannelPublicationsResponse, error)
  • func (h *Handler) GetChannels(ctx context.Context, _ *pbv1.CoreServiceGetChannelsRequest) (*pbv1.CoreServiceGetChannelsResponse, error)
  • func (h *Handler) GetFeed(ctx context.Context, _ *pbv1.CoreServiceGetFeedRequest) (*pbv1.CoreServiceGetFeedResponse, error)
  • func (h *Handler) GetGroupByID(ctx context.Context, _ *pbv1.CoreServiceGetGroupByIDRequest) (*pbv1.CoreServiceGetGroupByIDResponse, error)
  • func (h *Handler) GetGroupPublications(ctx context.Context, _ *pbv1.CoreServiceGetGroupPublicationsRequest) (*pbv1.CoreServiceGetGroupPublicationsResponse, error)
  • func (h *Handler) GetGroups(ctx context.Context, _ *pbv1.CoreServiceGetGroupsRequest) (*pbv1.CoreServiceGetGroupsResponse, error)
  • func (h *Handler) GetPublicationByID(ctx context.Context, _ *pbv1.CoreServiceGetPublicationByIDRequest) (*pbv1.CoreServiceGetPublicationByIDResponse, error)
  • func (h *Handler) InviteToChannel(ctx context.Context, _ *pbv1.CoreServiceInviteToChannelRequest) (*pbv1.CoreServiceInviteToChannelResponse, error)
  • func (h *Handler) JoinGroup(ctx context.Context, _ *pbv1.CoreServiceJoinGroupRequest) (*pbv1.CoreServiceJoinGroupResponse, error)
  • func (h *Handler) ModifyChannel(ctx context.Context, _ *pbv1.CoreServiceModifyChannelRequest) (*pbv1.CoreServiceModifyChannelResponse, error)
  • func (h *Handler) ModifyGroup(ctx context.Context, _ *pbv1.CoreServiceModifyGroupRequest) (*pbv1.CoreServiceModifyGroupResponse, error)
  • func (h *Handler) ReactOnPublication(ctx context.Context, _ *pbv1.CoreServiceReactOnPublicationRequest) (*pbv1.CoreServiceReactOnPublicationResponse, error)
  • func (h *Handler) RegisterChannel(ctx context.Context, _ *pbv1.CoreServiceRegisterChannelRequest) (*pbv1.CoreServiceRegisterChannelResponse, error)
  • func (h *Handler) RegisterGroup(ctx context.Context, _ *pbv1.CoreServiceRegisterGroupRequest) (*pbv1.CoreServiceRegisterGroupResponse, error)
  • func (h *Handler) RequestFollowChannel(ctx context.Context, _ *pbv1.CoreServiceRequestFollowChannelRequest) (*pbv1.CoreServiceRequestFollowChannelResponse, error)
  • func (h *Handler) RequestJoinGroup(ctx context.Context, _ *pbv1.CoreServiceRequestJoinGroupRequest) (*pbv1.CoreServiceRequestJoinGroupResponse, error)

Functions

func NewGRPCServer

func NewGRPCServer(params grpcServerParams) *fxgrpc.GRPCServer

func NewGatewayHandler

func NewGatewayHandler() *fxgrpc.HTTPGatewayHandler

func NewLivenessGateway

func NewLivenessGateway() *fxgrpc.LivenessGatewayHandler

func RunHTTPGateway

func RunHTTPGateway(
	lc fx.Lifecycle,
	s fx.Shutdowner,
	logger *zap.Logger,
	config *fxgrpc.Config,
	g *fxgrpc.HTTPGatewayHandler,
) error

Types

type Handler

type Handler struct {
	pbv1.CoreServiceServer
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(params handlerParams) *Handler

func (*Handler) FollowChannel

func (h *Handler) FollowChannel(ctx context.Context, _ *pbv1.CoreServiceFollowChannelRequest) (*pbv1.CoreServiceFollowChannelResponse, error)

func (*Handler) GetChannelByID

func (h *Handler) GetChannelByID(ctx context.Context, _ *pbv1.CoreServiceGetChannelByIDRequest) (*pbv1.CoreServiceGetChannelByIDResponse, error)

func (*Handler) GetChannelPublications

func (h *Handler) GetChannelPublications(ctx context.Context, _ *pbv1.CoreServiceGetChannelPublicationsRequest) (*pbv1.CoreServiceGetChannelPublicationsResponse, error)

func (*Handler) GetChannels

func (h *Handler) GetChannels(ctx context.Context, _ *pbv1.CoreServiceGetChannelsRequest) (*pbv1.CoreServiceGetChannelsResponse, error)

func (*Handler) GetFeed

func (h *Handler) GetFeed(ctx context.Context, _ *pbv1.CoreServiceGetFeedRequest) (*pbv1.CoreServiceGetFeedResponse, error)

func (*Handler) GetGroupByID

func (h *Handler) GetGroupByID(ctx context.Context, _ *pbv1.CoreServiceGetGroupByIDRequest) (*pbv1.CoreServiceGetGroupByIDResponse, error)

func (*Handler) GetGroupPublications

func (h *Handler) GetGroupPublications(ctx context.Context, _ *pbv1.CoreServiceGetGroupPublicationsRequest) (*pbv1.CoreServiceGetGroupPublicationsResponse, error)

func (*Handler) GetGroups

func (h *Handler) GetGroups(ctx context.Context, _ *pbv1.CoreServiceGetGroupsRequest) (*pbv1.CoreServiceGetGroupsResponse, error)

func (*Handler) GetPublicationByID

func (h *Handler) GetPublicationByID(ctx context.Context, _ *pbv1.CoreServiceGetPublicationByIDRequest) (*pbv1.CoreServiceGetPublicationByIDResponse, error)

func (*Handler) InviteToChannel

func (h *Handler) InviteToChannel(ctx context.Context, _ *pbv1.CoreServiceInviteToChannelRequest) (*pbv1.CoreServiceInviteToChannelResponse, error)

func (*Handler) JoinGroup

func (h *Handler) JoinGroup(ctx context.Context, _ *pbv1.CoreServiceJoinGroupRequest) (*pbv1.CoreServiceJoinGroupResponse, error)

func (*Handler) ModifyChannel

func (h *Handler) ModifyChannel(ctx context.Context, _ *pbv1.CoreServiceModifyChannelRequest) (*pbv1.CoreServiceModifyChannelResponse, error)

func (*Handler) ModifyGroup

func (h *Handler) ModifyGroup(ctx context.Context, _ *pbv1.CoreServiceModifyGroupRequest) (*pbv1.CoreServiceModifyGroupResponse, error)

func (*Handler) ReactOnPublication

func (h *Handler) ReactOnPublication(ctx context.Context, _ *pbv1.CoreServiceReactOnPublicationRequest) (*pbv1.CoreServiceReactOnPublicationResponse, error)

func (*Handler) RegisterChannel

func (h *Handler) RegisterChannel(ctx context.Context, _ *pbv1.CoreServiceRegisterChannelRequest) (*pbv1.CoreServiceRegisterChannelResponse, error)

func (*Handler) RegisterGroup

func (h *Handler) RegisterGroup(ctx context.Context, _ *pbv1.CoreServiceRegisterGroupRequest) (*pbv1.CoreServiceRegisterGroupResponse, error)

func (*Handler) RequestFollowChannel

func (h *Handler) RequestFollowChannel(ctx context.Context, _ *pbv1.CoreServiceRequestFollowChannelRequest) (*pbv1.CoreServiceRequestFollowChannelResponse, error)

func (*Handler) RequestJoinGroup

func (h *Handler) RequestJoinGroup(ctx context.Context, _ *pbv1.CoreServiceRequestJoinGroupRequest) (*pbv1.CoreServiceRequestJoinGroupResponse, error)