ystore

package

v0.0.0-...-99c3f21 Latest Latest Go to latest Published: Mar 3, 2025 License: MIT Imports: 10 Imported by: 0

Details

ystore wraps a proto.Message in a concurrency safe accessor.

This section is empty.

This section is empty.

This section is empty.

type Store[T proto.Message] struct {
	// contains filtered or unexported fields
}

func New[T any, P storer[T]](ctx context.Context, bkt *blob.Bucket, key string, init func() P) (*Store[P], error)

func (s *Store[T]) Do(ctx context.Context, f func(T))

func (s *Store[T]) RDo(ctx context.Context, f func(T))

func (s *Store[T]) Sync(ctx context.Context, force bool)