Documentation ¶
Index ¶
- func Connect(serviceName string, serverAddr string, regParams *pb.RegistrationParams) (*grpc.ClientConn, error)
- func DefaultRegParams(sc *SC) (*pb.RegistrationParams, error)
- type Logger
- type Response
- type ResponseJS
- type SC
- func (sc *SC) ProcessSubJSMsgs(ctx context.Context, topic, workQueue string, chanSize uint32, ...) error
- func (sc *SC) ProcessSubMsgs(ctx context.Context, topic string, chanSize uint32, ...) error
- func (sc *SC) Pub(ctx context.Context, topic string, data []byte, rb *pb.RetryBehavior) error
- func (sc *SC) PubJS(ctx context.Context, topic string, workQueue string, data []byte) error
- func (sc *SC) Recv(ctx context.Context, topic string) <-chan *Response
- func (sc *SC) RecvJS(ctx context.Context, topic string, workQueue string) <-chan *ResponseJS
- func (sc *SC) Register(serviceName string, regParams *pb.RegistrationParams) error
- func (sc *SC) Sub(ctx context.Context, topic string, chanSize uint32) error
- func (sc *SC) SubJS(ctx context.Context, topic string, workQueue string, chanSize uint32) error
- func (sc *SC) Unsub(ctx context.Context, topic string) error
- func (sc *SC) UnsubJS(ctx context.Context, topic string, workQueue string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect(serviceName string, serverAddr string, regParams *pb.RegistrationParams) (*grpc.ClientConn, error)
func DefaultRegParams ¶
func DefaultRegParams(sc *SC) (*pb.RegistrationParams, error)
Types ¶
type ResponseJS ¶
type ResponseJS struct {
// contains filtered or unexported fields
}
type SC ¶
type SC struct { Logger *Logger // contains filtered or unexported fields }
func InitSidecar ¶
func InitSidecar(serviceName string, regParams *pb.RegistrationParams) (*SC, error)
func (*SC) ProcessSubJSMsgs ¶
func (*SC) ProcessSubMsgs ¶
func (*SC) Register ¶
func (sc *SC) Register(serviceName string, regParams *pb.RegistrationParams) error
Click to show internal directories.
Click to hide internal directories.