unigrpc

Documentation

Index

• func RegisterService(server *grpc.Server, service unistream.CentrifugoUniStreamServer) error
• type Config
• type RawCodec
  • func (c *RawCodec) Marshal(v interface{}) ([]byte, error)
  • func (c *RawCodec) String() string
  • func (c *RawCodec) Unmarshal(data []byte, v interface{}) 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 {
	// ProtocolVersion used by default. If not set then we use centrifuge.ProtocolVersion1.
	ProtocolVersion centrifuge.ProtocolVersion
}

type RawCodec

type RawCodec struct{}

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

func (*RawCodec) Marshal

func (c *RawCodec) Marshal(v interface{}) ([]byte, error)

func (*RawCodec) String

func (c *RawCodec) String() string

func (*RawCodec) Unmarshal

func (c *RawCodec) Unmarshal(data []byte, v interface{}) 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.