keyvalue

Documentation

Index

• Variables
• func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.StoreDiffRequest) (resp *spacesyncproto.StoreDiffResponse, err error)
• func New() kvinterfaces.KeyValueService
• type Client
• type RemoteDiff
  • func NewRemoteDiff(spaceId string, client Client) RemoteDiff

Variables

var ErrUnexpectedMessageType = errors.New("unexpected message type")

Functions

func HandleRangeRequest

func HandleRangeRequest(ctx context.Context, d ldiff.Diff, req *spacesyncproto.StoreDiffRequest) (resp *spacesyncproto.StoreDiffResponse, err error)

func New

func New() kvinterfaces.KeyValueService

Types

type Client

type Client interface {
	StoreDiff(context.Context, *spacesyncproto.StoreDiffRequest) (*spacesyncproto.StoreDiffResponse, error)
}

type RemoteDiff

type RemoteDiff interface {
	ldiff.Remote
}

func NewRemoteDiff

func NewRemoteDiff(spaceId string, client Client) RemoteDiff