@@ -150,16 +150,16 @@ func TestProduceRaw(t *testing.T) {
150
150
}
151
151
}
152
152
153
- // This PanicProducer replaces the ProtoProducer, to simulate it producing a panic
154
- type PanicProducer struct {}
153
+ // This panicProducer replaces the ProtoProducer, to simulate it producing a panic
154
+ type panicProducer struct {}
155
155
156
- func (m * PanicProducer ) Produce (_ any , _ * producer.ProduceArgs ) ([]producer.ProducerMessage , error ) {
156
+ func (m * panicProducer ) Produce (_ any , _ * producer.ProduceArgs ) ([]producer.ProducerMessage , error ) {
157
157
panic ("producer panic!" )
158
158
}
159
159
160
- func (m * PanicProducer ) Close () {}
160
+ func (m * panicProducer ) Close () {}
161
161
162
- func (m * PanicProducer ) Commit (_ []producer.ProducerMessage ) {}
162
+ func (m * panicProducer ) Commit (_ []producer.ProducerMessage ) {}
163
163
164
164
func TestProducerPanic (t * testing.T ) {
165
165
// Create a mock logger that can capture logged messages
@@ -169,8 +169,8 @@ func TestProducerPanic(t *testing.T) {
169
169
// Create a mock consumer
170
170
mockConsumer := consumertest .NewNop ()
171
171
172
- // Wrap a PanicProducer (instead of ProtoProducer) in the OtelLogsProducerWrapper
173
- wrapper := newOtelLogsProducer (& PanicProducer {}, mockConsumer , logger , false )
172
+ // Wrap a panicProducer (instead of ProtoProducer) in the OtelLogsProducerWrapper
173
+ wrapper := newOtelLogsProducer (& panicProducer {}, mockConsumer , logger , false )
174
174
175
175
// Call Produce which should recover from panic
176
176
messages , err := wrapper .Produce (nil , & producer.ProduceArgs {
0 commit comments