etcdservice

Documentation

Index

• type EtcdService
  • func NewEtcdService(c *EtcdServiceConfig) *EtcdService
  • func (es *EtcdService) SendEvent(ctx *zservice.Context, key string, val []byte) *zservice.Error
  • func (es *EtcdService) WatchEvent(key string, cb func(ctx *zservice.Context, val []byte)) (cancelFunc context.CancelFunc)
• type EtcdServiceConfig
• type EventBody

Types

type EtcdService

type EtcdService struct {
	*zservice.ZService
	EtcdClient *clientv3.Client
}

func NewEtcdService

func NewEtcdService(c *EtcdServiceConfig) *EtcdService

func (*EtcdService) SendEvent

func (es *EtcdService) SendEvent(ctx *zservice.Context, key string, val []byte) *zservice.Error

发送事件

func (*EtcdService) WatchEvent

func (es *EtcdService) WatchEvent(key string, cb func(ctx *zservice.Context, val []byte)) (cancelFunc context.CancelFunc)

监听事件，支持取消功能

type EtcdServiceConfig

type EtcdServiceConfig struct {
	Addr    string             // ETCD 服务地址
	OnStart func(*EtcdService) // 启动的回调
}

type EventBody

type EventBody struct {
	S2S string `json:"s2s"` // S2S 数据
	Val []byte `json:"val"` // 内存
}