worker

Documentation

Index

• type EtcdRegistry
  • func NewEtcdRegistry(ops ...EtcdRegistryOp) *EtcdRegistry
  • func (r *EtcdRegistry) Register(ctx context.Context, worker Worker, ttl int64) error
  • func (r *EtcdRegistry) RegisterKey(ctx context.Context, key Key) error
• type EtcdRegistryOp
  • func WithEtcdClient(cli *clientv3.Client) 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) Register

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

func (*EtcdRegistry) RegisterKey

func (r *EtcdRegistry) RegisterKey(ctx context.Context, key Key) error

type EtcdRegistryOp

type EtcdRegistryOp func(*EtcdRegistry)

func WithEtcdClient

func WithEtcdClient(cli *clientv3.Client) 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
}