internal

type CloudEvent struct {
	SpecVersion     string          `json:"specversion"`
	ID              string          `json:"id"`
	Time            string          `json:"time"`
	Source          string          `json:"source"`
	Subject         string          `json:"subject"`
	Type            string          `json:"type"`
	DataContentType string          `json:"datacontenttype"`
	Data            json.RawMessage `json:"data"`
	Hash            string          `json:"hash"`
	PredecessorHash string          `json:"predecessorhash"`
	TraceParent     *string         `json:"traceparent"`
	TraceState      *string         `json:"tracestate"`
	Signature       *string         `json:"signature"`
}

type Error struct {
	Error string `json:"error"`
}

type Line struct {
	Type    string
	Payload json.RawMessage
}

type StreamEventType struct {
	EventType string          `json:"eventType"`
	IsPhantom bool            `json:"isPhantom"`
	Schema    *map[string]any `json:"schema,omitempty"`
}

type StreamSubject struct {
	Subject string `json:"subject"`
}