announcer

Documentation

Index

• type Announcer
  • func New() *Announcer
  • func (a *Announcer) Add(impl Impl)
  • func (a *Announcer) Announce(ctx context.Context, r *membership.Roxy) error
  • func (a *Announcer) Close() error
  • func (a *Announcer) Withdraw(ctx context.Context) error
• type Format
  • func (f Format) MarshalJSON() ([]byte, error)
  • func (f *Format) Parse(str string) error
  • func (f Format) String() string
  • func (f *Format) UnmarshalJSON(raw []byte) error
• type Impl
  • func NewATC(client *atcclient.ATCClient, serviceName, location, unique, namedPort string, ...) (Impl, error)
  • func NewEtcd(etcd *v3.Client, path, unique, namedPort string, format Format) (Impl, error)
  • func NewZK(zkconn *zk.Conn, path, unique, namedPort string, format Format) (Impl, error)

Types

type Announcer

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

func New

func New() *Announcer

func (*Announcer) Add

func (a *Announcer) Add(impl Impl)

func (*Announcer) Announce

func (a *Announcer) Announce(ctx context.Context, r *membership.Roxy) error

func (*Announcer) Close

func (a *Announcer) Close() error

func (*Announcer) Withdraw

func (a *Announcer) Withdraw(ctx context.Context) error

type Format

type Format uint8

const (
	RoxyFormat Format = iota
	FinagleFormat
	GRPCFormat
)

func (Format) MarshalJSON

func (f Format) MarshalJSON() ([]byte, error)

func (*Format) Parse

func (f *Format) Parse(str string) error

func (Format) String

func (f Format) String() string

func (*Format) UnmarshalJSON

func (f *Format) UnmarshalJSON(raw []byte) error

type Impl

type Impl interface {
	Announce(ctx context.Context, r *membership.Roxy) error
	Withdraw(ctx context.Context) error
	Close() error
}

func NewATC

func NewATC(client *atcclient.ATCClient, serviceName, location, unique, namedPort string, loadFn atcclient.LoadFunc) (Impl, error)

func NewEtcd

func NewEtcd(etcd *v3.Client, path, unique, namedPort string, format Format) (Impl, error)

func NewZK

func NewZK(zkconn *zk.Conn, path, unique, namedPort string, format Format) (Impl, error)