unigrpc

Documentation

Index

• func RegisterService(server *grpc.Server, service unistream.CentrifugoUniStreamServer) error
• type Config
• type RawCodec
  • func (c *RawCodec) Marshal(v any) ([]byte, error)
  • func (c *RawCodec) String() string
  • func (c *RawCodec) Unmarshal(data []byte, v any) error
• type Service
  • func NewService(n *centrifuge.Node, c Config) *Service
  • func (s *Service) Consume(req *unistream.ConnectRequest, ...) error

Functions

func RegisterService

func RegisterService(server *grpc.Server, service unistream.CentrifugoUniStreamServer) error

RegisterService ...

Types

type Config

type Config struct{}

type RawCodec

type RawCodec struct{}

RawCodec allows sending Protobuf encoded Pushes without additional wrapping and marshaling.

func (*RawCodec) Marshal

func (c *RawCodec) Marshal(v any) ([]byte, error)

func (*RawCodec) String

func (c *RawCodec) String() string

func (*RawCodec) Unmarshal

func (c *RawCodec) Unmarshal(data []byte, v any) error

type Service

type Service struct {
	unistream.UnimplementedCentrifugoUniStreamServer
	// contains filtered or unexported fields
}

Service can work with client GRPC connections.

func NewService

func NewService(n *centrifuge.Node, c Config) *Service

NewService creates new Service.

func (*Service) Consume

func (s *Service) Consume(req *unistream.ConnectRequest, stream unistream.CentrifugoUniStream_ConsumeServer) error

Consume is a unidirectional server->client stream with real-time data.