Documentation ¶
Index ¶
- Variables
- func LoadKey(key string, modelStruct interface{}) (bool, error)
- func PutKey(key string, data interface{}) error
- type Transaction
- func (tran *Transaction) AppendStringArray(key string, values ...string)
- func (tran *Transaction) CreateJSON(key string, data interface{})
- func (tran *Transaction) Execute(resolvers ...func(map[string]interface{}) error) (*etcdv3.TxnResponse, error)
- func (tran *Transaction) ExecuteMustSuccess() error
- func (tran *Transaction) PullStringArray(key string, value string)
- func (tran *Transaction) PutJSON(key string, data interface{})
- func (tran *Transaction) WatchJSON(key string, schema interface{}, resolver func(interface{}) error)
Constants ¶
This section is empty.
Variables ¶
View Source
var Client *etcdv3.Client
View Source
var ErrEtcdTransactionFailed = errors.New("etcd transaction failed")
Functions ¶
Types ¶
type Transaction ¶
type Transaction struct {
// contains filtered or unexported fields
}
func NewTransaction ¶
func NewTransaction() *Transaction
func (*Transaction) AppendStringArray ¶
func (tran *Transaction) AppendStringArray(key string, values ...string)
func (*Transaction) CreateJSON ¶
func (tran *Transaction) CreateJSON(key string, data interface{})
func (*Transaction) Execute ¶
func (tran *Transaction) Execute(resolvers ...func(map[string]interface{}) error) (*etcdv3.TxnResponse, error)
func (*Transaction) ExecuteMustSuccess ¶
func (tran *Transaction) ExecuteMustSuccess() error
func (*Transaction) PullStringArray ¶
func (tran *Transaction) PullStringArray(key string, value string)
func (*Transaction) PutJSON ¶
func (tran *Transaction) PutJSON(key string, data interface{})
func (*Transaction) WatchJSON ¶
func (tran *Transaction) WatchJSON(key string, schema interface{}, resolver func(interface{}) error)
Click to show internal directories.
Click to hide internal directories.