grpc

Documentation

Overview

Package grpc contains an implementation of the EventsServer, which is used to stream all events published for a set of identifiers.

Index

• type EventsServer
  • func NewEventsServer(ctx context.Context, pubsub events.PubSub) *EventsServer
  • func (srv *EventsServer) RegisterHandlers(s *grpc_runtime.ServeMux, conn *grpc.ClientConn)
  • func (srv *EventsServer) RegisterServices(s *grpc.Server)
  • func (srv *EventsServer) Roles() []ttnpb.ClusterRole
  • func (srv *EventsServer) Stream(req *ttnpb.StreamEventsRequest, stream ttnpb.Events_StreamServer) error

Types

type EventsServer

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

EventsServer streams events from a PubSub over gRPC.

func NewEventsServer

func NewEventsServer(ctx context.Context, pubsub events.PubSub) *EventsServer

NewEventsServer returns a new EventsServer on the given PubSub.

func (*EventsServer) RegisterHandlers

func (srv *EventsServer) RegisterHandlers(s *grpc_runtime.ServeMux, conn *grpc.ClientConn)

RegisterHandlers implements rpcserver.Registerer.

func (*EventsServer) RegisterServices

func (srv *EventsServer) RegisterServices(s *grpc.Server)

RegisterServices implements rpcserver.Registerer.

func (*EventsServer) Roles

func (srv *EventsServer) Roles() []ttnpb.ClusterRole

Roles implements rpcserver.Registerer.

func (*EventsServer) Stream

func (srv *EventsServer) Stream(req *ttnpb.StreamEventsRequest, stream ttnpb.Events_StreamServer) error

Stream implements the EventsServer interface.