model

package

v0.2.2 Latest Latest Go to latest Published: Dec 3, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation ¶

Index ¶

Constants
func EndpointIdFromIPAddressAndPort(address string, port Port) string
type Changes
type Endpoint
- func NewEndpointFromInstance(inst *types.HttpInstanceSummary) (endpointPtr *Endpoint, err error)
type Namespace
type NamespaceType
- func ConvertNamespaceType(nsType types.NamespaceType) (namespaceType NamespaceType)
- func (namespaceType *NamespaceType) IsUnsupported() bool
type Plan
- func (p *Plan) CalculateChanges() Changes
type Port
- func (p *Port) Equals(other *Port) bool
- func (p *Port) GetID() string
type Resource
type Service

Constants ¶

const (
	EndpointIpv4Attr      = "AWS_INSTANCE_IPV4"
	EndpointPortAttr      = "AWS_INSTANCE_PORT"
	EndpointPortNameAttr  = "ENDPOINT_PORT_NAME"
	EndpointProtocolAttr  = "ENDPOINT_PROTOCOL"
	ServicePortNameAttr   = "SERVICE_PORT_NAME"
	ServicePortAttr       = "SERVICE_PORT"
	ServiceTargetPortAttr = "SERVICE_TARGET_PORT"
	ServiceProtocolAttr   = "SERVICE_PROTOCOL"
)

Cloudmap Instances IP and Port is supposed to be AWS_INSTANCE_IPV4 and AWS_INSTANCE_PORT Rest are custom attributes

Variables ¶

This section is empty.

Functions ¶

func EndpointIdFromIPAddressAndPort ¶ added in v0.2.0

func EndpointIdFromIPAddressAndPort(address string, port Port) string

EndpointIdFromIPAddressAndPort converts an IP address to human-readable identifier.

Types ¶

type Changes ¶

type Changes struct {
	// List of endpoints that need to be created
	Create []*Endpoint
	// List of endpoints that need to be updated
	Update []*Endpoint
	// List of endpoints that need to be deleted
	Delete []*Endpoint
}

func (*Changes) HasDeletes ¶ added in v0.2.0

func (c *Changes) HasDeletes() bool

func (*Changes) HasUpdates ¶ added in v0.2.0

func (c *Changes) HasUpdates() bool

func (*Changes) IsNone ¶ added in v0.2.0

func (c *Changes) IsNone() bool

type Endpoint ¶

type Endpoint struct {
	Id           string
	IP           string
	EndpointPort Port
	ServicePort  Port
	Attributes   map[string]string
}

Endpoint holds basic values and attributes for an endpoint.

func NewEndpointFromInstance ¶

func NewEndpointFromInstance(inst *types.HttpInstanceSummary) (endpointPtr *Endpoint, err error)

NewEndpointFromInstance converts a Cloud Map HttpInstanceSummary to an endpoint.

func (*Endpoint) Equals ¶

func (e *Endpoint) Equals(other *Endpoint) bool

Equals evaluates if two Endpoints are "deeply equal" (including all fields).

func (*Endpoint) GetCloudMapAttributes ¶ added in v0.1.1

func (e *Endpoint) GetCloudMapAttributes() map[string]string

GetCloudMapAttributes extracts endpoint attributes for Cloud Map service instance registration.

func (*Endpoint) String ¶

func (e *Endpoint) String() string

String gives a string representation for an endpoint.

type Namespace ¶ added in v0.1.1

type Namespace struct {
	Id   string
	Name string
	Type NamespaceType
}

Namespace hold namespace attributes

type NamespaceType ¶ added in v0.1.1

type NamespaceType string

const (
	HttpNamespaceType       NamespaceType = "HTTP"
	DnsPrivateNamespaceType NamespaceType = "DNS_PRIVATE"
	// UnsupportedNamespaceType Placeholder NamespaceType to denote not supported values
	UnsupportedNamespaceType NamespaceType = ""
)

func ConvertNamespaceType ¶ added in v0.1.1

func ConvertNamespaceType(nsType types.NamespaceType) (namespaceType NamespaceType)

func (*NamespaceType) IsUnsupported ¶ added in v0.1.1

func (namespaceType *NamespaceType) IsUnsupported() bool

type Plan ¶

type Plan struct {
	// List of current instances
	Current []*Endpoint

	// List of desired instances
	Desired []*Endpoint
}

func (*Plan) CalculateChanges ¶

func (p *Plan) CalculateChanges() Changes

CalculateChanges returns list of Changes that need to applied

type Port ¶ added in v0.2.0

type Port struct {
	Name       string
	Port       int32
	TargetPort string
	Protocol   string // TCP, UDP, SCTP
}

func (*Port) Equals ¶ added in v0.2.2

func (p *Port) Equals(other *Port) bool

Equals evaluates if two Ports are "deeply equal" (including all fields).

func (*Port) GetID ¶ added in v0.2.0

func (p *Port) GetID() string

type Resource ¶ added in v0.1.1

type Resource struct {
	Id   string
	Name string
}

Resource encapsulates a ID/name pair.

type Service ¶

type Service struct {
	Namespace string
	Name      string
	Endpoints []*Endpoint
}

Service holds namespace and endpoint state for a named service.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL