instrumentation

Documentation

Index

• func NewStore(inner schemalog.Store, instrumentation *otel.Instrumentation) schemalog.Store
• type Store
  • func (s *Store) Ack(ctx context.Context, le *schemalog.LogEntry) (err error)
  • func (s *Store) Close() error
  • func (s *Store) Fetch(ctx context.Context, schemaName string, acked bool) (le *schemalog.LogEntry, err error)

Functions

func NewStore

func NewStore(inner schemalog.Store, instrumentation *otel.Instrumentation) schemalog.Store

Types

type Store

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

func (*Store) Ack

func (s *Store) Ack(ctx context.Context, le *schemalog.LogEntry) (err error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) Fetch

func (s *Store) Fetch(ctx context.Context, schemaName string, acked bool) (le *schemalog.LogEntry, err error)