retrier

package
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HandlerRetrier 

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

func NewHandler 

func NewHandler(h replication.Handler, backoffConfig backoff.Config, opts ...Option) *HandlerRetrier

func (*HandlerRetrier) Close 

func (h *HandlerRetrier) Close() error

func (*HandlerRetrier) GetCurrentLSN 

func (h *HandlerRetrier) GetCurrentLSN(ctx context.Context) (replication.LSN, error)

func (*HandlerRetrier) GetLSNParser 

func (h *HandlerRetrier) GetLSNParser() replication.LSNParser

func (*HandlerRetrier) GetReplicationLag 

func (h *HandlerRetrier) GetReplicationLag(ctx context.Context) (int64, error)

func (*HandlerRetrier) ReceiveMessage 

func (h *HandlerRetrier) ReceiveMessage(ctx context.Context) (*replication.Message, error)

func (*HandlerRetrier) ResetConnection 

func (h *HandlerRetrier) ResetConnection(ctx context.Context) error

func (*HandlerRetrier) StartReplication 

func (h *HandlerRetrier) StartReplication(ctx context.Context) error

func (*HandlerRetrier) StartReplicationFromLSN 

func (h *HandlerRetrier) StartReplicationFromLSN(ctx context.Context, lsn replication.LSN) error

func (*HandlerRetrier) SyncLSN 

func (h *HandlerRetrier) SyncLSN(ctx context.Context, lsn replication.LSN) error

type Option 

type Option func(*HandlerRetrier)

func WithLogger 

func WithLogger(logger loglib.Logger) Option

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.