mydis

package module

Go to main page

Versions in this module

v1

v1.2.4

Apr 28, 2017

v1.2.3

Apr 28, 2017

v1.2.2

Apr 26, 2017

v1.2.1

Apr 20, 2017

v1.2.0

Apr 7, 2017

Changes in this version

+ func NewSelfCerts(orgName string) (cfg *tls.Config, err error)

+ func RegisterMydisHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterMydisHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func WebsocketProxy(h http.Handler) http.HandlerFunc

type ClientConfig

+ Addresses []string

+ func NewClientConfigAddresses(addresses []string) ClientConfig

v1.1.0

Mar 20, 2017

v1.0.1

Mar 14, 2017

v1.0.0

Mar 14, 2017

Changes in this version

+ var ErrTypeMismatch = errors.New("Type mismatch")

+ var Permission_Type_name = map[int32]string

+ var Permission_Type_value = map[string]int32

+ func GetKeyPrefix(key string) (bkey []byte, rangEnd []byte)

+ type AuthDisableRequest struct

+ func (*AuthDisableRequest) Descriptor() ([]byte, []int)

+ func (*AuthDisableRequest) ProtoMessage()

+ func (m *AuthDisableRequest) Reset()

+ func (m *AuthDisableRequest) String() string

+ type AuthDisableResponse struct

+ Header *ResponseHeader

+ func (*AuthDisableResponse) Descriptor() ([]byte, []int)

+ func (*AuthDisableResponse) ProtoMessage()

+ func (m *AuthDisableResponse) GetHeader() *ResponseHeader

+ func (m *AuthDisableResponse) Reset()

+ func (m *AuthDisableResponse) String() string

+ type AuthEnableRequest struct

+ func (*AuthEnableRequest) Descriptor() ([]byte, []int)

+ func (*AuthEnableRequest) ProtoMessage()

+ func (m *AuthEnableRequest) Reset()

+ func (m *AuthEnableRequest) String() string

+ type AuthEnableResponse struct

+ Header *ResponseHeader

+ func (*AuthEnableResponse) Descriptor() ([]byte, []int)

+ func (*AuthEnableResponse) ProtoMessage()

+ func (m *AuthEnableResponse) GetHeader() *ResponseHeader

+ func (m *AuthEnableResponse) Reset()

+ func (m *AuthEnableResponse) String() string

+ type AuthRoleAddRequest struct

+ Name string

+ func (*AuthRoleAddRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleAddRequest) ProtoMessage()

+ func (m *AuthRoleAddRequest) GetName() string

+ func (m *AuthRoleAddRequest) Reset()

+ func (m *AuthRoleAddRequest) String() string

+ type AuthRoleAddResponse struct

+ Header *ResponseHeader

+ func (*AuthRoleAddResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleAddResponse) ProtoMessage()

+ func (m *AuthRoleAddResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleAddResponse) Reset()

+ func (m *AuthRoleAddResponse) String() string

+ type AuthRoleDeleteRequest struct

+ Role string

+ func (*AuthRoleDeleteRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleDeleteRequest) ProtoMessage()

+ func (m *AuthRoleDeleteRequest) GetRole() string

+ func (m *AuthRoleDeleteRequest) Reset()

+ func (m *AuthRoleDeleteRequest) String() string

+ type AuthRoleDeleteResponse struct

+ Header *ResponseHeader

+ func (*AuthRoleDeleteResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleDeleteResponse) ProtoMessage()

+ func (m *AuthRoleDeleteResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleDeleteResponse) Reset()

+ func (m *AuthRoleDeleteResponse) String() string

+ type AuthRoleGetRequest struct

+ Role string

+ func (*AuthRoleGetRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleGetRequest) ProtoMessage()

+ func (m *AuthRoleGetRequest) GetRole() string

+ func (m *AuthRoleGetRequest) Reset()

+ func (m *AuthRoleGetRequest) String() string

+ type AuthRoleGetResponse struct

+ Header *ResponseHeader

+ Perm []*Permission

+ func (*AuthRoleGetResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleGetResponse) ProtoMessage()

+ func (m *AuthRoleGetResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleGetResponse) GetPerm() []*Permission

+ func (m *AuthRoleGetResponse) Reset()

+ func (m *AuthRoleGetResponse) String() string

+ type AuthRoleGrantPermissionRequest struct

+ Name string

+ Perm *Permission

+ func (*AuthRoleGrantPermissionRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleGrantPermissionRequest) ProtoMessage()

+ func (m *AuthRoleGrantPermissionRequest) GetName() string

+ func (m *AuthRoleGrantPermissionRequest) GetPerm() *Permission

+ func (m *AuthRoleGrantPermissionRequest) Reset()

+ func (m *AuthRoleGrantPermissionRequest) String() string

+ type AuthRoleGrantPermissionResponse struct

+ Header *ResponseHeader

+ func (*AuthRoleGrantPermissionResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleGrantPermissionResponse) ProtoMessage()

+ func (m *AuthRoleGrantPermissionResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleGrantPermissionResponse) Reset()

+ func (m *AuthRoleGrantPermissionResponse) String() string

+ type AuthRoleListRequest struct

+ func (*AuthRoleListRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleListRequest) ProtoMessage()

+ func (m *AuthRoleListRequest) Reset()

+ func (m *AuthRoleListRequest) String() string

+ type AuthRoleListResponse struct

+ Header *ResponseHeader

+ Roles []string

+ func (*AuthRoleListResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleListResponse) ProtoMessage()

+ func (m *AuthRoleListResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleListResponse) GetRoles() []string

+ func (m *AuthRoleListResponse) Reset()

+ func (m *AuthRoleListResponse) String() string

+ type AuthRoleRevokePermissionRequest struct

+ Key string

+ RangeEnd string

+ Role string

+ func (*AuthRoleRevokePermissionRequest) Descriptor() ([]byte, []int)

+ func (*AuthRoleRevokePermissionRequest) ProtoMessage()

+ func (m *AuthRoleRevokePermissionRequest) GetKey() string

+ func (m *AuthRoleRevokePermissionRequest) GetRangeEnd() string

+ func (m *AuthRoleRevokePermissionRequest) GetRole() string

+ func (m *AuthRoleRevokePermissionRequest) Reset()

+ func (m *AuthRoleRevokePermissionRequest) String() string

+ type AuthRoleRevokePermissionResponse struct

+ Header *ResponseHeader

+ func (*AuthRoleRevokePermissionResponse) Descriptor() ([]byte, []int)

+ func (*AuthRoleRevokePermissionResponse) ProtoMessage()

+ func (m *AuthRoleRevokePermissionResponse) GetHeader() *ResponseHeader

+ func (m *AuthRoleRevokePermissionResponse) Reset()

+ func (m *AuthRoleRevokePermissionResponse) String() string

+ type AuthUserAddRequest struct

+ Name string

+ Password string

+ func (*AuthUserAddRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserAddRequest) ProtoMessage()

+ func (m *AuthUserAddRequest) GetName() string

+ func (m *AuthUserAddRequest) GetPassword() string

+ func (m *AuthUserAddRequest) Reset()

+ func (m *AuthUserAddRequest) String() string

+ type AuthUserAddResponse struct

+ Header *ResponseHeader

+ func (*AuthUserAddResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserAddResponse) ProtoMessage()

+ func (m *AuthUserAddResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserAddResponse) Reset()

+ func (m *AuthUserAddResponse) String() string

+ type AuthUserChangePasswordRequest struct

+ Name string

+ Password string

+ func (*AuthUserChangePasswordRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserChangePasswordRequest) ProtoMessage()

+ func (m *AuthUserChangePasswordRequest) GetName() string

+ func (m *AuthUserChangePasswordRequest) GetPassword() string

+ func (m *AuthUserChangePasswordRequest) Reset()

+ func (m *AuthUserChangePasswordRequest) String() string

+ type AuthUserChangePasswordResponse struct

+ Header *ResponseHeader

+ func (*AuthUserChangePasswordResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserChangePasswordResponse) ProtoMessage()

+ func (m *AuthUserChangePasswordResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserChangePasswordResponse) Reset()

+ func (m *AuthUserChangePasswordResponse) String() string

+ type AuthUserDeleteRequest struct

+ Name string

+ func (*AuthUserDeleteRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserDeleteRequest) ProtoMessage()

+ func (m *AuthUserDeleteRequest) GetName() string

+ func (m *AuthUserDeleteRequest) Reset()

+ func (m *AuthUserDeleteRequest) String() string

+ type AuthUserDeleteResponse struct

+ Header *ResponseHeader

+ func (*AuthUserDeleteResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserDeleteResponse) ProtoMessage()

+ func (m *AuthUserDeleteResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserDeleteResponse) Reset()

+ func (m *AuthUserDeleteResponse) String() string

+ type AuthUserGetRequest struct

+ Name string

+ func (*AuthUserGetRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserGetRequest) ProtoMessage()

+ func (m *AuthUserGetRequest) GetName() string

+ func (m *AuthUserGetRequest) Reset()

+ func (m *AuthUserGetRequest) String() string

+ type AuthUserGetResponse struct

+ Header *ResponseHeader

+ Roles []string

+ func (*AuthUserGetResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserGetResponse) ProtoMessage()

+ func (m *AuthUserGetResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserGetResponse) GetRoles() []string

+ func (m *AuthUserGetResponse) Reset()

+ func (m *AuthUserGetResponse) String() string

+ type AuthUserGrantRoleRequest struct

+ Role string

+ User string

+ func (*AuthUserGrantRoleRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserGrantRoleRequest) ProtoMessage()

+ func (m *AuthUserGrantRoleRequest) GetRole() string

+ func (m *AuthUserGrantRoleRequest) GetUser() string

+ func (m *AuthUserGrantRoleRequest) Reset()

+ func (m *AuthUserGrantRoleRequest) String() string

+ type AuthUserGrantRoleResponse struct

+ Header *ResponseHeader

+ func (*AuthUserGrantRoleResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserGrantRoleResponse) ProtoMessage()

+ func (m *AuthUserGrantRoleResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserGrantRoleResponse) Reset()

+ func (m *AuthUserGrantRoleResponse) String() string

+ type AuthUserListRequest struct

+ func (*AuthUserListRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserListRequest) ProtoMessage()

+ func (m *AuthUserListRequest) Reset()

+ func (m *AuthUserListRequest) String() string

+ type AuthUserListResponse struct

+ Header *ResponseHeader

+ Users []string

+ func (*AuthUserListResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserListResponse) ProtoMessage()

+ func (m *AuthUserListResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserListResponse) GetUsers() []string

+ func (m *AuthUserListResponse) Reset()

+ func (m *AuthUserListResponse) String() string

+ type AuthUserRevokeRoleRequest struct

+ Name string

+ Role string

+ func (*AuthUserRevokeRoleRequest) Descriptor() ([]byte, []int)

+ func (*AuthUserRevokeRoleRequest) ProtoMessage()

+ func (m *AuthUserRevokeRoleRequest) GetName() string

+ func (m *AuthUserRevokeRoleRequest) GetRole() string

+ func (m *AuthUserRevokeRoleRequest) Reset()

+ func (m *AuthUserRevokeRoleRequest) String() string

+ type AuthUserRevokeRoleResponse struct

+ Header *ResponseHeader

+ func (*AuthUserRevokeRoleResponse) Descriptor() ([]byte, []int)

+ func (*AuthUserRevokeRoleResponse) ProtoMessage()

+ func (m *AuthUserRevokeRoleResponse) GetHeader() *ResponseHeader

+ func (m *AuthUserRevokeRoleResponse) Reset()

+ func (m *AuthUserRevokeRoleResponse) String() string

+ type AuthenticateRequest struct

+ Name string

+ Password string

+ func (*AuthenticateRequest) Descriptor() ([]byte, []int)

+ func (*AuthenticateRequest) ProtoMessage()

+ func (m *AuthenticateRequest) GetName() string

+ func (m *AuthenticateRequest) GetPassword() string

+ func (m *AuthenticateRequest) Reset()

+ func (m *AuthenticateRequest) String() string

+ type AuthenticateResponse struct

+ Header *ResponseHeader

+ Token string

+ func (*AuthenticateResponse) Descriptor() ([]byte, []int)

+ func (*AuthenticateResponse) ProtoMessage()

+ func (m *AuthenticateResponse) GetHeader() *ResponseHeader

+ func (m *AuthenticateResponse) GetToken() string

+ func (m *AuthenticateResponse) Reset()

+ func (m *AuthenticateResponse) String() string

type Client

+ func (c *Client) AuthDisable() error

+ func (c *Client) AuthEnable() error

+ func (c *Client) Authenticate(username, password string) (string, error)

+ func (c *Client) ListPopLeftBlock(key string, timeout int64) Value

+ func (c *Client) ListPopRightBlock(key string, timeout int64) Value

+ func (c *Client) LogOut()

+ func (c *Client) RoleAdd(role string) error

+ func (c *Client) RoleDelete(role string) error

+ func (c *Client) RoleGet(role string) ([]*Permission, error)

+ func (c *Client) RoleGrantPermission(role string, perm *Permission) error

+ func (c *Client) RoleList() ([]string, error)

+ func (c *Client) RoleRevokePermission(role string, perm *Permission) error

+ func (c *Client) UserAdd(username, password string) error

+ func (c *Client) UserChangePassword(username, password string) error

+ func (c *Client) UserDelete(username string) error

+ func (c *Client) UserGet(username string) ([]string, error)

+ func (c *Client) UserGrantRole(username, role string) error

+ func (c *Client) UserList() ([]string, error)

+ func (c *Client) UserRevokeRole(username, role string) error

type Key

+ Block bool

+ BlockTimeout int64

+ func (m *Key) GetBlock() bool

+ func (m *Key) GetBlockTimeout() int64

type MydisClient

+ AuthDisable func(ctx context.Context, in *AuthDisableRequest, opts ...grpc.CallOption) (*AuthDisableResponse, error)

+ AuthEnable func(ctx context.Context, in *AuthEnableRequest, opts ...grpc.CallOption) (*AuthEnableResponse, error)

+ Authenticate func(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error)

+ RoleAdd func(ctx context.Context, in *AuthRoleAddRequest, opts ...grpc.CallOption) (*AuthRoleAddResponse, error)

+ RoleDelete func(ctx context.Context, in *AuthRoleDeleteRequest, opts ...grpc.CallOption) (*AuthRoleDeleteResponse, error)

+ RoleGet func(ctx context.Context, in *AuthRoleGetRequest, opts ...grpc.CallOption) (*AuthRoleGetResponse, error)

+ RoleGrantPermission func(ctx context.Context, in *AuthRoleGrantPermissionRequest, ...) (*AuthRoleGrantPermissionResponse, error)

+ RoleList func(ctx context.Context, in *AuthRoleListRequest, opts ...grpc.CallOption) (*AuthRoleListResponse, error)

+ RoleRevokePermission func(ctx context.Context, in *AuthRoleRevokePermissionRequest, ...) (*AuthRoleRevokePermissionResponse, error)

+ UserAdd func(ctx context.Context, in *AuthUserAddRequest, opts ...grpc.CallOption) (*AuthUserAddResponse, error)

+ UserChangePassword func(ctx context.Context, in *AuthUserChangePasswordRequest, ...) (*AuthUserChangePasswordResponse, error)

+ UserDelete func(ctx context.Context, in *AuthUserDeleteRequest, opts ...grpc.CallOption) (*AuthUserDeleteResponse, error)

+ UserGet func(ctx context.Context, in *AuthUserGetRequest, opts ...grpc.CallOption) (*AuthUserGetResponse, error)

+ UserGrantRole func(ctx context.Context, in *AuthUserGrantRoleRequest, opts ...grpc.CallOption) (*AuthUserGrantRoleResponse, error)

+ UserList func(ctx context.Context, in *AuthUserListRequest, opts ...grpc.CallOption) (*AuthUserListResponse, error)

+ UserRevokeRole func(ctx context.Context, in *AuthUserRevokeRoleRequest, opts ...grpc.CallOption) (*AuthUserRevokeRoleResponse, error)

type MydisServer

+ AuthDisable func(context.Context, *AuthDisableRequest) (*AuthDisableResponse, error)

+ AuthEnable func(context.Context, *AuthEnableRequest) (*AuthEnableResponse, error)

+ Authenticate func(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)

+ RoleAdd func(context.Context, *AuthRoleAddRequest) (*AuthRoleAddResponse, error)

+ RoleDelete func(context.Context, *AuthRoleDeleteRequest) (*AuthRoleDeleteResponse, error)

+ RoleGet func(context.Context, *AuthRoleGetRequest) (*AuthRoleGetResponse, error)

+ RoleGrantPermission func(context.Context, *AuthRoleGrantPermissionRequest) (*AuthRoleGrantPermissionResponse, error)

+ RoleList func(context.Context, *AuthRoleListRequest) (*AuthRoleListResponse, error)

+ RoleRevokePermission func(context.Context, *AuthRoleRevokePermissionRequest) (*AuthRoleRevokePermissionResponse, error)

+ UserAdd func(context.Context, *AuthUserAddRequest) (*AuthUserAddResponse, error)

+ UserChangePassword func(context.Context, *AuthUserChangePasswordRequest) (*AuthUserChangePasswordResponse, error)

+ UserDelete func(context.Context, *AuthUserDeleteRequest) (*AuthUserDeleteResponse, error)

+ UserGet func(context.Context, *AuthUserGetRequest) (*AuthUserGetResponse, error)

+ UserGrantRole func(context.Context, *AuthUserGrantRoleRequest) (*AuthUserGrantRoleResponse, error)

+ UserList func(context.Context, *AuthUserListRequest) (*AuthUserListResponse, error)

+ UserRevokeRole func(context.Context, *AuthUserRevokeRoleRequest) (*AuthUserRevokeRoleResponse, error)

+ type Permission struct

+ Key []byte

+ PermType Permission_Type

+ RangeEnd []byte

+ func GetPermission(key string, permName string) *Permission

+ func (*Permission) Descriptor() ([]byte, []int)

+ func (*Permission) ProtoMessage()

+ func (m *Permission) GetKey() []byte

+ func (m *Permission) GetPermType() Permission_Type

+ func (m *Permission) GetRangeEnd() []byte

+ func (m *Permission) Reset()

+ func (m *Permission) String() string

+ type Permission_Type int32

+ const Permission_READ

+ const Permission_READWRITE

+ const Permission_WRITE

+ func (Permission_Type) EnumDescriptor() ([]byte, []int)

+ func (x Permission_Type) String() string

+ type ResponseHeader struct

+ ClusterId uint64

+ MemberId uint64

+ RaftTerm uint64

+ Revision int64

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (m *ResponseHeader) GetClusterId() uint64

+ func (m *ResponseHeader) GetMemberId() uint64

+ func (m *ResponseHeader) GetRaftTerm() uint64

+ func (m *ResponseHeader) GetRevision() int64

+ func (m *ResponseHeader) Reset()

+ func (m *ResponseHeader) String() string

type Server

+ func (s *Server) AuthDisable(ctx context.Context, req *AuthDisableRequest) (*AuthDisableResponse, error)

+ func (s *Server) AuthEnable(ctx context.Context, req *AuthEnableRequest) (*AuthEnableResponse, error)

+ func (s *Server) Authenticate(ctx context.Context, req *AuthenticateRequest) (*AuthenticateResponse, error)

+ func (s *Server) RoleAdd(ctx context.Context, req *AuthRoleAddRequest) (*AuthRoleAddResponse, error)

+ func (s *Server) RoleDelete(ctx context.Context, req *AuthRoleDeleteRequest) (*AuthRoleDeleteResponse, error)

+ func (s *Server) RoleGet(ctx context.Context, req *AuthRoleGetRequest) (*AuthRoleGetResponse, error)

+ func (s *Server) RoleGrantPermission(ctx context.Context, req *AuthRoleGrantPermissionRequest) (*AuthRoleGrantPermissionResponse, error)

+ func (s *Server) RoleList(ctx context.Context, req *AuthRoleListRequest) (*AuthRoleListResponse, error)

+ func (s *Server) RoleRevokePermission(ctx context.Context, req *AuthRoleRevokePermissionRequest) (*AuthRoleRevokePermissionResponse, error)

+ func (s *Server) UserAdd(ctx context.Context, req *AuthUserAddRequest) (*AuthUserAddResponse, error)

+ func (s *Server) UserChangePassword(ctx context.Context, req *AuthUserChangePasswordRequest) (*AuthUserChangePasswordResponse, error)

+ func (s *Server) UserDelete(ctx context.Context, req *AuthUserDeleteRequest) (*AuthUserDeleteResponse, error)

+ func (s *Server) UserGet(ctx context.Context, req *AuthUserGetRequest) (*AuthUserGetResponse, error)

+ func (s *Server) UserGrantRole(ctx context.Context, req *AuthUserGrantRoleRequest) (*AuthUserGrantRoleResponse, error)

+ func (s *Server) UserList(ctx context.Context, req *AuthUserListRequest) (*AuthUserListResponse, error)

+ func (s *Server) UserRevokeRole(ctx context.Context, req *AuthUserRevokeRoleRequest) (*AuthUserRevokeRoleResponse, error)

v0

v0.5.0

Mar 7, 2017

Changes in this version

+ var ErrHashFieldNotFound = errors.New("Hash field does not exist")

+ var ErrInvalidKey = errors.New("Invalid key name")

+ var ErrKeyLocked = errors.New("Key is locked")

+ var ErrKeyNotFound = errors.New("Key not found")

+ var ErrListEmpty = errors.New("List is empty")

+ var ErrListIndexOutOfRange = errors.New("Index out of range")

+ var Event_EventType_name = map[int32]string

+ var Event_EventType_value = map[string]int32

+ var VERSION = "0.5.0"

+ var ZeroByte = []byte

+ func BytesToString(b []byte) string

+ func ConfigFromYAML(b []byte) (*embed.Config, error)

+ func ConfigToYAML(config *embed.Config) ([]byte, error)

+ func CopyConfig(config *embed.Config) *embed.Config

+ func ListStringToBytes(lst []string) [][]byte

+ func ListValueToBytes(lst []Value) [][]byte

+ func MapBoolToMapBytes(h map[string]bool) map[string][]byte

+ func MapBytesToValues(h map[string][]byte) map[string]Value

+ func MapFloatToMapBytes(h map[string]float64) map[string][]byte

+ func MapIntToMapBytes(h map[string]int64) map[string][]byte

+ func MapStringToMapBytes(h map[string]string) map[string][]byte

+ func MapValueToMapBytes(h map[string]Value) map[string][]byte

+ func RegisterMydisServer(s *grpc.Server, srv MydisServer)

+ func StringToBytes(s string) []byte

+ type Bool struct

+ Value bool

+ func (*Bool) Descriptor() ([]byte, []int)

+ func (*Bool) ProtoMessage()

+ func (m *Bool) GetValue() bool

+ func (m *Bool) Reset()

+ func (m *Bool) String() string

+ type ByteValue struct

+ Key string

+ Value []byte

+ func (*ByteValue) Descriptor() ([]byte, []int)

+ func (*ByteValue) ProtoMessage()

+ func (m *ByteValue) GetKey() string

+ func (m *ByteValue) GetValue() []byte

+ func (m *ByteValue) Reset()

+ func (m *ByteValue) String() string

+ type Client struct

+ func NewClient(config ClientConfig) (*Client, error)

+ func (c *Client) Clear() error

+ func (c *Client) Close()

+ func (c *Client) CloseEventChannel(id int64)

+ func (c *Client) DecrementFloat(key string, by float64) (float64, error)

+ func (c *Client) DecrementInt(key string, by int64) (int64, error)

+ func (c *Client) DelHashField(key, field string) error

+ func (c *Client) Delete(key string) error

+ func (c *Client) Get(key string) Value

+ func (c *Client) GetHashField(key, field string) Value

+ func (c *Client) GetHashFields(key string, fields []string) (map[string]Value, error)

+ func (c *Client) GetListItem(key string, index int64) Value

+ func (c *Client) GetMany(keys []string) (map[string]Value, error)

+ func (c *Client) GetWithPrefix(prefix string) (map[string]Value, error)

+ func (c *Client) Has(key string) (bool, error)

+ func (c *Client) HashFields(key string) ([]string, error)

+ func (c *Client) HashHas(key, field string) (bool, error)

+ func (c *Client) HashLength(key string) (int64, error)

+ func (c *Client) HashValues(key string) ([]Value, error)

+ func (c *Client) IncrementFloat(key string, by float64) (float64, error)

+ func (c *Client) IncrementInt(key string, by int64) (int64, error)

+ func (c *Client) Keys() ([]string, error)

+ func (c *Client) KeysWithPrefix(prefix string) ([]string, error)

+ func (c *Client) Length(key string) (int64, error)

+ func (c *Client) ListAppend(key string, v interface{}) error

+ func (c *Client) ListDelete(key string, index int64) error

+ func (c *Client) ListDeleteItem(key string, v interface{}) (int64, error)

+ func (c *Client) ListHas(key string, v interface{}) (int64, error)

+ func (c *Client) ListInsert(key string, index int64, v interface{}) error

+ func (c *Client) ListLength(key string) (int64, error)

+ func (c *Client) ListLimit(key string, limit int64) error

+ func (c *Client) ListPopLeft(key string) Value

+ func (c *Client) ListPopRight(key string) Value

+ func (c *Client) Lock(key string) error

+ func (c *Client) LockWithTimeout(key string, seconds int64) error

+ func (c *Client) NewEventChannel() (ch chan *Event, id int64)

+ func (c *Client) Set(key string, v interface{}) error

+ func (c *Client) SetExpire(key string, seconds int64) error

+ func (c *Client) SetHashField(key, field string, v interface{}) error

+ func (c *Client) SetHashFields(key string, vals map[string]Value) error

+ func (c *Client) SetListItem(key string, index int64, v interface{}) error

+ func (c *Client) SetLockTimeout(seconds int64)

+ func (c *Client) SetMany(vals map[string]Value) (map[string]string, error)

+ func (c *Client) SetNX(key string, v interface{}) (bool, error)

+ func (c *Client) Unlock(key string) error

+ func (c *Client) UnlockThenSet(key string, v Value) error

+ func (c *Client) Unwatch(key string, prefix bool)

+ func (c *Client) Watch(key string, prefix bool)

+ type ClientConfig struct

+ Address string

+ AutoTLS bool

+ TLS *tls.Config

+ func NewClientConfig(address string) ClientConfig

+ type ErrorHash struct

+ Errors map[string]string

+ func (*ErrorHash) Descriptor() ([]byte, []int)

+ func (*ErrorHash) ProtoMessage()

+ func (m *ErrorHash) GetErrors() map[string]string

+ func (m *ErrorHash) Reset()

+ func (m *ErrorHash) String() string

+ type Event struct

+ Current *ByteValue

+ Previous *ByteValue

+ Type Event_EventType

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (m *Event) GetCurrent() *ByteValue

+ func (m *Event) GetPrevious() *ByteValue

+ func (m *Event) GetType() Event_EventType

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ type Event_EventType int32

+ const Event_DELETE

+ const Event_PUT

+ func (Event_EventType) EnumDescriptor() ([]byte, []int)

+ func (x Event_EventType) String() string

+ type Expiration struct

+ Exp int64

+ Key string

+ func (*Expiration) Descriptor() ([]byte, []int)

+ func (*Expiration) ProtoMessage()

+ func (m *Expiration) GetExp() int64

+ func (m *Expiration) GetKey() string

+ func (m *Expiration) Reset()

+ func (m *Expiration) String() string

+ type FloatValue struct

+ Key string

+ Value float64

+ func (*FloatValue) Descriptor() ([]byte, []int)

+ func (*FloatValue) ProtoMessage()

+ func (m *FloatValue) GetKey() string

+ func (m *FloatValue) GetValue() float64

+ func (m *FloatValue) Reset()

+ func (m *FloatValue) String() string

+ type Hash struct

+ Key string

+ Value map[string][]byte

+ func (*Hash) Descriptor() ([]byte, []int)

+ func (*Hash) ProtoMessage()

+ func (m *Hash) GetKey() string

+ func (m *Hash) GetValue() map[string][]byte

+ func (m *Hash) Reset()

+ func (m *Hash) String() string

+ type HashField struct

+ Field string

+ Key string

+ Value []byte

+ func (*HashField) Descriptor() ([]byte, []int)

+ func (*HashField) ProtoMessage()

+ func (m *HashField) GetField() string

+ func (m *HashField) GetKey() string

+ func (m *HashField) GetValue() []byte

+ func (m *HashField) Reset()

+ func (m *HashField) String() string

+ type HashFieldSet struct

+ Field []string

+ Key string

+ Value [][]byte

+ func (*HashFieldSet) Descriptor() ([]byte, []int)

+ func (*HashFieldSet) ProtoMessage()

+ func (m *HashFieldSet) GetField() []string

+ func (m *HashFieldSet) GetKey() string

+ func (m *HashFieldSet) GetValue() [][]byte

+ func (m *HashFieldSet) Reset()

+ func (m *HashFieldSet) String() string

+ type IntValue struct

+ Key string

+ Value int64

+ func (*IntValue) Descriptor() ([]byte, []int)

+ func (*IntValue) ProtoMessage()

+ func (m *IntValue) GetKey() string

+ func (m *IntValue) GetValue() int64

+ func (m *IntValue) Reset()

+ func (m *IntValue) String() string

+ type Key struct

+ Key string

+ Limit int64

+ MaxCreateRevision int64

+ MaxModRevision int64

+ MinCreateRevision int64

+ MinModRevision int64

+ Revision int64

+ func (*Key) Descriptor() ([]byte, []int)

+ func (*Key) ProtoMessage()

+ func (m *Key) GetKey() string

+ func (m *Key) GetLimit() int64

+ func (m *Key) GetMaxCreateRevision() int64

+ func (m *Key) GetMaxModRevision() int64

+ func (m *Key) GetMinCreateRevision() int64

+ func (m *Key) GetMinModRevision() int64

+ func (m *Key) GetRevision() int64

+ func (m *Key) Reset()

+ func (m *Key) String() string

+ type KeysList struct

+ Keys []string

+ func (*KeysList) Descriptor() ([]byte, []int)

+ func (*KeysList) ProtoMessage()

+ func (m *KeysList) GetKeys() []string

+ func (m *KeysList) Reset()

+ func (m *KeysList) String() string

+ type List struct

+ Key string

+ Limit int64

+ Value [][]byte

+ func (*List) Descriptor() ([]byte, []int)

+ func (*List) ProtoMessage()

+ func (m *List) GetKey() string

+ func (m *List) GetLimit() int64

+ func (m *List) GetValue() [][]byte

+ func (m *List) Reset()

+ func (m *List) String() string

+ type ListItem struct

+ Index int64

+ Key string

+ Value []byte

+ func (*ListItem) Descriptor() ([]byte, []int)

+ func (*ListItem) ProtoMessage()

+ func (m *ListItem) GetIndex() int64

+ func (m *ListItem) GetKey() string

+ func (m *ListItem) GetValue() []byte

+ func (m *ListItem) Reset()

+ func (m *ListItem) String() string

+ type MydisClient interface

+ Clear func(ctx context.Context, in *Null, opts ...grpc.CallOption) (*Null, error)

+ DecrementFloat func(ctx context.Context, in *FloatValue, opts ...grpc.CallOption) (*FloatValue, error)

+ DecrementInt func(ctx context.Context, in *IntValue, opts ...grpc.CallOption) (*IntValue, error)

+ DelHashField func(ctx context.Context, in *HashField, opts ...grpc.CallOption) (*Null, error)

+ Delete func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Null, error)

+ Get func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*ByteValue, error)

+ GetFloat func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*FloatValue, error)

+ GetHash func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Hash, error)

+ GetHashField func(ctx context.Context, in *HashField, opts ...grpc.CallOption) (*ByteValue, error)

+ GetHashFields func(ctx context.Context, in *HashFieldSet, opts ...grpc.CallOption) (*Hash, error)

+ GetInt func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*IntValue, error)

+ GetList func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*List, error)

+ GetListItem func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*ByteValue, error)

+ GetMany func(ctx context.Context, in *KeysList, opts ...grpc.CallOption) (*Hash, error)

+ GetWithPrefix func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Hash, error)

+ Has func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Bool, error)

+ HashFields func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*KeysList, error)

+ HashHas func(ctx context.Context, in *HashField, opts ...grpc.CallOption) (*Bool, error)

+ HashLength func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*IntValue, error)

+ HashValues func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*List, error)

+ IncrementFloat func(ctx context.Context, in *FloatValue, opts ...grpc.CallOption) (*FloatValue, error)

+ IncrementInt func(ctx context.Context, in *IntValue, opts ...grpc.CallOption) (*IntValue, error)

+ Keys func(ctx context.Context, in *Null, opts ...grpc.CallOption) (*KeysList, error)

+ KeysWithPrefix func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*KeysList, error)

+ Length func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*IntValue, error)

+ ListAppend func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*Null, error)

+ ListDelete func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*Null, error)

+ ListDeleteItem func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*IntValue, error)

+ ListHas func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*IntValue, error)

+ ListInsert func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*Null, error)

+ ListLength func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*IntValue, error)

+ ListLimit func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*Null, error)

+ ListPopLeft func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*ByteValue, error)

+ ListPopRight func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*ByteValue, error)

+ Lock func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Null, error)

+ LockWithTimeout func(ctx context.Context, in *Expiration, opts ...grpc.CallOption) (*Null, error)

+ Set func(ctx context.Context, in *ByteValue, opts ...grpc.CallOption) (*Null, error)

+ SetExpire func(ctx context.Context, in *Expiration, opts ...grpc.CallOption) (*Null, error)

+ SetFloat func(ctx context.Context, in *FloatValue, opts ...grpc.CallOption) (*Null, error)

+ SetHash func(ctx context.Context, in *Hash, opts ...grpc.CallOption) (*Null, error)

+ SetHashField func(ctx context.Context, in *HashField, opts ...grpc.CallOption) (*Null, error)

+ SetHashFields func(ctx context.Context, in *Hash, opts ...grpc.CallOption) (*Null, error)

+ SetInt func(ctx context.Context, in *IntValue, opts ...grpc.CallOption) (*Null, error)

+ SetList func(ctx context.Context, in *List, opts ...grpc.CallOption) (*Null, error)

+ SetListItem func(ctx context.Context, in *ListItem, opts ...grpc.CallOption) (*Null, error)

+ SetMany func(ctx context.Context, in *Hash, opts ...grpc.CallOption) (*ErrorHash, error)

+ SetNX func(ctx context.Context, in *ByteValue, opts ...grpc.CallOption) (*Bool, error)

+ Unlock func(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Null, error)

+ UnlockThenSet func(ctx context.Context, in *ByteValue, opts ...grpc.CallOption) (*Null, error)

+ UnlockThenSetList func(ctx context.Context, in *List, opts ...grpc.CallOption) (*Null, error)

+ Watch func(ctx context.Context, opts ...grpc.CallOption) (Mydis_WatchClient, error)

+ func NewMydisClient(cc *grpc.ClientConn) MydisClient

+ type MydisServer interface

+ Clear func(context.Context, *Null) (*Null, error)

+ DecrementFloat func(context.Context, *FloatValue) (*FloatValue, error)

+ DecrementInt func(context.Context, *IntValue) (*IntValue, error)

+ DelHashField func(context.Context, *HashField) (*Null, error)

+ Delete func(context.Context, *Key) (*Null, error)

+ Get func(context.Context, *Key) (*ByteValue, error)

+ GetFloat func(context.Context, *Key) (*FloatValue, error)

+ GetHash func(context.Context, *Key) (*Hash, error)

+ GetHashField func(context.Context, *HashField) (*ByteValue, error)

+ GetHashFields func(context.Context, *HashFieldSet) (*Hash, error)

+ GetInt func(context.Context, *Key) (*IntValue, error)

+ GetList func(context.Context, *Key) (*List, error)

+ GetListItem func(context.Context, *ListItem) (*ByteValue, error)

+ GetMany func(context.Context, *KeysList) (*Hash, error)

+ GetWithPrefix func(context.Context, *Key) (*Hash, error)

+ Has func(context.Context, *Key) (*Bool, error)

+ HashFields func(context.Context, *Key) (*KeysList, error)

+ HashHas func(context.Context, *HashField) (*Bool, error)

+ HashLength func(context.Context, *Key) (*IntValue, error)

+ HashValues func(context.Context, *Key) (*List, error)

+ IncrementFloat func(context.Context, *FloatValue) (*FloatValue, error)

+ IncrementInt func(context.Context, *IntValue) (*IntValue, error)

+ Keys func(context.Context, *Null) (*KeysList, error)

+ KeysWithPrefix func(context.Context, *Key) (*KeysList, error)

+ Length func(context.Context, *Key) (*IntValue, error)

+ ListAppend func(context.Context, *ListItem) (*Null, error)

+ ListDelete func(context.Context, *ListItem) (*Null, error)

+ ListDeleteItem func(context.Context, *ListItem) (*IntValue, error)

+ ListHas func(context.Context, *ListItem) (*IntValue, error)

+ ListInsert func(context.Context, *ListItem) (*Null, error)

+ ListLength func(context.Context, *Key) (*IntValue, error)

+ ListLimit func(context.Context, *ListItem) (*Null, error)

+ ListPopLeft func(context.Context, *Key) (*ByteValue, error)

+ ListPopRight func(context.Context, *Key) (*ByteValue, error)

+ Lock func(context.Context, *Key) (*Null, error)

+ LockWithTimeout func(context.Context, *Expiration) (*Null, error)

+ Set func(context.Context, *ByteValue) (*Null, error)

+ SetExpire func(context.Context, *Expiration) (*Null, error)

+ SetFloat func(context.Context, *FloatValue) (*Null, error)

+ SetHash func(context.Context, *Hash) (*Null, error)

+ SetHashField func(context.Context, *HashField) (*Null, error)

+ SetHashFields func(context.Context, *Hash) (*Null, error)

+ SetInt func(context.Context, *IntValue) (*Null, error)

+ SetList func(context.Context, *List) (*Null, error)

+ SetListItem func(context.Context, *ListItem) (*Null, error)

+ SetMany func(context.Context, *Hash) (*ErrorHash, error)

+ SetNX func(context.Context, *ByteValue) (*Bool, error)

+ Unlock func(context.Context, *Key) (*Null, error)

+ UnlockThenSet func(context.Context, *ByteValue) (*Null, error)

+ UnlockThenSetList func(context.Context, *List) (*Null, error)

+ Watch func(Mydis_WatchServer) error

+ type Mydis_WatchClient interface

+ Recv func() (*Event, error)

+ Send func(*WatchRequest) error

+ type Mydis_WatchServer interface

+ Recv func() (*WatchRequest, error)

+ Send func(*Event) error

+ type Null struct

+ func (*Null) Descriptor() ([]byte, []int)

+ func (*Null) ProtoMessage()

+ func (m *Null) Reset()

+ func (m *Null) String() string

+ type Server struct

+ func NewServer(config *embed.Config) *Server

+ func (s *Server) Clear(ctx context.Context, null *Null) (*Null, error)

+ func (s *Server) Close()

+ func (s *Server) DecrementFloat(ctx context.Context, fv *FloatValue) (*FloatValue, error)

+ func (s *Server) DecrementInt(ctx context.Context, iv *IntValue) (*IntValue, error)

+ func (s *Server) DelHashField(ctx context.Context, hf *HashField) (*Null, error)

+ func (s *Server) Delete(ctx context.Context, key *Key) (*Null, error)

+ func (s *Server) Get(ctx context.Context, key *Key) (*ByteValue, error)

+ func (s *Server) GetFloat(ctx context.Context, key *Key) (*FloatValue, error)

+ func (s *Server) GetHash(ctx context.Context, key *Key) (*Hash, error)

+ func (s *Server) GetHashField(ctx context.Context, hf *HashField) (*ByteValue, error)

+ func (s *Server) GetHashFields(ctx context.Context, hs *HashFieldSet) (*Hash, error)

+ func (s *Server) GetInt(ctx context.Context, key *Key) (*IntValue, error)

+ func (s *Server) GetList(ctx context.Context, key *Key) (*List, error)

+ func (s *Server) GetListItem(ctx context.Context, li *ListItem) (*ByteValue, error)

+ func (s *Server) GetMany(ctx context.Context, keys *KeysList) (*Hash, error)

+ func (s *Server) GetWithPrefix(ctx context.Context, key *Key) (*Hash, error)

+ func (s *Server) Has(ctx context.Context, key *Key) (*Bool, error)

+ func (s *Server) HashFields(ctx context.Context, key *Key) (*KeysList, error)

+ func (s *Server) HashHas(ctx context.Context, hf *HashField) (*Bool, error)

+ func (s *Server) HashLength(ctx context.Context, key *Key) (*IntValue, error)

+ func (s *Server) HashValues(ctx context.Context, key *Key) (*List, error)

+ func (s *Server) IncrementFloat(ctx context.Context, fv *FloatValue) (*FloatValue, error)

+ func (s *Server) IncrementInt(ctx context.Context, iv *IntValue) (*IntValue, error)

+ func (s *Server) Keys(ctx context.Context, null *Null) (*KeysList, error)

+ func (s *Server) KeysWithPrefix(ctx context.Context, key *Key) (*KeysList, error)

+ func (s *Server) Length(ctx context.Context, key *Key) (*IntValue, error)

+ func (s *Server) ListAppend(ctx context.Context, li *ListItem) (*Null, error)

+ func (s *Server) ListDelete(ctx context.Context, li *ListItem) (*Null, error)

+ func (s *Server) ListDeleteItem(ctx context.Context, li *ListItem) (*IntValue, error)

+ func (s *Server) ListHas(ctx context.Context, li *ListItem) (*IntValue, error)

+ func (s *Server) ListInsert(ctx context.Context, li *ListItem) (*Null, error)

+ func (s *Server) ListLength(ctx context.Context, key *Key) (*IntValue, error)

+ func (s *Server) ListLimit(ctx context.Context, li *ListItem) (*Null, error)

+ func (s *Server) ListPopLeft(ctx context.Context, key *Key) (*ByteValue, error)

+ func (s *Server) ListPopRight(ctx context.Context, key *Key) (*ByteValue, error)

+ func (s *Server) Lock(ctx context.Context, key *Key) (*Null, error)

+ func (s *Server) LockWithTimeout(ctx context.Context, ex *Expiration) (*Null, error)

+ func (s *Server) Set(ctx context.Context, val *ByteValue) (*Null, error)

+ func (s *Server) SetExpire(ctx context.Context, ex *Expiration) (*Null, error)

+ func (s *Server) SetFloat(ctx context.Context, fv *FloatValue) (*Null, error)

+ func (s *Server) SetHash(ctx context.Context, h *Hash) (*Null, error)

+ func (s *Server) SetHashField(ctx context.Context, hf *HashField) (*Null, error)

+ func (s *Server) SetHashFields(ctx context.Context, ah *Hash) (*Null, error)

+ func (s *Server) SetInt(ctx context.Context, iv *IntValue) (*Null, error)

+ func (s *Server) SetList(ctx context.Context, lst *List) (*Null, error)

+ func (s *Server) SetListItem(ctx context.Context, li *ListItem) (*Null, error)

+ func (s *Server) SetMany(ctx context.Context, h *Hash) (*ErrorHash, error)

+ func (s *Server) SetNX(ctx context.Context, val *ByteValue) (*Bool, error)

+ func (s *Server) Start(address string) error

+ func (s *Server) Unlock(ctx context.Context, key *Key) (*Null, error)

+ func (s *Server) UnlockThenSet(ctx context.Context, val *ByteValue) (*Null, error)

+ func (s *Server) UnlockThenSetHash(ctx context.Context, val *Hash) (*Null, error)

+ func (s *Server) UnlockThenSetList(ctx context.Context, val *List) (*Null, error)

+ func (s *Server) Watch(stream Mydis_WatchServer) error

+ type StringHash struct

+ Key string

+ Value map[string]string

+ func (*StringHash) Descriptor() ([]byte, []int)

+ func (*StringHash) ProtoMessage()

+ func (m *StringHash) GetKey() string

+ func (m *StringHash) GetValue() map[string]string

+ func (m *StringHash) Reset()

+ func (m *StringHash) String() string

+ type Value struct

+ func ListStringToValues(lst []string) []Value

+ func ListToValues(lst [][]byte) []Value

+ func NewValue(t interface{}) Value

+ func (v Value) Bool() (bool, error)

+ func (v Value) Bytes() ([]byte, error)

+ func (v Value) Duration() (time.Duration, error)

+ func (v Value) Error() error

+ func (v Value) Float() (float64, error)

+ func (v Value) Int() (int64, error)

+ func (v Value) List() ([]Value, error)

+ func (v Value) Map() (map[string]Value, error)

+ func (v Value) Proto(pb proto.Message) error

+ func (v Value) String() (string, error)

+ func (v Value) Time() (time.Time, error)

+ type WatchController struct

+ func NewWatchController(server *etcdserver.EtcdServer) *WatchController

+ func (w *WatchController) Close()

+ func (w *WatchController) NewWatcher() *Watcher

+ type WatchRequest struct

+ Cancel bool

+ Id int64

+ Key string

+ Prefix bool

+ Rev int64

+ func (*WatchRequest) Descriptor() ([]byte, []int)

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) GetCancel() bool

+ func (m *WatchRequest) GetId() int64

+ func (m *WatchRequest) GetKey() string

+ func (m *WatchRequest) GetPrefix() bool

+ func (m *WatchRequest) GetRev() int64

+ func (m *WatchRequest) Reset()

+ func (m *WatchRequest) String() string

+ type Watcher struct

+ func (w *Watcher) Close()

+ func (w *Watcher) RequestID(r *WatchRequest) string

Incompatible versions in this module

v2.0.2+incompatible

Apr 28, 2017

v2.0.0+incompatible

Apr 28, 2017

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