naming

Documentation

Index

• func NewNamingMessage(action string) (*transport.Message, error)
• type ActivityId
  • func (a ActivityId) IsEmpty() bool
  • func (a ActivityId) String() string
• type ApplicationQueryResult
• type ConsistencyUnitId
• type GatewayDescription
• type GenerationNumber
• type NamingClient
  • func NewNamingClient(transport *transport.Client) (*NamingClient, error)
  • func (n *NamingClient) GetApplicationList(ctx context.Context, filter string) ([]ApplicationQueryResult, error)
  • func (n *NamingClient) Ping(ctx context.Context) (*GatewayDescription, error)
  • func (n *NamingClient) RegisterFilter(ctx context.Context, name common.Uri, ...) (uint64, error)
• type NotificationClientConnectionReplyBody
• type NotificationClientConnectionRequestBody
• type ProtocolVersion
• type RegisterServiceNotificationFilterRequestBody
• type ServiceNotification
• type ServiceNotificationFilter
• type ServiceNotificationFilterFlags
• type ServiceNotificationPageId
• type ServiceReplicaSet
• type ServiceTableEntry
• type ServiceTableEntryNotification
• type VersionRange
• type VersionRangeCollection

Functions

func NewNamingMessage

func NewNamingMessage(action string) (*transport.Message, error)

Types

type ActivityId

type ActivityId struct {
	Id    serialization.GUID
	Index uint64
}

func (ActivityId) IsEmpty

func (a ActivityId) IsEmpty() bool

func (ActivityId) String

func (a ActivityId) String() string

type ApplicationQueryResult

type ApplicationQueryResult struct {
	ApplicationName        common.Uri
	ApplicationTypeName    string
	ApplicationTypeVersion string
	ApplicationStatus      int64
	HealthState            int64
	ApplicationParameters  map[string]string
}

type ConsistencyUnitId

type ConsistencyUnitId struct {
	GUID serialization.GUID
}

type GatewayDescription

type GatewayDescription struct {
	Address      string
	NodeInstance federation.NodeInstance
	NodeName     string
}

type GenerationNumber

type GenerationNumber struct {
	Generation int64
	Owner      federation.NodeID
}

type NamingClient

type NamingClient struct {
	OnServiceNotification func(notification *ServiceNotification)
	// contains filtered or unexported fields
}

func NewNamingClient

func NewNamingClient(transport *transport.Client) (*NamingClient, error)

func (*NamingClient) GetApplicationList

func (n *NamingClient) GetApplicationList(ctx context.Context, filter string) ([]ApplicationQueryResult, error)

func (*NamingClient) Ping

func (n *NamingClient) Ping(ctx context.Context) (*GatewayDescription, error)

func (*NamingClient) RegisterFilter

func (n *NamingClient) RegisterFilter(ctx context.Context, name common.Uri, matchNamePrefix, matchPrimaryChangeOnly bool) (uint64, error)

type NotificationClientConnectionReplyBody

type NotificationClientConnectionReplyBody struct {
	Generation                       GenerationNumber
	LastDeletedEmptyPartitionVersion int64
	Gateway                          GatewayDescription
}

type NotificationClientConnectionRequestBody

type NotificationClientConnectionRequestBody struct {
	ClientId       string
	Generation     GenerationNumber
	ClientVersions *VersionRangeCollection
	Filters        []*ServiceNotificationFilter
}

type ProtocolVersion

type ProtocolVersion struct {
	Major int64
	Minor int64
}

type RegisterServiceNotificationFilterRequestBody

type RegisterServiceNotificationFilterRequestBody struct {
	ClientId string
	Filter   *ServiceNotificationFilter
}

type ServiceNotification

type ServiceNotification struct {
	NotificationPageId ServiceNotificationPageId
	Generation         GenerationNumber
	Versions           *VersionRangeCollection
	Partitions         []*ServiceTableEntryNotification
}

type ServiceNotificationFilter

type ServiceNotificationFilter struct {
	FilterId uint64
	Name     common.Uri
	Flags    ServiceNotificationFilterFlags
}

type ServiceNotificationFilterFlags

type ServiceNotificationFilterFlags struct {
	Flags uint32
}

type ServiceNotificationPageId

type ServiceNotificationPageId struct {
	NotificationId transport.ActivityId
	PageIndex      uint64
}

type ServiceReplicaSet

type ServiceReplicaSet struct {
	IsStateful             bool
	IsPrimaryLocationValid bool
	PrimaryLocation        string
	ReplicaLocations       []string
	LookupVersion          int64
	IsPrimaryAuxiliary     bool
	AuxiliaryLocations     []string
}

type ServiceTableEntry

type ServiceTableEntry struct {
	ConsistencyUnitId ConsistencyUnitId
	ServiceName       string
	ServiceReplicaSet ServiceReplicaSet
	IsFound           bool
}

type ServiceTableEntryNotification

type ServiceTableEntryNotification struct {
	ServiceTable       *ServiceTableEntry
	MatchedPrimaryOnly bool
}

type VersionRange

type VersionRange struct {
	StartVersion int64
	EndVersion   int64
}

type VersionRangeCollection

type VersionRangeCollection struct {
	VersionRanges []VersionRange
}