store

Documentation

Index

• func NewClient(s types.QueueStorer) *sClient
• type Client
• type StoreClient
• type Storer

Functions

func NewClient

func NewClient(s types.QueueStorer) *sClient

Types

type Client

type Client interface {
	Add(context.Context, string, []byte) error
	Process(context.Context, uint64, types.QueueMessage) error
}

type StoreClient

type StoreClient interface {
	Client
	Storer
}

type Storer

type Storer interface {
	SetStore(types.QueueStorer)
	GetStore() types.QueueStorer
}