modshared

May 15, 2024

Changes in this version

+ const NoAgentID

+ func APIToErrReporter(api API) errz.ErrReporter

+ func InjectRPCAPI(ctx context.Context, rpcAPI RPCAPI) context.Context

+ func StreamRPCAPIInterceptor(factory RPCAPIFactory) grpc.StreamServerInterceptor

+ func UnaryRPCAPIInterceptor(factory RPCAPIFactory) grpc.UnaryServerInterceptor

+ type API interface

+ HandleProcessingError func(ctx context.Context, log *zap.Logger, agentID int64, msg string, err error)

+ type Factory interface

+ Name func() string

+ StartStopPhase func() ModuleStartStopPhase

+ type ModuleStartStopPhase byte

+ const ModuleStartAfterServers

+ const ModuleStartBeforeServers

+ type RPCAPI interface

+ HandleIOError func(log *zap.Logger, msg string, err error) error

+ HandleProcessingError func(log *zap.Logger, agentID int64, msg string, err error)

+ Log func() *zap.Logger

+ PollWithBackoff func(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error

+ func RPCAPIFromContext(ctx context.Context) RPCAPI

+ type RPCAPIFactory func(ctx context.Context, method string) RPCAPI

+ type RPCAPIStub struct

+ Logger *zap.Logger

+ StreamCtx context.Context

+ func (a *RPCAPIStub) Log() *zap.Logger

+ func (a *RPCAPIStub) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error