Documentation ¶
Overview ¶
Package handler is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicBackendConfiguration ¶ added in v1.4.0
type DynamicBackendConfiguration struct { // Name of the backend. Name string `yaml:"name"` // Hashing function type. HashType sharding.HashType `yaml:"hashType"` // Producer configs the m3msg producer. Producer config.ProducerConfiguration `yaml:"producer"` // Filters configs the filter for consumer services. Filters []consumerServiceFilterConfiguration `yaml:"filters"` // Filters configs the filter for consumer services. StoragePolicyFilters []storagePolicyFilterConfiguration `yaml:"storagePolicyFilters"` // Writer configs the writer options. Writer writerConfiguration `yaml:"writer"` }
DynamicBackendConfiguration configures a dynamic backend as a flush handler.
type FlushConfiguration ¶ added in v1.4.0
type FlushConfiguration struct {
Handlers []FlushHandlerConfiguration `yaml:"handlers" validate:"nonzero"`
}
FlushConfiguration configures flush handlers.
func (FlushConfiguration) NewHandler ¶ added in v1.4.0
func (c FlushConfiguration) NewHandler( cs client.Client, instrumentOpts instrument.Options, rwOpts xio.Options, ) (Handler, error)
NewHandler creates a new flush handler based on the configuration.
type FlushHandlerConfiguration ¶
type FlushHandlerConfiguration struct { // StaticBackend configures the backend. StaticBackend *StaticBackendConfiguration `yaml:"staticBackend"` // DynamicBackend configures the dynamic backend. DynamicBackend *DynamicBackendConfiguration `yaml:"dynamicBackend"` }
FlushHandlerConfiguration contains configuration for individual flush handlers.
func (FlushHandlerConfiguration) Validate ¶ added in v1.4.0
func (c FlushHandlerConfiguration) Validate() error
Validate validates the FlushHandlerConfiguration.
type Handler ¶
type Handler interface { // NewWriter creates a new writer for writing aggregated metrics and policies. NewWriter(scope tally.Scope) (writer.Writer, error) // Close closes the handler. Close() }
Handler handles aggregated metrics alongside their policies.
func NewBlackholeHandler ¶
func NewBlackholeHandler() Handler
NewBlackholeHandler creates a new blackhole handler.
func NewBroadcastHandler ¶
NewBroadcastHandler creates a new Handler that broadcasts incoming data to a list of handlers.
func NewLoggingHandler ¶
NewLoggingHandler creates a new logging handler.
type MockHandler ¶
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface.
func NewMockHandler ¶
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance.
func (*MockHandler) EXPECT ¶
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockHandlerMockRecorder ¶
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler.
func (*MockHandlerMockRecorder) Close ¶
func (mr *MockHandlerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockHandlerMockRecorder) NewWriter ¶
func (mr *MockHandlerMockRecorder) NewWriter(arg0 interface{}) *gomock.Call
NewWriter indicates an expected call of NewWriter.
type StaticBackendConfiguration ¶ added in v1.4.0
type StaticBackendConfiguration struct { // Static backend type. Type Type `yaml:"type"` // Name of the backend. Name string `yaml:"name"` }
StaticBackendConfiguration configures a static backend as a flush handler.