events

Documentation

Index

• func NewService(events *events.Exchange) api.EventsServer
• type Service
  • func (s *Service) Forward(ctx context.Context, r *api.ForwardRequest) (*empty.Empty, error)
  • func (s *Service) Publish(ctx context.Context, r *api.PublishRequest) (*empty.Empty, error)
  • func (s *Service) Register(server *grpc.Server) error
  • func (s *Service) Subscribe(req *api.SubscribeRequest, srv api.Events_SubscribeServer) error

Functions

func NewService

func NewService(events *events.Exchange) api.EventsServer

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

func (*Service) Forward

func (s *Service) Forward(ctx context.Context, r *api.ForwardRequest) (*empty.Empty, error)

func (*Service) Publish

func (s *Service) Publish(ctx context.Context, r *api.PublishRequest) (*empty.Empty, error)

func (*Service) Register

func (s *Service) Register(server *grpc.Server) error

func (*Service) Subscribe

func (s *Service) Subscribe(req *api.SubscribeRequest, srv api.Events_SubscribeServer) error