lane

Documentation

Index

• type Lane
  • func DefaultLane() *Lane
  • func New(cfg config.Source) (lane *Lane)
  • func (l *Lane) GetLaneID(ctx context.Context) string
  • func (l *Lane) Select(ctx context.Context, svc naming.Service, nodes []naming.Instance) []naming.Instance
• type LaneGroup
• type LaneInfo
• type LaneRule
• type TagRule

Types

type Lane

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

func DefaultLane

func DefaultLane() *Lane

func New

func New(cfg config.Source) (lane *Lane)

func (*Lane) GetLaneID

func (l *Lane) GetLaneID(ctx context.Context) string

func (*Lane) Select

func (l *Lane) Select(ctx context.Context, svc naming.Service, nodes []naming.Instance) []naming.Instance

type LaneGroup

type LaneGroup struct {
	ApplicationID   string `yaml:"applicationId"`
	ApplicationName string `yaml:"applicationName"`
	ClusterType     string `yaml:"clusterType"`
	Entrance        bool   `yaml:"entrance"`
	GroupID         string `yaml:"groupId"`
	NamespaceID     string `yaml:"namespaceId"`
	GroupName       string `yaml:"groupName"`
}

type LaneInfo

type LaneInfo struct {
	ID         string      `yaml:"laneId"`
	Name       string      `yaml:"laneName"`
	GroupList  []LaneGroup `yaml:"laneGroupList"`
	CreateTime time.Time   `yaml:"createTime"`
}

type LaneRule

type LaneRule struct {
	ID           string    `yaml:"ruleId"` //本身LaneRule的ID
	Name         string    `yaml:"ruleName"`
	Enable       bool      `yaml:"enable"`
	LaneID       string    `yaml:"laneId"` //对于的泳道信息的ID，不是LaneRuleID
	Priority     int64     `yaml:"priority"`
	TagList      []TagRule `yaml:"ruleTagList"`
	Relationship string    `yaml:"ruleTagRelationship"`
	CreateTime   time.Time `yaml:"createTime"`
}

type TagRule

type TagRule struct {
	ID       string `yaml:"tagId"` //本身tag的ID
	Name     string `yaml:"tagName"`
	Operator string `yaml:"tagOperator"`
	Value    string `yaml:"tagValue"`
}