func()

in plugins/pulsar/instrument.go [49:86]

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

func (i *Instrument) Points() []*instrument.Point {
	return []*instrument.Point{
		{
			PackagePath: "pulsar",
			At: instrument.NewMethodEnhance("*partitionProducer", "Send",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "*ProducerMessage"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "MessageID"),
				instrument.WithResultType(1, "error"),
			),
			Interceptor: "SendInterceptor",
		},
		{
			PackagePath: "pulsar",
			At: instrument.NewMethodEnhance("*partitionProducer", "SendAsync",
				instrument.WithArgsCount(3),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "*ProducerMessage"),
				instrument.WithArgType(2, "func(MessageID, *ProducerMessage, error)"),
				instrument.WithResultCount(0),
			),
			Interceptor: "SendAsyncInterceptor",
		},
		{
			PackagePath: "pulsar",
			At: instrument.NewMethodEnhance("*consumer", "Receive",
				instrument.WithArgsCount(1),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "Message"),
				instrument.WithResultType(1, "error"),
			),
			Interceptor: "ReceiveInterceptor",
		},
	}
}