pilot

Documentation

Index

• Constants
• Variables
• func GetEgressRule() map[string][]*config.EgressRule
• func InitPilotFetcher(o egress.Options) error
• func SetEgressRule(rule map[string][]*config.EgressRule)
• type PilotEgress
  • func (r *PilotEgress) FetchEgressRule() map[string][]*config.EgressRule
  • func (r *PilotEgress) Init(o egress.Options) error
  • func (r *PilotEgress) SetEgressRule(rr map[string][]*config.EgressRule)

Constants

const OUTBOUND = "outbound"

OUTBOUND outbound

Variables

var DefaultPilotRefresh = 10 * time.Second

DefaultPilotRefresh is default pilot refresh time TODO: use stream instead

Functions

func GetEgressRule

func GetEgressRule() map[string][]*config.EgressRule

GetEgressRule get egress rule

func InitPilotFetcher

func InitPilotFetcher(o egress.Options) error

InitPilotFetcher init the config mgr and add several sources

func SetEgressRule

func SetEgressRule(rule map[string][]*config.EgressRule)

SetEgressRule set egress rule

Types

type PilotEgress

type PilotEgress struct{}

PilotEgress is pilot egress service

func (*PilotEgress) FetchEgressRule

func (r *PilotEgress) FetchEgressRule() map[string][]*config.EgressRule

FetchEgressRule return all rules

func (*PilotEgress) Init

func (r *PilotEgress) Init(o egress.Options) error

Init init egress config

func (*PilotEgress) SetEgressRule

func (r *PilotEgress) SetEgressRule(rr map[string][]*config.EgressRule)

SetEgressRule set rules