kv

Documentation

Index

• type YtDynTableKVWrapper
  • func NewYtDynTableKVWrapper(ctx context.Context, client yt.Client, path ypath.Path, key, val interface{}, ...) (*YtDynTableKVWrapper, error)
  • func (l *YtDynTableKVWrapper) CountAllRows(ctx context.Context) (uint64, error)
  • func (l *YtDynTableKVWrapper) DeleteRow(ctx context.Context, key interface{}) error
  • func (l *YtDynTableKVWrapper) DeleteRows(ctx context.Context, keys []interface{}) error
  • func (l *YtDynTableKVWrapper) GetValueByKey(ctx context.Context, key interface{}) (bool, interface{}, error)
  • func (l *YtDynTableKVWrapper) GetValueByKeyTx(ctx context.Context, tx yt.TabletTx, key interface{}) (bool, interface{}, error)
  • func (l *YtDynTableKVWrapper) InsertRow(ctx context.Context, key, value interface{}) error
  • func (l *YtDynTableKVWrapper) InsertRowTx(ctx context.Context, tx yt.TabletTx, key, value interface{}) error
  • func (l *YtDynTableKVWrapper) InsertRows(ctx context.Context, keys, values []interface{}) error
  • func (l *YtDynTableKVWrapper) InsertRowsTx(ctx context.Context, tx yt.TabletTx, keys, values []interface{}) error

Types

type YtDynTableKVWrapper

type YtDynTableKVWrapper struct {
	YtClient yt.Client
	Path     ypath.Path
	// contains filtered or unexported fields
}

func NewYtDynTableKVWrapper

func NewYtDynTableKVWrapper(ctx context.Context, client yt.Client, path ypath.Path, key, val interface{}, bundle string, attrs map[string]interface{}) (*YtDynTableKVWrapper, error)

func (*YtDynTableKVWrapper) CountAllRows

func (l *YtDynTableKVWrapper) CountAllRows(ctx context.Context) (uint64, error)

func (*YtDynTableKVWrapper) DeleteRow

func (l *YtDynTableKVWrapper) DeleteRow(ctx context.Context, key interface{}) error

func (*YtDynTableKVWrapper) DeleteRows

func (l *YtDynTableKVWrapper) DeleteRows(ctx context.Context, keys []interface{}) error

func (*YtDynTableKVWrapper) GetValueByKey

func (l *YtDynTableKVWrapper) GetValueByKey(ctx context.Context, key interface{}) (bool, interface{}, error)

func (*YtDynTableKVWrapper) GetValueByKeyTx

func (l *YtDynTableKVWrapper) GetValueByKeyTx(ctx context.Context, tx yt.TabletTx, key interface{}) (bool, interface{}, error)

func (*YtDynTableKVWrapper) InsertRow

func (l *YtDynTableKVWrapper) InsertRow(ctx context.Context, key, value interface{}) error

func (*YtDynTableKVWrapper) InsertRowTx

func (l *YtDynTableKVWrapper) InsertRowTx(ctx context.Context, tx yt.TabletTx, key, value interface{}) error

func (*YtDynTableKVWrapper) InsertRows

func (l *YtDynTableKVWrapper) InsertRows(ctx context.Context, keys, values []interface{}) error

func (*YtDynTableKVWrapper) InsertRowsTx

func (l *YtDynTableKVWrapper) InsertRowsTx(ctx context.Context, tx yt.TabletTx, keys, values []interface{}) error