egress

type Batch struct {
	BatchID           string
	TransportBatchRaw []byte
	InsertTime        time.Time
}

type EmbeddedNotifier struct {
	Forwarder Forwarder
}

type Forwarder struct {
	// contains filtered or unexported fields
}

type ForwarderConfig struct {
	Storage                   Storage        // A storage a Forwarder instance uses to fetch message batches (queued-traffic).
	Writer                    streams.Writer // A writer implementation a Forwarder instance uses to publish message batches to.
	Codec                     codec.Codec    // Codec used by the egress writer to store traffic messages.
	Logger                    *log.Logger    // Logger to write information to.
	TableName                 string         // Name of the egress table.
	ForwardJobTimeout         time.Duration  // Maximum time duration to wait a forward job to finish.
	ForwardJobTotalRetries    int            // Maximum count a forward job will be retried.
	ForwardJobRetryBackoff    time.Duration  // Initial time duration between each retry process.
	ForwardJobRetryBackoffMax time.Duration  // Maximum time duration between each retry process.
}

type NetworkNotifier struct {
	// contains filtered or unexported fields
}

type NoopStorage struct {
	WantGetBatch    Batch
	WantGetBatchErr error
	WantCommitErr   error
}

type Notifier interface {
	// NotifyAgent triggers egress proxy agent to forward traffic buffer (batch) into a stream.
	NotifyAgent(batchID string) error
}

type Storage interface {
	// GetBatch retrieves specified batch.
	GetBatch(ctx context.Context, batchID string) (Batch, error)
	// Commit Evicts specified batch.
	Commit(ctx context.Context, batchID string) error
}

type StorageConfig struct {
	TableName string
}

type StorageOption interface {
	Apply(*StorageConfig)
}