grpc

Aug 24, 2023

Changes in this version

+ const SuccessMessage

+ func DefaultSubscribeOn(stream ServerStream[P], subscriptions *Subscriptions[T, P], ...) error

+ func DefaultUnsubscribe(ctx context.Context, subscriptions *Subscriptions[T, P], subscriptionID uint64) (*pb.UnsubscribeResponse, error)

+ type Client struct

+ func NewClient(server string) *Client

+ func (client *Client) Close() error

+ func (client *Client) Connect(ctx context.Context, opts ...ConnectOption) error

+ func (client *Client) Connection() *grpc.ClientConn

+ func (client *Client) Name() string

+ func (client *Client) Reconnect() <-chan struct{}

+ func (client *Client) Start(ctx context.Context)

+ type ConnectOption func(opts *ConnectOptions)

+ func WaitServer() ConnectOption

+ func WithReconnectTimeout(duration time.Duration) ConnectOption

+ func WithReconnectionTime(duration time.Duration) ConnectOption

+ func WithTlsFromCert(domain string) ConnectOption

+ func WithUserAgent(s string) ConnectOption

+ type ConnectOptions struct

+ type Server struct

+ func NewServer(cfg *ServerConfig) (*Server, error)

+ func (*Server) Name() string

+ func (module *Server) Close() error

+ func (module *Server) Server() *gogrpc.Server

+ func (module *Server) Start(ctx context.Context)

+ type ServerConfig struct

+ Bind string

+ Log bool

+ Metrics bool

+ RPS int

+ type ServerStream interface

+ Send func(T) error

+ type Stream struct

+ func NewStream(stream grpc.ClientStream) *Stream[T]

+ func (s *Stream[T]) Close() error

+ func (s *Stream[T]) Context() context.Context

+ func (s *Stream[T]) Listen() <-chan *T

+ func (s *Stream[T]) Subscribe(ctx context.Context) (uint64, error)

+ func (s *Stream[T]) Unsubscribe(ctx context.Context, id uint64) error

+ type Subscription interface

+ Filter func(typ T) bool

+ Listen func() <-chan P

+ Send func(msg P)

+ type Subscriptions struct

+ func NewSubscriptions() *Subscriptions[T, P]

+ func (s *Subscriptions[T, P]) Add(id uint64, subscription Subscription[T, P])

+ func (s *Subscriptions[T, P]) Close() error

+ func (s *Subscriptions[T, P]) Get(id uint64) (Subscription[T, P], bool)

+ func (s *Subscriptions[T, P]) NotifyAll(typ T, converter func(uint64, T) P)

+ func (s *Subscriptions[T, P]) Remove(id uint64) error