client

Jun 7, 2026

Changes in this version

type BaseAuditClient

+ func (bac *BaseAuditClient[D]) GetName() string

+ func (bac *BaseAuditClient[D]) IsRunning() bool

Apr 11, 2026

Changes in this version

+ type AuditAction func(ctx context.Context, workerIndex int, data D, token string) error

+ type AuditClient interface

+ Audit func(data A) error

+ Start func(ctx context.Context) error

+ Stop func(stopTimeout time.Duration) error

+ TotalLost func() int32

+ type AuthAuditClient interface

+ type BaseAuditClient struct

+ func NewBaseAuditClient[D any](name string, conf *worker.BasePoolConfig, auditAction AuditAction[D], ...) *BaseAuditClient[D]

+ func (bac *BaseAuditClient[D]) Audit(data D) error

+ func (bac *BaseAuditClient[D]) GetConfig() *worker.BasePoolConfig

+ func (bac *BaseAuditClient[D]) GetLogger() logger.Logger

+ func (bac *BaseAuditClient[D]) IncLostCounter()

+ func (bac *BaseAuditClient[D]) Start(ctx context.Context) error

+ func (bac *BaseAuditClient[D]) Stop(stopTimeout time.Duration) error

+ func (bac *BaseAuditClient[D]) TotalLost() int32

+ type DataAuditClient interface