wrapper

Documentation

Index

• Variables
• func NewCallWrapper(opts ...Option) client.CallWrapper
• func NewClientWrapper(opts ...Option) client.Wrapper
• func NewHandlerWrapper(opts ...Option) server.HandlerWrapper
• func NewSubscriberWrapper(opts ...Option) server.SubscriberWrapper
• type Option
  • func Meter(m meter.Meter) Option
  • func ServiceID(id string) Option
  • func ServiceName(name string) Option
  • func ServiceVersion(version string) Option
  • func SkipEndoints(eps ...string) Option
• type Options
  • func NewOptions(opts ...Option) Options

Variables

var (
	ClientRequestDurationSeconds     = "client_request_duration_seconds"
	ClientRequestLatencyMicroseconds = "client_request_latency_microseconds"
	ClientRequestTotal               = "client_request_total"
	ClientRequestInflight            = "client_request_inflight"

	ServerRequestDurationSeconds     = "server_request_duration_seconds"
	ServerRequestLatencyMicroseconds = "server_request_latency_microseconds"
	ServerRequestTotal               = "server_request_total"
	ServerRequestInflight            = "server_request_inflight"

	PublishMessageDurationSeconds     = "publish_message_duration_seconds"
	PublishMessageLatencyMicroseconds = "publish_message_latency_microseconds"
	PublishMessageTotal               = "publish_message_total"
	PublishMessageInflight            = "publish_message_inflight"

	SubscribeMessageDurationSeconds     = "subscribe_message_duration_seconds"
	SubscribeMessageLatencyMicroseconds = "subscribe_message_latency_microseconds"
	SubscribeMessageTotal               = "subscribe_message_total"
	SubscribeMessageInflight            = "subscribe_message_inflight"

	// DefaultSkipEndpoints contains list of endpoints that not evaluted by wrapper
	DefaultSkipEndpoints = []string{"Meter.Metrics"}
)

Functions

func NewCallWrapper

func NewCallWrapper(opts ...Option) client.CallWrapper

func NewClientWrapper

func NewClientWrapper(opts ...Option) client.Wrapper

func NewHandlerWrapper

func NewHandlerWrapper(opts ...Option) server.HandlerWrapper

func NewSubscriberWrapper

func NewSubscriberWrapper(opts ...Option) server.SubscriberWrapper

Types

type Option

type Option func(*Options)

func Meter

func Meter(m meter.Meter) Option

func ServiceID

func ServiceID(id string) Option

func ServiceName

func ServiceName(name string) Option

func ServiceVersion

func ServiceVersion(version string) Option

func SkipEndoints

func SkipEndoints(eps ...string) Option

type Options

type Options struct {
	Meter meter.Meter

	SkipEndpoints []string
	// contains filtered or unexported fields
}

func NewOptions

func NewOptions(opts ...Option) Options