azureeventgrid

type AdvancedFilter struct {
	Value        any    `json:"value,omitempty"`
	OperatorType string `json:"operatorType"`
	Key          string `json:"key,omitempty"`
	Values       []any  `json:"values,omitempty"`
}

type ConfigProvider interface {
	GetAzureEventGridSettings() Settings
}

type Destination struct {
	Properties   map[string]any `json:"properties,omitempty"`
	EndpointType string         `json:"endpointType"`
}

type DomainInfo struct {
	CreatedAt   time.Time
	Name        string
	ResourceID  string
	InputSchema string
	AutoCreate  bool
	AutoDelete  bool
}

type DomainTopicInfo struct {
	CreatedAt time.Time
	Name      string
}

type Event struct {
	Fields map[string]any
	ID     string
	Raw    json.RawMessage
}

type Filter struct {
	SubjectBeginsWith               string           `json:"subjectBeginsWith"`
	SubjectEndsWith                 string           `json:"subjectEndsWith"`
	IncludedEventTypes              []string         `json:"includedEventTypes,omitempty"`
	AdvancedFilters                 []AdvancedFilter `json:"advancedFilters,omitempty"`
	IsSubjectCaseSensitive          bool             `json:"isSubjectCaseSensitive"`
	EnableAdvancedFilteringOnArrays bool             `json:"enableAdvancedFilteringOnArrays,omitempty"`
}

type Handler struct {
	Backend *InMemoryBackend

	Settings Settings
	Port     int
	// contains filtered or unexported fields
}

type InMemoryBackend struct {
	// contains filtered or unexported fields
}

type Keys struct {
	Key1 string
	Key2 string
}

type LockFailure struct {
	LockToken string
	Code      string
	Message   string
}

type Message struct {
	ID          string
	Subject     string
	ContentType string
	Body        []byte
}

type Provider struct{}

type Publisher struct {
	Name   string
	Domain bool
}

type Received struct {
	LockToken     string
	Event         json.RawMessage
	DeliveryCount int
}

type ResourceEvent struct {
	Time            time.Time
	Claims          map[string]any
	EventType       string
	SubscriptionID  string
	ResourceGroup   string
	ResourceURI     string
	Provider        string
	OperationName   string
	CorrelationID   string
	TenantID        string
	HTTPMethod      string
	HTTPURL         string
	ClientRequestID string
	ClientIP        string
}

type RetryPolicy struct {
	MaxDeliveryAttempts      int `json:"maxDeliveryAttempts"`
	EventTimeToLiveInMinutes int `json:"eventTimeToLiveInMinutes"`
}

type Scope struct {
	Domain   string
	Topic    string
	Resource string
}

type Settings struct {
	TLSCertFile string `` //nolint:lll // config struct tags are intentionally verbose
	/* 236-byte string literal not displayed */
	TLSKeyFile string `` //nolint:lll // config struct tags are intentionally verbose
	/* 138-byte string literal not displayed */
	Advertise string `` //nolint:lll // config struct tags are intentionally verbose
	/* 184-byte string literal not displayed */
	Port int `` //nolint:lll // config struct tags are intentionally verbose
	/* 252-byte string literal not displayed */
	ValidateSAS bool `` //nolint:lll // config struct tags are intentionally verbose
	/* 252-byte string literal not displayed */
}

type Spec struct {
	DeadLetterDestination *Destination `json:"deadLetterDestination,omitempty"`
	ExpirationTimeUTC     string       `json:"expirationTimeUtc,omitempty"`
	EventDeliverySchema   string       `json:"eventDeliverySchema,omitempty"`
	Destination           Destination  `json:"destination"`
	Labels                []string     `json:"labels,omitempty"`
	Filter                Filter       `json:"filter"`
	RetryPolicy           RetryPolicy  `json:"retryPolicy"`
}

type Targets interface {
	SendServiceBus(queue, topic string, m Message) error
	SendEventHub(namespace, hub string, m Message) error
	SendStorageQueue(account, queue, text string, ttl time.Duration) error
	PutBlob(account, container, blob string, data []byte, contentType string) error
}

type TopicInfo struct {
	CreatedAt   time.Time
	Name        string
	ResourceID  string
	InputSchema string
}