attributes

Documentation

Index

• func GetChannelAssignmentInfoFromAttributes(attrs *Attributes) *types.StreamingNodeAssignment
• func GetServerID(attr *Attributes) *int64
• func GetSessionFromAttributes(attrs *Attributes) *sessionutil.SessionRaw
• func WithChannelAssignmentInfo(attr *Attributes, assignment *types.StreamingNodeAssignment) *attributes.Attributes
• func WithSession(attr *Attributes, val *sessionutil.SessionRaw) *attributes.Attributes
• type Attributes
  • func WithServerID(attr *Attributes, serverID int64) *Attributes

Functions

func GetChannelAssignmentInfoFromAttributes

func GetChannelAssignmentInfoFromAttributes(attrs *Attributes) *types.StreamingNodeAssignment

GetChannelAssignmentInfoFromAttributes get the channel info fetched from streamingcoord. Generated by the channel assignment discoverer and sent to channel assignment balancer.

func GetServerID

func GetServerID(attr *Attributes) *int64

GetServerID returns the serverID in the given Attributes.

func GetSessionFromAttributes

func GetSessionFromAttributes(attrs *Attributes) *sessionutil.SessionRaw

GetSessionFromAttributes get session from attributes.

func WithChannelAssignmentInfo

func WithChannelAssignmentInfo(attr *Attributes, assignment *types.StreamingNodeAssignment) *attributes.Attributes

WithChannelAssignmentInfo returns a new Attributes containing the given channelInfo.

func WithSession

func WithSession(attr *Attributes, val *sessionutil.SessionRaw) *attributes.Attributes

WithSession returns a new Attributes containing the given session.

Types

type Attributes

type Attributes = attributes.Attributes

func WithServerID

func WithServerID(attr *Attributes, serverID int64) *Attributes

WithServerID returns a new Attributes containing the given serverID.