v1

package

v0.0.0-...-b690631 Latest Latest Go to latest Published: Nov 15, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

View Source

const (
	MaxEventCount = 1024
	DefaultTTL    = 60 * 24 * time.Hour
)

This section is empty.

func New(cfg Configuration) (svc.Handler, error)

type Configuration struct {
	integrationsShared.Endpoint
	integrationsShared.Database

	Async ConfigurationAsync
}

func NewConfiguration() Configuration

func (c Configuration) Validate() error

func (c Configuration) With(mods ...util.ModR[Configuration]) Configuration

type ConfigurationAsync struct {
	Enabled bool
	Size    int
	Retry   ConfigurationRetry
}

func (c ConfigurationAsync) Validate() error

type ConfigurationRetry struct {
	Timeout time.Duration
	Delay   time.Duration
}

func (c ConfigurationRetry) Validate() error

type RemoteStore[IN proto.Message] interface {
	Init(ctx context.Context) error

	Emit(ctx context.Context, events ...IN) error
}

func NewArangoRemoteStore[IN proto.Message](client cache.Object[arangodb.Collection]) RemoteStore[IN]

func WithAsync[IN proto.Message, H RemoteStore[IN]](in H, size int, timeout time.Duration, delay time.Duration) RemoteStore[IN]

Path	Synopsis
definition