cloud

Documentation

Index

• type Address
  • func NewAddress(public string, private string) Address
  • func (a Address) String() string
• type AddressProvider
  • func NewAddressProvider(dc *DiscoveryClient) *AddressProvider
  • func (a *AddressProvider) Addresses(ctx context.Context) ([]pubcluster.Address, error)
• type AddressTranslator
  • func NewAddressTranslator(dc *DiscoveryClient) *AddressTranslator
  • func (a *AddressTranslator) Translate(ctx context.Context, address pubcluster.Address) (pubcluster.Address, error)
  • func (a *AddressTranslator) TranslateMember(ctx context.Context, member *pubcluster.MemberInfo) (addr pubcluster.Address, err error)
• type DiscoveryClient
  • func NewDiscoveryClient(config *cluster.CloudConfig, logger logger.LogAdaptor) *DiscoveryClient
  • func (c *DiscoveryClient) DiscoverNodes(ctx context.Context) ([]Address, error)

Types

type Address

type Address struct {
	Public  string
	Private string
}

func NewAddress

func NewAddress(public string, private string) Address

func (Address) String

func (a Address) String() string

type AddressProvider

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

func NewAddressProvider

func NewAddressProvider(dc *DiscoveryClient) *AddressProvider

func (*AddressProvider) Addresses

func (a *AddressProvider) Addresses(ctx context.Context) ([]pubcluster.Address, error)

type AddressTranslator

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

func NewAddressTranslator

func NewAddressTranslator(dc *DiscoveryClient) *AddressTranslator

func (*AddressTranslator) Translate

func (a *AddressTranslator) Translate(ctx context.Context, address pubcluster.Address) (pubcluster.Address, error)

func (*AddressTranslator) TranslateMember

func (a *AddressTranslator) TranslateMember(ctx context.Context, member *pubcluster.MemberInfo) (addr pubcluster.Address, err error)

type DiscoveryClient

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

func NewDiscoveryClient

func NewDiscoveryClient(config *cluster.CloudConfig, logger logger.LogAdaptor) *DiscoveryClient

func (*DiscoveryClient) DiscoverNodes

func (c *DiscoveryClient) DiscoverNodes(ctx context.Context) ([]Address, error)