worker

Documentation

Index

• type EtcdRegistry
  • func NewEtcdRegistry(ops ...EtcdRegistryOp) *EtcdRegistry
  • func (r *EtcdRegistry) Publish(ctx context.Context, message *subscribe.Message)
  • func (r *EtcdRegistry) Register(ctx context.Context, worker Worker) error
• type EtcdRegistryOp
  • func WithEtcdClient(cli *clientv3.Client) EtcdRegistryOp
  • func WithKeyTTL(ttl int64) EtcdRegistryOp
  • func WithWorkerTTL(ttl int64) EtcdRegistryOp
• type Key
• type Worker

Types

type EtcdRegistry

type EtcdRegistry struct {
	// contains filtered or unexported fields
}

func NewEtcdRegistry

func NewEtcdRegistry(ops ...EtcdRegistryOp) *EtcdRegistry

func (*EtcdRegistry) Publish

func (r *EtcdRegistry) Publish(ctx context.Context, message *subscribe.Message)

func (*EtcdRegistry) Register

func (r *EtcdRegistry) Register(ctx context.Context, worker Worker) error

type EtcdRegistryOp

type EtcdRegistryOp func(*EtcdRegistry)

func WithEtcdClient

func WithEtcdClient(cli *clientv3.Client) EtcdRegistryOp

func WithKeyTTL

func WithKeyTTL(ttl int64) EtcdRegistryOp

func WithWorkerTTL

func WithWorkerTTL(ttl int64) EtcdRegistryOp

type Key

type Key struct {
	Value     string
	Topic     string
	Partition string
}

type Worker

type Worker struct {
	HostId    string
	HostAddr  string
	Topic     string
	Partition string
}