stream

Documentation

Index

• Variables
• func InterceptorLogger(l *log.Logger) logging.Logger
• type StreamClient
  • func NewStreamClient(pubaddr, subaddr string) (StreamClient, error)

Variables

var (
	ErrUnknown = errors.New("unknown error")
)

Functions

func InterceptorLogger

func InterceptorLogger(l *log.Logger) logging.Logger

Types

type StreamClient

type StreamClient interface {
	Close()
	PublishMessage(chatId, userId, content string) error
	GetSubscribeStream() pb.TransistorService_SubscribeClient
}

func NewStreamClient

func NewStreamClient(pubaddr, subaddr string) (StreamClient, error)