etcdclient

package

v1.2.2 Latest Latest Go to latest Published: Nov 28, 2022 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tmnhs/crony

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DelLock(key string) error
func Delete(key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)
func Get(key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
func GetLock(key string, id clientv3.LeaseID) (bool, error)
func Grant(ttl int64) (*clientv3.LeaseGrantResponse, error)
func IsValidAsKeyPath(s string) bool
func NewEtcdTimeoutContext() (context.Context, context.CancelFunc)
func Put(key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
func PutWithModRev(key, val string, rev int64) (*clientv3.PutResponse, error)
func PutWithTtl(key, val string, ttl int64) (*clientv3.PutResponse, error)
func Revoke(id clientv3.LeaseID) (*clientv3.LeaseRevokeResponse, error)
func Watch(key string, opts ...clientv3.OpOption) clientv3.WatchChan
type Client
- func GetEtcdClient() *Client
- func Init(endpoints []string, dialTimeout, reqTimeout int64) (*Client, error)
type ServerReg
- func NewServerReg(ttl int64) *ServerReg
type Watcher

Constants ¶

View Source

const (

	//key /crony/node/<node_uuid>
	KeyEtcdNodeProfile = keyEtcdProfile + "node/"
	KeyEtcdNode        = KeyEtcdNodeProfile + "%s"

	//key  /crony/proc/<node_uuid>/<job_id>/<pid>
	KeyEtcdProcProfile     = keyEtcdProfile + "proc/"
	KeyEtcdNodeProcProfile = KeyEtcdProcProfile + "%s/"
	KeyEtcdJobProcProfile  = KeyEtcdNodeProcProfile + "%d/"
	KeyEtcdProc            = KeyEtcdJobProcProfile + "%d"

	//key /crony/job/<node_uuid>/<job_id>
	KeyEtcdJobProfile = keyEtcdProfile + "job/%s/"
	KeyEtcdJob        = KeyEtcdJobProfile + "%d"

	// key /crony/once/<jobID>
	KeyEtcdOnceProfile = keyEtcdProfile + "once/"
	KeyEtcdOnce        = KeyEtcdOnceProfile + "%d"

	KeyEtcdLockProfile = keyEtcdProfile + "lock/"
	KeyEtcdLock        = KeyEtcdLockProfile + "%s"

	// key /crony/system/<node_uuid>
	KeyEtcdSystemProfile = keyEtcdProfile + "system/"
	KeyEtcdSystemSwitch  = KeyEtcdSystemProfile + "switch/" + "%s"
	KeyEtcdSystemGet     = KeyEtcdSystemProfile + "get/" + "%s"
)

Variables ¶

This section is empty.

Functions ¶

func DelLock ¶

func DelLock(key string) error

func Delete ¶

func Delete(key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

func Get ¶

func Get(key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

func GetLock ¶

func GetLock(key string, id clientv3.LeaseID) (bool, error)

func Grant ¶

func Grant(ttl int64) (*clientv3.LeaseGrantResponse, error)

func IsValidAsKeyPath ¶

func IsValidAsKeyPath(s string) bool

func NewEtcdTimeoutContext ¶

func NewEtcdTimeoutContext() (context.Context, context.CancelFunc)

NewEtcdTimeoutContext return a new etcdTimeoutContext

func Put ¶

func Put(key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

func PutWithModRev ¶

func PutWithModRev(key, val string, rev int64) (*clientv3.PutResponse, error)

func PutWithTtl ¶

func PutWithTtl(key, val string, ttl int64) (*clientv3.PutResponse, error)

func Revoke ¶

func Revoke(id clientv3.LeaseID) (*clientv3.LeaseRevokeResponse, error)

func Watch ¶

func Watch(key string, opts ...clientv3.OpOption) clientv3.WatchChan

Types ¶

type Client ¶

type Client struct {
	*clientv3.Client
	// contains filtered or unexported fields
}

func GetEtcdClient ¶

func GetEtcdClient() *Client

func Init ¶

func Init(endpoints []string, dialTimeout, reqTimeout int64) (*Client, error)

type ServerReg ¶

type ServerReg struct {
	Client *Client

	//time-to-live
	Ttl int64
	// contains filtered or unexported fields
}

func NewServerReg ¶

func NewServerReg(ttl int64) *ServerReg

func (*ServerReg) Register ¶

func (s *ServerReg) Register(key string, value string) error

func (*ServerReg) RevokeLease ¶

func (s *ServerReg) RevokeLease() error

func (*ServerReg) Stop ¶

func (s *ServerReg) Stop()

type Watcher ¶

type Watcher interface {
	Watch() error

	Close() error
}

Source Files ¶

View all Source files

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