kvstore

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

• type EtcdClient
  • func NewEtcdClient(logger *zap.SugaredLogger, config EtcdConfig) *EtcdClient
• type EtcdConfig
• type Transaction
  • func NewTransaction() *Transaction
  • func (t *Transaction) AddKeyValue(key string, version int, value proto.Message) *Transaction
  • func (t *Transaction) WriteTo(store kv.TxnStore) error

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