model

Documentation

Index

• type MessageWriter
  • func NewMessagesWriterLoggingMiddleware(mw MessageWriter, log *slog.Logger) MessageWriter

Types

type MessageWriter

type MessageWriter interface {
	io.Closer
	fmt.Stringer

	Write(ctx context.Context, msg *pb.CloudEvent) (err error)

	// WriteBatch writes the specified messages and returns the accepted count preserving the order.
	// Returns io.EOF if the destination file/connection/whatever is closed.
	WriteBatch(ctx context.Context, msgs []*pb.CloudEvent) (ackCount uint32, err error)
}

func NewMessagesWriterLoggingMiddleware

func NewMessagesWriterLoggingMiddleware(mw MessageWriter, log *slog.Logger) MessageWriter