discovery

Documentation

Index

• Variables
• func CreateURLEndpoint(hazelcastProperties *property.HazelcastProperties, cloudToken string) string
• type HazelcastCloud
  • func NewHazelcastCloud(endpointURL string, connectionTimeout time.Duration, certPool *x509.CertPool) *HazelcastCloud
• type HzCloudAddrProvider
  • func NewHzCloudAddrProvider(endpointURL string, connectionTimeout time.Duration, logger logger.Logger) *HzCloudAddrProvider
  • func NewHzCloudAddrProviderWithCloudDisc(cloudDisc *HazelcastCloud, logger logger.Logger) *HzCloudAddrProvider
  • func (ap *HzCloudAddrProvider) LoadAddresses() []core.Address
• type HzCloudAddrTranslator
  • func NewHzCloudAddrTranslator(endpointURL string, connectionTimeout time.Duration, logger logger.Logger) *HzCloudAddrTranslator
  • func NewHzCloudAddrTranslatorWithCloudDisc(cloudDisc *HazelcastCloud, logger logger.Logger) *HzCloudAddrTranslator
  • func (at *HzCloudAddrTranslator) Refresh()
  • func (at *HzCloudAddrTranslator) Translate(addr core.Address) core.Address

Variables

var CloudURLBaseProperty = property.NewHazelcastPropertyString("hazelcast.client.cloud.url",
	"https://coordinator.hazelcast.cloud")

Functions

func CreateURLEndpoint

func CreateURLEndpoint(hazelcastProperties *property.HazelcastProperties, cloudToken string) string

Types

type HazelcastCloud

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

func NewHazelcastCloud

func NewHazelcastCloud(endpointURL string, connectionTimeout time.Duration, certPool *x509.CertPool) *HazelcastCloud

type HzCloudAddrProvider

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

HzCloudAddrProvider provides initial addresses for hazelcast.cloud

func NewHzCloudAddrProvider

func NewHzCloudAddrProvider(endpointURL string, connectionTimeout time.Duration, logger logger.Logger) *HzCloudAddrProvider

NewHzCloudAddrProvider returns a HzCloudAddrProvider with the given parameters.

func NewHzCloudAddrProviderWithCloudDisc

func NewHzCloudAddrProviderWithCloudDisc(cloudDisc *HazelcastCloud, logger logger.Logger) *HzCloudAddrProvider

NewHzCloudAddrProviderWithCloudDisc returns a HzCloudAddrProvider with the given parameters.

func (*HzCloudAddrProvider) LoadAddresses

func (ap *HzCloudAddrProvider) LoadAddresses() []core.Address

LoadAddresses returns a slice of addresses.

type HzCloudAddrTranslator

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

HzCloudAddrTranslator is used to translate private addresses to public addresses.

func NewHzCloudAddrTranslator

func NewHzCloudAddrTranslator(endpointURL string, connectionTimeout time.Duration, logger logger.Logger) *HzCloudAddrTranslator

NewHzCloudAddrTranslator returns a HzCloudAddrTranslator with the given parameters.

func NewHzCloudAddrTranslatorWithCloudDisc

func NewHzCloudAddrTranslatorWithCloudDisc(cloudDisc *HazelcastCloud, logger logger.Logger) *HzCloudAddrTranslator

NewHzCloudAddrTranslatorWithCloudDisc returns a HzCloudAddrTranslator with the given parameters.

func (*HzCloudAddrTranslator) Refresh

func (at *HzCloudAddrTranslator) Refresh()

Refresh refreshes the internal lookup table.

func (*HzCloudAddrTranslator) Translate

func (at *HzCloudAddrTranslator) Translate(addr core.Address) core.Address

Translate translates the given addr to its public address.