Documentation ¶
Index ¶
- func MetadataDecoder(raw json.RawMessage) (getter.Getter, error)
- func NewProbe(g *graph.Graph, address string) (probe.Handler, error)
- func Register()
- type ACLMetadata
- func (obj *ACLMetadata) GetField(key string) (interface{}, error)
- func (obj *ACLMetadata) GetFieldBool(key string) (bool, error)
- func (obj *ACLMetadata) GetFieldInt64(key string) (int64, error)
- func (obj *ACLMetadata) GetFieldKeys() []string
- func (obj *ACLMetadata) GetFieldString(key string) (string, error)
- func (v ACLMetadata) MarshalEasyJSON(w *jwriter.Writer)
- func (v ACLMetadata) MarshalJSON() ([]byte, error)
- func (obj *ACLMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
- func (obj *ACLMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
- func (obj *ACLMetadata) MatchString(key string, predicate getter.StringPredicate) bool
- func (v *ACLMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *ACLMetadata) UnmarshalJSON(data []byte) error
- type LRPMetadata
- func (obj *LRPMetadata) GetField(key string) (interface{}, error)
- func (obj *LRPMetadata) GetFieldBool(key string) (bool, error)
- func (obj *LRPMetadata) GetFieldInt64(key string) (int64, error)
- func (obj *LRPMetadata) GetFieldKeys() []string
- func (obj *LRPMetadata) GetFieldString(key string) (string, error)
- func (v LRPMetadata) MarshalEasyJSON(w *jwriter.Writer)
- func (v LRPMetadata) MarshalJSON() ([]byte, error)
- func (obj *LRPMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
- func (obj *LRPMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
- func (obj *LRPMetadata) MatchString(key string, predicate getter.StringPredicate) bool
- func (v *LRPMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *LRPMetadata) UnmarshalJSON(data []byte) error
- type LSPMetadata
- func (obj *LSPMetadata) GetField(key string) (interface{}, error)
- func (obj *LSPMetadata) GetFieldBool(key string) (bool, error)
- func (obj *LSPMetadata) GetFieldInt64(key string) (int64, error)
- func (obj *LSPMetadata) GetFieldKeys() []string
- func (obj *LSPMetadata) GetFieldString(key string) (string, error)
- func (v LSPMetadata) MarshalEasyJSON(w *jwriter.Writer)
- func (v LSPMetadata) MarshalJSON() ([]byte, error)
- func (obj *LSPMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
- func (obj *LSPMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
- func (obj *LSPMetadata) MatchString(key string, predicate getter.StringPredicate) bool
- func (v *LSPMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *LSPMetadata) UnmarshalJSON(data []byte) error
- type Metadata
- func (obj *Metadata) GetField(key string) (interface{}, error)
- func (obj *Metadata) GetFieldBool(key string) (bool, error)
- func (obj *Metadata) GetFieldInt64(key string) (int64, error)
- func (obj *Metadata) GetFieldKeys() []string
- func (obj *Metadata) GetFieldString(key string) (string, error)
- func (v Metadata) MarshalEasyJSON(w *jwriter.Writer)
- func (v Metadata) MarshalJSON() ([]byte, error)
- func (obj *Metadata) MatchBool(key string, predicate getter.BoolPredicate) bool
- func (obj *Metadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
- func (obj *Metadata) MatchString(key string, predicate getter.StringPredicate) bool
- func (v *Metadata) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *Metadata) UnmarshalJSON(data []byte) error
- type Probe
- func (p *Probe) Do(ctx context.Context, wg *sync.WaitGroup) error
- func (p *Probe) OnACLCreate(acl *goovn.ACL)
- func (p *Probe) OnACLDelete(acl *goovn.ACL)
- func (p *Probe) OnDHCPOptionsCreate(*goovn.DHCPOptions)
- func (p *Probe) OnDHCPOptionsDelete(*goovn.DHCPOptions)
- func (p *Probe) OnDisconnected()
- func (p *Probe) OnError(err error)
- func (p *Probe) OnLoadBalancerCreate(*goovn.LoadBalancer)
- func (p *Probe) OnLoadBalancerDelete(*goovn.LoadBalancer)
- func (p *Probe) OnLogicalPortCreate(lp *goovn.LogicalSwitchPort)
- func (p *Probe) OnLogicalPortDelete(lp *goovn.LogicalSwitchPort)
- func (p *Probe) OnLogicalRouterCreate(ls *goovn.LogicalRouter)
- func (p *Probe) OnLogicalRouterDelete(ls *goovn.LogicalRouter)
- func (p *Probe) OnLogicalRouterPortCreate(lp *goovn.LogicalRouterPort)
- func (p *Probe) OnLogicalRouterPortDelete(lp *goovn.LogicalRouterPort)
- func (p *Probe) OnLogicalRouterStaticRouteCreate(lp *goovn.LogicalRouterStaticRoute)
- func (p *Probe) OnLogicalRouterStaticRouteDelete(lp *goovn.LogicalRouterStaticRoute)
- func (p *Probe) OnLogicalSwitchCreate(ls *goovn.LogicalSwitch)
- func (p *Probe) OnLogicalSwitchDelete(ls *goovn.LogicalSwitch)
- func (p *Probe) OnQoSCreate(*goovn.QoS)
- func (p *Probe) OnQoSDelete(*goovn.QoS)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MetadataDecoder ¶ added in v0.24.0
func MetadataDecoder(raw json.RawMessage) (getter.Getter, error)
MetadataDecoder implements a json message raw decoder
Types ¶
type ACLMetadata ¶ added in v0.24.0
type ACLMetadata struct { Action string `json:",omitempty"` Direction string `json:",omitempty"` Log bool `json:",omitempty"` Match string `json:",omitempty"` Priority int64 `json:",omitempty"` }
ACLMetadata describes the information of an OVN ACL easyjson:json gendecoder
func (*ACLMetadata) GetField ¶ added in v0.26.0
func (obj *ACLMetadata) GetField(key string) (interface{}, error)
func (*ACLMetadata) GetFieldBool ¶ added in v0.26.0
func (obj *ACLMetadata) GetFieldBool(key string) (bool, error)
func (*ACLMetadata) GetFieldInt64 ¶ added in v0.26.0
func (obj *ACLMetadata) GetFieldInt64(key string) (int64, error)
func (*ACLMetadata) GetFieldKeys ¶ added in v0.26.0
func (obj *ACLMetadata) GetFieldKeys() []string
func (*ACLMetadata) GetFieldString ¶ added in v0.26.0
func (obj *ACLMetadata) GetFieldString(key string) (string, error)
func (ACLMetadata) MarshalEasyJSON ¶ added in v0.26.0
func (v ACLMetadata) MarshalEasyJSON(w *jwriter.Writer)
MarshalEasyJSON supports easyjson.Marshaler interface
func (ACLMetadata) MarshalJSON ¶ added in v0.26.0
func (v ACLMetadata) MarshalJSON() ([]byte, error)
MarshalJSON supports json.Marshaler interface
func (*ACLMetadata) MatchBool ¶ added in v0.26.0
func (obj *ACLMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
func (*ACLMetadata) MatchInt64 ¶ added in v0.26.0
func (obj *ACLMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
func (*ACLMetadata) MatchString ¶ added in v0.26.0
func (obj *ACLMetadata) MatchString(key string, predicate getter.StringPredicate) bool
func (*ACLMetadata) UnmarshalEasyJSON ¶ added in v0.26.0
func (v *ACLMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*ACLMetadata) UnmarshalJSON ¶ added in v0.26.0
func (v *ACLMetadata) UnmarshalJSON(data []byte) error
UnmarshalJSON supports json.Unmarshaler interface
type LRPMetadata ¶ added in v0.24.0
type LRPMetadata struct { GatewayChassis []string `json:",omitempty"` IPv6RAConfigs graph.Metadata `json:",omitempty" field:"Metadata"` Networks []string `json:",omitempty"` Peer string `json:",omitempty"` }
LRPMetadata describes the information of an OVN logical router port easyjson:json gendecoder
func (*LRPMetadata) GetField ¶ added in v0.26.0
func (obj *LRPMetadata) GetField(key string) (interface{}, error)
func (*LRPMetadata) GetFieldBool ¶ added in v0.26.0
func (obj *LRPMetadata) GetFieldBool(key string) (bool, error)
func (*LRPMetadata) GetFieldInt64 ¶ added in v0.26.0
func (obj *LRPMetadata) GetFieldInt64(key string) (int64, error)
func (*LRPMetadata) GetFieldKeys ¶ added in v0.26.0
func (obj *LRPMetadata) GetFieldKeys() []string
func (*LRPMetadata) GetFieldString ¶ added in v0.26.0
func (obj *LRPMetadata) GetFieldString(key string) (string, error)
func (LRPMetadata) MarshalEasyJSON ¶ added in v0.26.0
func (v LRPMetadata) MarshalEasyJSON(w *jwriter.Writer)
MarshalEasyJSON supports easyjson.Marshaler interface
func (LRPMetadata) MarshalJSON ¶ added in v0.26.0
func (v LRPMetadata) MarshalJSON() ([]byte, error)
MarshalJSON supports json.Marshaler interface
func (*LRPMetadata) MatchBool ¶ added in v0.26.0
func (obj *LRPMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
func (*LRPMetadata) MatchInt64 ¶ added in v0.26.0
func (obj *LRPMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
func (*LRPMetadata) MatchString ¶ added in v0.26.0
func (obj *LRPMetadata) MatchString(key string, predicate getter.StringPredicate) bool
func (*LRPMetadata) UnmarshalEasyJSON ¶ added in v0.26.0
func (v *LRPMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*LRPMetadata) UnmarshalJSON ¶ added in v0.26.0
func (v *LRPMetadata) UnmarshalJSON(data []byte) error
UnmarshalJSON supports json.Unmarshaler interface
type LSPMetadata ¶ added in v0.24.0
type LSPMetadata struct { Addresses []string `json:",omitempty"` PortSecurity []string `json:",omitempty"` DHCPv4Options string `json:",omitempty"` DHCPv6Options string `json:",omitempty"` Type string `json:",omitempty"` }
LSPMetadata describes the information of an OVN logical router easyjson:json gendecoder
func (*LSPMetadata) GetField ¶ added in v0.26.0
func (obj *LSPMetadata) GetField(key string) (interface{}, error)
func (*LSPMetadata) GetFieldBool ¶ added in v0.26.0
func (obj *LSPMetadata) GetFieldBool(key string) (bool, error)
func (*LSPMetadata) GetFieldInt64 ¶ added in v0.26.0
func (obj *LSPMetadata) GetFieldInt64(key string) (int64, error)
func (*LSPMetadata) GetFieldKeys ¶ added in v0.26.0
func (obj *LSPMetadata) GetFieldKeys() []string
func (*LSPMetadata) GetFieldString ¶ added in v0.26.0
func (obj *LSPMetadata) GetFieldString(key string) (string, error)
func (LSPMetadata) MarshalEasyJSON ¶ added in v0.26.0
func (v LSPMetadata) MarshalEasyJSON(w *jwriter.Writer)
MarshalEasyJSON supports easyjson.Marshaler interface
func (LSPMetadata) MarshalJSON ¶ added in v0.26.0
func (v LSPMetadata) MarshalJSON() ([]byte, error)
MarshalJSON supports json.Marshaler interface
func (*LSPMetadata) MatchBool ¶ added in v0.26.0
func (obj *LSPMetadata) MatchBool(key string, predicate getter.BoolPredicate) bool
func (*LSPMetadata) MatchInt64 ¶ added in v0.26.0
func (obj *LSPMetadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
func (*LSPMetadata) MatchString ¶ added in v0.26.0
func (obj *LSPMetadata) MatchString(key string, predicate getter.StringPredicate) bool
func (*LSPMetadata) UnmarshalEasyJSON ¶ added in v0.26.0
func (v *LSPMetadata) UnmarshalEasyJSON(l *jlexer.Lexer)
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*LSPMetadata) UnmarshalJSON ¶ added in v0.26.0
func (v *LSPMetadata) UnmarshalJSON(data []byte) error
UnmarshalJSON supports json.Unmarshaler interface
type Metadata ¶ added in v0.24.0
type Metadata struct { LSPMetadata `json:",omitempty"` LRPMetadata `json:",omitempty"` ACLMetadata `json:",omitempty"` ExtID graph.Metadata `json:",omitempty" field:"Metadata"` Options graph.Metadata `json:",omitempty" field:"Metadata"` }
Metadata describes the information of an OVN object easyjson:json gendecoder
func (*Metadata) GetFieldBool ¶ added in v0.26.0
func (*Metadata) GetFieldInt64 ¶ added in v0.26.0
func (*Metadata) GetFieldKeys ¶ added in v0.26.0
func (*Metadata) GetFieldString ¶ added in v0.26.0
func (Metadata) MarshalEasyJSON ¶ added in v0.26.0
MarshalEasyJSON supports easyjson.Marshaler interface
func (Metadata) MarshalJSON ¶ added in v0.26.0
MarshalJSON supports json.Marshaler interface
func (*Metadata) MatchBool ¶ added in v0.26.0
func (obj *Metadata) MatchBool(key string, predicate getter.BoolPredicate) bool
func (*Metadata) MatchInt64 ¶ added in v0.26.0
func (obj *Metadata) MatchInt64(key string, predicate getter.Int64Predicate) bool
func (*Metadata) MatchString ¶ added in v0.26.0
func (obj *Metadata) MatchString(key string, predicate getter.StringPredicate) bool
func (*Metadata) UnmarshalEasyJSON ¶ added in v0.26.0
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*Metadata) UnmarshalJSON ¶ added in v0.26.0
UnmarshalJSON supports json.Unmarshaler interface
type Probe ¶
type Probe struct { graph.ListenerHandler // contains filtered or unexported fields }
Probe describes an OVN probe
func (*Probe) OnACLCreate ¶
OnACLCreate is called when an ACL is created
func (*Probe) OnACLDelete ¶
OnACLDelete is called when an ACL is deleted
func (*Probe) OnDHCPOptionsCreate ¶
func (p *Probe) OnDHCPOptionsCreate(*goovn.DHCPOptions)
OnDHCPOptionsCreate is called when DHCP options are created
func (*Probe) OnDHCPOptionsDelete ¶
func (p *Probe) OnDHCPOptionsDelete(*goovn.DHCPOptions)
OnDHCPOptionsDelete is called when DHCP options are deleted
func (*Probe) OnDisconnected ¶ added in v0.25.0
func (p *Probe) OnDisconnected()
OnDisconnected is called when the connection to OVSDB is lost
func (*Probe) OnLoadBalancerCreate ¶
func (p *Probe) OnLoadBalancerCreate(*goovn.LoadBalancer)
OnLoadBalancerCreate is called when DHCP options are created
func (*Probe) OnLoadBalancerDelete ¶
func (p *Probe) OnLoadBalancerDelete(*goovn.LoadBalancer)
OnLoadBalancerDelete is called when DHCP options are deleted
func (*Probe) OnLogicalPortCreate ¶
func (p *Probe) OnLogicalPortCreate(lp *goovn.LogicalSwitchPort)
OnLogicalPortCreate is called when a logical port is created on a switch
func (*Probe) OnLogicalPortDelete ¶
func (p *Probe) OnLogicalPortDelete(lp *goovn.LogicalSwitchPort)
OnLogicalPortDelete is called when a logical is deleted from a switch
func (*Probe) OnLogicalRouterCreate ¶
func (p *Probe) OnLogicalRouterCreate(ls *goovn.LogicalRouter)
OnLogicalRouterCreate is called when a logical router is created
func (*Probe) OnLogicalRouterDelete ¶
func (p *Probe) OnLogicalRouterDelete(ls *goovn.LogicalRouter)
OnLogicalRouterDelete is called when a logical router is deleted
func (*Probe) OnLogicalRouterPortCreate ¶
func (p *Probe) OnLogicalRouterPortCreate(lp *goovn.LogicalRouterPort)
OnLogicalRouterPortCreate is called when a logical port is created on a router
func (*Probe) OnLogicalRouterPortDelete ¶
func (p *Probe) OnLogicalRouterPortDelete(lp *goovn.LogicalRouterPort)
OnLogicalRouterPortDelete is called when a logical port is removed from a router
func (*Probe) OnLogicalRouterStaticRouteCreate ¶ added in v0.25.0
func (p *Probe) OnLogicalRouterStaticRouteCreate(lp *goovn.LogicalRouterStaticRoute)
OnLogicalRouterStaticRouteCreate is called when a static route is added to a router
func (*Probe) OnLogicalRouterStaticRouteDelete ¶ added in v0.25.0
func (p *Probe) OnLogicalRouterStaticRouteDelete(lp *goovn.LogicalRouterStaticRoute)
OnLogicalRouterStaticRouteDelete is called when a static route is removed from a router
func (*Probe) OnLogicalSwitchCreate ¶
func (p *Probe) OnLogicalSwitchCreate(ls *goovn.LogicalSwitch)
OnLogicalSwitchCreate is called when a logical switch is created
func (*Probe) OnLogicalSwitchDelete ¶
func (p *Probe) OnLogicalSwitchDelete(ls *goovn.LogicalSwitch)
OnLogicalSwitchDelete is called when a logical switch is deleted
func (*Probe) OnQoSCreate ¶
OnQoSCreate is called when QoS is created
func (*Probe) OnQoSDelete ¶
OnQoSDelete is called when QoS is deleted