streamingretry

package

v1.0.0-beta.227 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

Index ¶

type Config
- func (c Config) Validate() error
type Connector
- func New(config Config) (*Connector, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	DownstreamConnector streaming.Connector
	Logger              *slog.Logger
	RetryWaitDuration   time.Duration
	MaxTries            int
}

func (Config) Validate ¶

func (c Config) Validate() error

type Connector ¶

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

func New ¶

func New(config Config) (*Connector, error)

func (*Connector) BatchInsert ¶

func (c *Connector) BatchInsert(ctx context.Context, events []streaming.RawEvent) error

func (*Connector) CountEvents ¶

func (c *Connector) CountEvents(ctx context.Context, namespace string, params streaming.CountEventsParams) ([]streaming.CountEventRow, error)

func (*Connector) CreateNamespace ¶

func (c *Connector) CreateNamespace(ctx context.Context, namespace string) error

func (*Connector) DeleteNamespace ¶

func (c *Connector) DeleteNamespace(ctx context.Context, namespace string) error

func (*Connector) ListEvents ¶

func (c *Connector) ListEvents(ctx context.Context, namespace string, params streaming.ListEventsParams) ([]streaming.RawEvent, error)

func (*Connector) ListEventsV2 ¶

func (c *Connector) ListEventsV2(ctx context.Context, params streaming.ListEventsV2Params) ([]streaming.RawEvent, error)

func (*Connector) ListGroupByValues ¶

func (c *Connector) ListGroupByValues(ctx context.Context, params streaming.ListGroupByValuesParams) ([]string, error)

func (*Connector) ListSubjects ¶

func (c *Connector) ListSubjects(ctx context.Context, params streaming.ListSubjectsParams) ([]string, error)

func (*Connector) QueryMeter ¶

func (c *Connector) QueryMeter(ctx context.Context, namespace string, m meter.Meter, params streaming.QueryParams) ([]meter.MeterQueryRow, error)

func (*Connector) ValidateJSONPath ¶

func (c *Connector) ValidateJSONPath(ctx context.Context, jsonPath string) (bool, error)

Source Files ¶

View all Source files

retry.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL