register

package

v2.0.7-alpha Latest Latest Go to latest Published: Mar 15, 2025 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(r *Register)

Option function to configure *Register

func WithData(data *pipeline.Instance) Option

WithData sets registerData

func WithKey(key string) Option

WithKey sets registerKey

func WithLog(log *logrus.Entry) Option

func WithTTL(ttl time.Duration) Option

WithTTL sets ttl

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

Register Encapsulation of etcd register

func New(opts ...Option) (r *Register)

New returns a new *Register

func (r *Register) Close() error

func (r *Register) Closed() chan struct{}

func (r *Register) CompleteClose()

func (r *Register) IsClosed() bool

func (r *Register) Run(ctx context.Context) (err error)

Run start register