chirpstore

type DeleteRequest ¶

type DeleteRequest = IDKeyRequest

type GetRequest ¶

type GetRequest = IDKeyRequest

type HasRequest ¶

type HasRequest struct {
	ID   int
	Keys []string
}

HasRequest is an encoding wrapper for the arguments of the Has method.

func (s *HasRequest) Decode(data []byte) error

func (s HasRequest) Encode() []byte

type IDKeyRequest ¶

type IDKeyRequest struct {
	ID  int
	Key []byte
}

IDKeyRequest is a shared type for requests that take an ID and a key.

func (r *IDKeyRequest) Decode(data []byte) error

func (r IDKeyRequest) Encode() []byte

type IDOnly ¶

type IDOnly struct {
	ID int
}

IDOnly is a shared type for requests and responses that report only an ID.

func (r *IDOnly) Decode(data []byte) error

func (r IDOnly) Encode() []byte

type KV ¶

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

KV implements the blob.KV interface by calling a Chirp v0 peer.

func (s KV) Delete(ctx context.Context, key string) error

func (s KV) Get(ctx context.Context, key string) ([]byte, error)

func (s KV) Has(ctx context.Context, keys ...string) (blob.KeySet, error)

func (s KV) Len(ctx context.Context) (int64, error)

func (s KV) List(ctx context.Context, start string) iter.Seq2[string, error]

func (s KV) Put(ctx context.Context, opts blob.PutOptions) error

func (s KV) Status(ctx context.Context) ([]byte, error)

type KeyspaceRequest ¶

type KeyspaceRequest = IDKeyRequest

KeyspaceRequest is the encoding wrapper for a Keyspace request.

type KeyspaceResponse ¶

type KeyspaceResponse = IDOnly

KeyspaceResponse is the encoding wrapper for a Keyspace response.

type LenRequest ¶

type LenRequest = IDOnly

LenRequest is the encoding wrapper for a Len request.

type ListRequest ¶

type ListRequest struct {
	ID    int
	Start []byte
	Count int
}

ListRequest is the an encoding wrapper for the arguments to the List method.

func (r *ListRequest) Decode(data []byte) error

func (r ListRequest) Encode() []byte

type ListResponse ¶

type ListResponse struct {
	Keys [][]byte
	Next []byte
}

ListResponse is the an encoding wrapper for the List method response.

func (r *ListResponse) Decode(data []byte) error

func (r ListResponse) Encode() []byte

type PutRequest ¶

type PutRequest struct {
	ID      int
	Key     []byte
	Data    []byte
	Replace bool
}

PutRequest is an encoding wrapper for the arguments of the Put method.

func (p *PutRequest) Decode(data []byte) error

func (p PutRequest) Encode() []byte

type Service ¶

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

func NewService(st blob.Store, opts *ServiceOptions) *Service

func (s *Service) Delete(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Get(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Has(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) KV(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Len(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) List(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Put(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Register(p *chirp.Peer)

func (s *Service) Status(ctx context.Context, req *chirp.Request) ([]byte, error)

func (s *Service) Sub(ctx context.Context, req *chirp.Request) ([]byte, error)

type ServiceOptions ¶

type ServiceOptions struct {
	// A prefix to prepend to all the method names exported by the service.
	Prefix string
}

ServiceOptions provides optional settings for constructing a Service.

type Store ¶

type Store struct {
	*monitor.M[chirpStub, KV]
}

Store implements the blob.StoreCloser interface by delegating requests to a Chirp v0 peer. Store and KV operations are delegated to the remote peer.

func NewStore(peer *chirp.Peer, opts *StoreOptions) Store

func (s Store) Close(context.Context) error

type StoreOptions ¶

type StoreOptions struct {
	// A prefix to prepend to all the method names exported by the service.
	MethodPrefix string
}

StoreOptions provide optional settings for a Store. A nil is ready for use and provides default values.

type SubRequest ¶

type SubRequest = IDKeyRequest

SubRequest is the encoding wrapper for a Sub request.

type SubResponse ¶

type SubResponse = IDOnly

SubResponse is the encoding wrapper for a Sub response.