topic

Documentation

Index

• func RegisterGRPCServer(s grpc.ServiceRegistrar, srv desc.TopicServiceServer)
• type Implementation
  • func NewTopicService() *Implementation
  • func (i *Implementation) CreateTopic(_ context.Context, request *desc.CreateTopicRequest) (*desc.CreateTopicResponse, error)
  • func (i *Implementation) DeleteTopicById(_ context.Context, _ *desc.DeleteTopicByIdRequest) (*desc.DeleteTopicByIdResponse, error)
  • func (i *Implementation) GetByCollection(_ context.Context, request *desc.GetByCollectionRequest) (*desc.GetByCollectionResponse, error)
  • func (i *Implementation) GetTopicById(_ context.Context, request *desc.GetTopicByIdRequest) (*desc.GetTopicByIdResponse, error)

Functions

func RegisterGRPCServer

func RegisterGRPCServer(s grpc.ServiceRegistrar, srv desc.TopicServiceServer)

Types

type Implementation

type Implementation struct {
	desc.UnimplementedTopicServiceServer
}

func NewTopicService

func NewTopicService() *Implementation

func (*Implementation) CreateTopic

func (i *Implementation) CreateTopic(_ context.Context, request *desc.CreateTopicRequest) (*desc.CreateTopicResponse, error)

func (*Implementation) DeleteTopicById

func (i *Implementation) DeleteTopicById(_ context.Context, _ *desc.DeleteTopicByIdRequest) (*desc.DeleteTopicByIdResponse, error)

func (*Implementation) GetByCollection

func (i *Implementation) GetByCollection(_ context.Context, request *desc.GetByCollectionRequest) (*desc.GetByCollectionResponse, error)

func (*Implementation) GetTopicById

func (i *Implementation) GetTopicById(_ context.Context, request *desc.GetTopicByIdRequest) (*desc.GetTopicByIdResponse, error)