Function WithMetadataFilter

consumer.go:252–261

(filter *MetadataFilter)

// MetadataFilter is a filter for metadata. Right now support only direct matching of key/value
type (
	MetadataOperation string

	MetadataFilter struct {
		Key       string
		Operation MetadataOperation
		Value     string
	}
)

const (
	OpEqual    MetadataOperation = "="
	OpNotEqual MetadataOperation = "<>"