inmem

Documentation

Index

• type Storage
  • func New(ctx context.Context) (*Storage, error)
  • func (ts *Storage) List(ctx context.Context, msg proto.Message) ([]string, error)
  • func (ts *Storage) Load(ctx context.Context, msg nodeenrollment.MessageWithId) error
  • func (ts *Storage) Remove(ctx context.Context, msg nodeenrollment.MessageWithId) error
  • func (ts *Storage) Store(ctx context.Context, msg nodeenrollment.MessageWithId) error

Types

type Storage

type Storage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

InmemBackend is an in-memory only physical backend. It is useful for testing and development situations where the data is not expected to be durable.

func New

func New(ctx context.Context) (*Storage, error)

New creates a new object that implements the Storage interface in memory. It is thread-safe.

func (*Storage) List

func (ts *Storage) List(ctx context.Context, msg proto.Message) ([]string, error)

List implements the Storage interface

func (*Storage) Load

func (ts *Storage) Load(ctx context.Context, msg nodeenrollment.MessageWithId) error

Load implements the Storage interface

func (*Storage) Remove

func (ts *Storage) Remove(ctx context.Context, msg nodeenrollment.MessageWithId) error

Remove implements the Storage interface

func (*Storage) Store

func (ts *Storage) Store(ctx context.Context, msg nodeenrollment.MessageWithId) error

Store implements the Storage interface.

If the message already exists, it is overwritten.