Versions in this module Expand all Collapse all v1 v1.6.0 Sep 25, 2026 Changes in this version + type MockPolicyConfig struct + func NewMockPolicyConfig(ctrl *gomock.Controller) *MockPolicyConfig + func (m *MockPolicyConfig) EXPECT() *MockPolicyConfigMockRecorder + func (m *MockPolicyConfig) TrafficTypes() map[string]uint64 + type MockPolicyConfigMockRecorder struct + func (mr *MockPolicyConfigMockRecorder) TrafficTypes() *gomock.Call + type MockPolicyHandler struct + func NewMockPolicyHandler(ctrl *gomock.Controller) *MockPolicyHandler + func (m *MockPolicyHandler) Close() + func (m *MockPolicyHandler) EXPECT() *MockPolicyHandlerMockRecorder + func (m *MockPolicyHandler) GetTrafficTypes() map[string]uint64 + func (m *MockPolicyHandler) Subscribe(arg0 PolicyUpdateListener) int + func (m *MockPolicyHandler) Unsubscribe(arg0 int) + type MockPolicyHandlerMockRecorder struct + func (mr *MockPolicyHandlerMockRecorder) Close() *gomock.Call + func (mr *MockPolicyHandlerMockRecorder) GetTrafficTypes() *gomock.Call + func (mr *MockPolicyHandlerMockRecorder) Subscribe(arg0 interface{}) *gomock.Call + func (mr *MockPolicyHandlerMockRecorder) Unsubscribe(arg0 interface{}) *gomock.Call + type PolicyConfig interface + TrafficTypes func() map[string]uint64 + func NewPolicyConfig(trafficTypes map[string]uint64) PolicyConfig + func NewPolicyConfigFromValue(v kv.Value) (PolicyConfig, error) + type PolicyHandler interface + Close func() + GetTrafficTypes func() map[string]uint64 + Subscribe func(listener PolicyUpdateListener) int + Unsubscribe func(id int) + func NewRoutingPolicyHandler(opts PolicyHandlerOptions) (PolicyHandler, error) + type PolicyHandlerOptions interface + KVClient func() client.Client + KVKey func() string + KVOverrideOptions func() kv.OverrideOptions + Validate func() error + WithKVClient func(kvClient client.Client) PolicyHandlerOptions + WithKVKey func(kvKey string) PolicyHandlerOptions + WithKVOverrideOptions func(kvOverrideOptions kv.OverrideOptions) PolicyHandlerOptions + func NewPolicyHandlerOptions() PolicyHandlerOptions + type PolicyUpdateListener func(PolicyConfig)
Go to main page