instrumentation

package

v0.9.13 Latest Latest Go to latest Published: May 20, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

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, version int) (le *schemalog.LogEntry, err error)

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

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