func()

in plugins/rocketmq/instrument.go [49:95]

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

func (i *Instrument) Points() []*instrument.Point {
	return []*instrument.Point{
		{
			PackagePath: "producer",
			At: instrument.NewMethodEnhance("*defaultProducer", "SendSync",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "...*primitive.Message"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "*primitive.SendResult"),
				instrument.WithResultType(1, "error")),
			Interceptor: "SendSyncInterceptor",
		},
		{
			PackagePath: "producer",
			At: instrument.NewMethodEnhance("*defaultProducer", "SendAsync",
				instrument.WithArgsCount(3),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "func(context.Context, *primitive.SendResult, error)"),
				instrument.WithArgType(2, "...*primitive.Message"),
				instrument.WithResultCount(1),
				instrument.WithResultType(0, "error")),
			Interceptor: "SendASyncInterceptor",
		},
		{
			PackagePath: "producer",
			At: instrument.NewMethodEnhance("*defaultProducer", "SendOneWay",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "msgs ...*primitive.Message"),
				instrument.WithResultCount(1),
				instrument.WithResultType(0, "error")),
			Interceptor: "SendOneWayInterceptor",
		},
		{
			PackagePath: "consumer",
			At: instrument.NewMethodEnhance("*pushConsumer", "consumeInner",
				instrument.WithArgsCount(2),
				instrument.WithArgType(0, "context.Context"),
				instrument.WithArgType(1, "[]*primitive.MessageExt"),
				instrument.WithResultCount(2),
				instrument.WithResultType(0, "ConsumeResult"),
				instrument.WithResultType(1, "error")),
			Interceptor: "SwConsumerInterceptor",
		},
	}
}