cfkv

Documentation

Index

• func NewCFWorkersKV(logger logger.Logger) state.Store
• type CFWorkersKV
  • func (q *CFWorkersKV) Close() error
  • func (q *CFWorkersKV) Delete(parentCtx context.Context, stateReq *state.DeleteRequest) error
  • func (q CFWorkersKV) Features() []state.Feature
  • func (q *CFWorkersKV) Get(parentCtx context.Context, stateReq *state.GetRequest) (*state.GetResponse, error)
  • func (q *CFWorkersKV) GetComponentMetadata() map[string]string
  • func (q *CFWorkersKV) Init(metadata state.Metadata) error
  • func (q *CFWorkersKV) Set(parentCtx context.Context, stateReq *state.SetRequest) error

Functions

func NewCFWorkersKV

func NewCFWorkersKV(logger logger.Logger) state.Store

NewCFWorkersKV returns a new CFWorkersKV.

Types

type CFWorkersKV

type CFWorkersKV struct {
	*workers.Base
	state.DefaultBulkStore
	// contains filtered or unexported fields
}

CFWorkersKV is a state store backed by Cloudflare Workers KV.

func (*CFWorkersKV) Close

func (q *CFWorkersKV) Close() error

Close the component

func (*CFWorkersKV) Delete

func (q *CFWorkersKV) Delete(parentCtx context.Context, stateReq *state.DeleteRequest) error

func (CFWorkersKV) Features

func (q CFWorkersKV) Features() []state.Feature

Features returns the features supported by this state store.

func (*CFWorkersKV) Get

func (q *CFWorkersKV) Get(parentCtx context.Context, stateReq *state.GetRequest) (*state.GetResponse, error)

func (*CFWorkersKV) GetComponentMetadata

func (q *CFWorkersKV) GetComponentMetadata() map[string]string

func (*CFWorkersKV) Init

func (q *CFWorkersKV) Init(metadata state.Metadata) error

Init the component.

func (*CFWorkersKV) Set

func (q *CFWorkersKV) Set(parentCtx context.Context, stateReq *state.SetRequest) error