kvstore

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Copyright (c) 2017-2018 Uber Technologies, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright (c) 2017-2018 Uber Technologies, Inc.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EtcdClient

type EtcdClient struct {
	Zone          string
	Environment   string
	ServiceName   string
	ClusterClient client.Client
	TxnStore      kv.TxnStore
	Services      services.Services
}

EtcdClient represents etcd client

func NewEtcdClient

func NewEtcdClient(logger *zap.SugaredLogger, config EtcdConfig) *EtcdClient

NewEtcdClient returns a new EtcdClient

type EtcdConfig

type EtcdConfig struct {
	etcd.Configuration `yaml:",inline"`
	Enabled            bool `yaml:"enabled" json:"enabled"`
}

EtcdConfig represents etcd config

type Transaction

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

Transaction defines a Transaction

func NewTransaction

func NewTransaction() *Transaction

NewTransaction creates a new transaction

func (*Transaction) AddKeyValue

func (t *Transaction) AddKeyValue(key string, version int, value proto.Message) *Transaction

AddKeyValue adds a tuple of (key, version, value) to the transaction

func (*Transaction) WriteTo

func (t *Transaction) WriteTo(store kv.TxnStore) error

WriteTo writes the transaction to the transaction store

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL