storage

Documentation

Index

• type Readable
• type Saveable
• type Store
  • func New(name string) (Store, error)
  • func (s *Store) Close()
  • func (s *Store) Persist(ctx context.Context, e Saveable) error
  • func (s *Store) Read(ctx context.Context, key string, v Readable) (Readable, error)
  • func (s *Store) ReadMany(ctx context.Context, index string, helper Readable) ([]Readable, error)

Types

type Readable

type Readable interface {
	Unmarshal([]byte) (Readable, error)
}

type Saveable

type Saveable interface {
	GetKey() string
	GetIndices() []string
	Marshal() ([]byte, error)
}

type Store

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

Store is simple access layer to a dapr store

func New

func New(name string) (Store, error)

func (*Store) Close

func (s *Store) Close()

func (*Store) Persist

func (s *Store) Persist(ctx context.Context, e Saveable) error

func (*Store) Read

func (s *Store) Read(ctx context.Context, key string, v Readable) (Readable, error)

func (*Store) ReadMany

func (s *Store) ReadMany(ctx context.Context, index string, helper Readable) ([]Readable, error)