common

Documentation

Index

• func PtrBool(b bool) *bool
• func PtrInt64(i int64) *int64
• func PtrString(s string) *string
• func WriteHexDump(out io.Writer, buffer []byte)
• func WriteOutput(out io.Writer, value any)
• type ClientConfig
  • func (ClientConfig) NewClient() (oxia.SyncClient, error)
• type MockClient
  • func NewMockClient() *MockClient
  • func (m *MockClient) Close() error
  • func (m *MockClient) Delete(_ context.Context, key string, options ...oxia.DeleteOption) error
  • func (m *MockClient) DeleteRange(_ context.Context, minKeyInclusive string, maxKeyExclusive string, ...) error
  • func (m *MockClient) Get(_ context.Context, key string, options ...oxia.GetOption) (storedKey string, value []byte, version oxia.Version, err error)
  • func (*MockClient) GetNotifications() (oxia.Notifications, error)
  • func (m *MockClient) List(_ context.Context, minKeyInclusive string, maxKeyExclusive string, ...) (keys []string, err error)
  • func (m *MockClient) Put(_ context.Context, key string, value []byte, options ...oxia.PutOption) (insertedKey string, version oxia.Version, err error)
  • func (m *MockClient) RangeScan(_ context.Context, minKeyInclusive string, maxKeyExclusive string, ...) <-chan oxia.GetResult
• type OutputError
• type OutputVersion

Functions

func PtrBool

func PtrBool(b bool) *bool

func PtrInt64

func PtrInt64(i int64) *int64

func PtrString

func PtrString(s string) *string

func WriteHexDump

func WriteHexDump(out io.Writer, buffer []byte)

func WriteOutput

func WriteOutput(out io.Writer, value any)

Types

type ClientConfig

type ClientConfig struct {
	ServiceAddr    string
	Namespace      string
	RequestTimeout time.Duration
}

func (ClientConfig) NewClient

func (ClientConfig) NewClient() (oxia.SyncClient, error)

type MockClient

type MockClient struct {
	mock.Mock
}

var (
	Config       = ClientConfig{}
	MockedClient *MockClient
)

func NewMockClient

func NewMockClient() *MockClient

func (*MockClient) Close

func (m *MockClient) Close() error

func (*MockClient) Delete

func (m *MockClient) Delete(_ context.Context, key string, options ...oxia.DeleteOption) error

func (*MockClient) DeleteRange

func (m *MockClient) DeleteRange(_ context.Context, minKeyInclusive string, maxKeyExclusive string, options ...oxia.DeleteRangeOption) error

func (*MockClient) Get

func (m *MockClient) Get(_ context.Context, key string, options ...oxia.GetOption) (storedKey string, value []byte, version oxia.Version, err error)

func (*MockClient) GetNotifications

func (*MockClient) GetNotifications() (oxia.Notifications, error)

func (*MockClient) List

func (m *MockClient) List(_ context.Context, minKeyInclusive string, maxKeyExclusive string, options ...oxia.ListOption) (keys []string, err error)

func (*MockClient) Put

func (m *MockClient) Put(_ context.Context, key string, value []byte, options ...oxia.PutOption) (insertedKey string, version oxia.Version, err error)

func (*MockClient) RangeScan

func (m *MockClient) RangeScan(_ context.Context, minKeyInclusive string, maxKeyExclusive string, options ...oxia.RangeScanOption) <-chan oxia.GetResult

type OutputError

type OutputError struct {
	Err string `json:"error,omitempty"`
}

type OutputVersion

type OutputVersion struct {
	Key                string    `json:"key"`
	VersionId          int64     `json:"version_id"`
	CreatedTimestamp   time.Time `json:"created_timestamp"`
	ModifiedTimestamp  time.Time `json:"modified_timestamp"`
	ModificationsCount int64     `json:"modifications_count"`
	Ephemeral          bool      `json:"ephemeral"`
	ClientIdentity     string    `json:"client_identity"`
}