func()

in plugins/amqp/instrument.go [48:119]

• 72 lines of code
• 1 McCabe index (conditional complexity)

func (i *Instrument) Points() []*instrument.Point {
	return []*instrument.Point{
		{
			PackagePath: "",
			PackageName: "amqp091",
			At: instrument.NewMethodEnhance("*Channel", "PublishWithDeferredConfirmWithContext",
				instrument.WithArgsCount(6),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "string"),
				instrument.WithArgType(2, "string"),
				instrument.WithArgType(5, "Publishing"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "*DeferredConfirmation"),
				instrument.WithResultType(1, "error"),
			),
			Interceptor: "ProducerInterceptor",
		},
		{
			PackagePath: "",
			PackageName: "amqp091",
			At: instrument.NewMethodEnhance("*consumers", "send",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "string"),
				instrument.WithArgType(1, "*Delivery"),
				instrument.WithResultCount(1),
				instrument.WithResultType(0, "bool"),
			),
			Interceptor: "ConsumersSendInterceptor",
		},
		{
			PackagePath: "",
			PackageName: "amqp091",
			At: instrument.NewMethodEnhance("*consumers", "close",
				instrument.WithArgsCount(0),
				instrument.WithResultCount(0),
			),
			Interceptor: "ConsumersCloseInterceptor",
		},
		{
			PackagePath: "",
			PackageName: "amqp091",
			At: instrument.NewMethodEnhance("*Channel", "Consume",
				instrument.WithArgsCount(7),
				instrument.WithArgType(0, "string"),
				instrument.WithArgType(1, "string"),
				instrument.WithArgType(6, "Table"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "<-chan Delivery"),
				instrument.WithResultType(1, "error"),
			),
			Interceptor: "ConsumerInterceptor",
		},
		{
			PackagePath: "",
			PackageName: "amqp091",
			At: instrument.NewStaticMethodEnhance("DialConfig",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "string"),
				instrument.WithArgType(1, "Config"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "*Connection"),
				instrument.WithResultType(1, "error"),
			),
			Interceptor: "DialInterceptor",
		},
		{
			PackagePath: "",
			PackageName: "amqp091",
			At:          instrument.NewStructEnhance("Connection"),
		},
	}
}