remoteconfighandler

Documentation

Overview

Package remoteconfighandler holds the logic responsible for updating the samplers when the remote configuration changes.

Index

• type MockRemoteClient
  • func NewMockRemoteClient(ctrl *gomock.Controller) *MockRemoteClient
  • func (m *MockRemoteClient) Close()
  • func (m *MockRemoteClient) EXPECT() *MockRemoteClientMockRecorder
  • func (m *MockRemoteClient) Start()
  • func (m *MockRemoteClient) Subscribe(arg0 string, ...)
  • func (m *MockRemoteClient) UpdateApplyStatus(cfgPath string, status state.ApplyStatus)
• type MockRemoteClientMockRecorder
  • func (mr *MockRemoteClientMockRecorder) Close() *gomock.Call
  • func (mr *MockRemoteClientMockRecorder) Start() *gomock.Call
  • func (mr *MockRemoteClientMockRecorder) Subscribe(arg0 interface{}, arg1 interface{}) *gomock.Call
  • func (mr *MockRemoteClientMockRecorder) UpdateApplyStatus(arg0 interface{}, arg1 interface{}) *gomock.Call
• type MockerrorsSampler
  • func NewMockerrorsSampler(ctrl *gomock.Controller) *MockerrorsSampler
  • func (m *MockerrorsSampler) EXPECT() *MockerrorsSamplerMockRecorder
  • func (m *MockerrorsSampler) UpdateTargetTPS(targetTPS float64)
• type MockerrorsSamplerMockRecorder
  • func (mr *MockerrorsSamplerMockRecorder) UpdateTargetTPS(targetTPS interface{}) *gomock.Call
• type MockprioritySampler
  • func NewMockprioritySampler(ctrl *gomock.Controller) *MockprioritySampler
  • func (m *MockprioritySampler) EXPECT() *MockprioritySamplerMockRecorder
  • func (m *MockprioritySampler) UpdateTargetTPS(targetTPS float64)
• type MockprioritySamplerMockRecorder
  • func (mr *MockprioritySamplerMockRecorder) UpdateTargetTPS(targetTPS interface{}) *gomock.Call
• type MockrareSampler
  • func NewMockrareSampler(ctrl *gomock.Controller) *MockrareSampler
  • func (m *MockrareSampler) EXPECT() *MockrareSamplerMockRecorder
  • func (m *MockrareSampler) SetEnabled(enabled bool)
• type MockrareSamplerMockRecorder
  • func (mr *MockrareSamplerMockRecorder) SetEnabled(enabled interface{}) *gomock.Call
• type RemoteConfigHandler
  • func New(conf *config.AgentConfig, prioritySampler prioritySampler, ...) *RemoteConfigHandler
  • func (h *RemoteConfigHandler) Start()

Types

type MockRemoteClient

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

MockRemoteClient is a mock of RemoteClient interface.

func NewMockRemoteClient

func NewMockRemoteClient(ctrl *gomock.Controller) *MockRemoteClient

NewMockRemoteClient creates a new mock instance.

func (*MockRemoteClient) Close

func (m *MockRemoteClient) Close()

Close mocks base method.

func (*MockRemoteClient) EXPECT

func (m *MockRemoteClient) EXPECT() *MockRemoteClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRemoteClient) Start

func (m *MockRemoteClient) Start()

Start mocks base method.

func (*MockRemoteClient) Subscribe

func (m *MockRemoteClient) Subscribe(arg0 string, arg1 func(map[string]state.RawConfig, func(string, state.ApplyStatus)))

Subscribe mocks base method.

func (*MockRemoteClient) UpdateApplyStatus

func (m *MockRemoteClient) UpdateApplyStatus(cfgPath string, status state.ApplyStatus)

UpdateApplyStatus mocks base method

type MockRemoteClientMockRecorder

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

MockRemoteClientMockRecorder is the mock recorder for MockRemoteClient.

func (*MockRemoteClientMockRecorder) Close

func (mr *MockRemoteClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockRemoteClientMockRecorder) Start

func (mr *MockRemoteClientMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockRemoteClientMockRecorder) Subscribe

func (mr *MockRemoteClientMockRecorder) Subscribe(arg0 interface{}, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockRemoteClientMockRecorder) UpdateApplyStatus

func (mr *MockRemoteClientMockRecorder) UpdateApplyStatus(arg0 interface{}, arg1 interface{}) *gomock.Call

UpdateApplyStatus mocks base method

type MockerrorsSampler

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

MockerrorsSampler is a mock of errorsSampler interface.

func NewMockerrorsSampler

func NewMockerrorsSampler(ctrl *gomock.Controller) *MockerrorsSampler

NewMockerrorsSampler creates a new mock instance.

func (*MockerrorsSampler) EXPECT

func (m *MockerrorsSampler) EXPECT() *MockerrorsSamplerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockerrorsSampler) UpdateTargetTPS

func (m *MockerrorsSampler) UpdateTargetTPS(targetTPS float64)

UpdateTargetTPS mocks base method.

type MockerrorsSamplerMockRecorder

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

MockerrorsSamplerMockRecorder is the mock recorder for MockerrorsSampler.

func (*MockerrorsSamplerMockRecorder) UpdateTargetTPS

func (mr *MockerrorsSamplerMockRecorder) UpdateTargetTPS(targetTPS interface{}) *gomock.Call

UpdateTargetTPS indicates an expected call of UpdateTargetTPS.

type MockprioritySampler

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

MockprioritySampler is a mock of prioritySampler interface.

func NewMockprioritySampler

func NewMockprioritySampler(ctrl *gomock.Controller) *MockprioritySampler

NewMockprioritySampler creates a new mock instance.

func (*MockprioritySampler) EXPECT

func (m *MockprioritySampler) EXPECT() *MockprioritySamplerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockprioritySampler) UpdateTargetTPS

func (m *MockprioritySampler) UpdateTargetTPS(targetTPS float64)

UpdateTargetTPS mocks base method.

type MockprioritySamplerMockRecorder

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

MockprioritySamplerMockRecorder is the mock recorder for MockprioritySampler.

func (*MockprioritySamplerMockRecorder) UpdateTargetTPS

func (mr *MockprioritySamplerMockRecorder) UpdateTargetTPS(targetTPS interface{}) *gomock.Call

UpdateTargetTPS indicates an expected call of UpdateTargetTPS.

type MockrareSampler

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

MockrareSampler is a mock of rareSampler interface.

func NewMockrareSampler

func NewMockrareSampler(ctrl *gomock.Controller) *MockrareSampler

NewMockrareSampler creates a new mock instance.

func (*MockrareSampler) EXPECT

func (m *MockrareSampler) EXPECT() *MockrareSamplerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockrareSampler) SetEnabled

func (m *MockrareSampler) SetEnabled(enabled bool)

SetEnabled mocks base method.

type MockrareSamplerMockRecorder

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

MockrareSamplerMockRecorder is the mock recorder for MockrareSampler.

func (*MockrareSamplerMockRecorder) SetEnabled

func (mr *MockrareSamplerMockRecorder) SetEnabled(enabled interface{}) *gomock.Call

SetEnabled indicates an expected call of SetEnabled.

type RemoteConfigHandler

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

RemoteConfigHandler holds pointers to samplers that need to be updated when APM remote config changes

func New

func New(conf *config.AgentConfig, prioritySampler prioritySampler, rareSampler rareSampler, errorsSampler errorsSampler) *RemoteConfigHandler

New creates a new RemoteConfigHandler

func (*RemoteConfigHandler) Start

func (h *RemoteConfigHandler) Start()

Start starts the remote config handler