kafka_queue

type AddSessionFeedbackArgs struct {
	SessionSecureID string
	UserName        *string
	UserEmail       *string
	Verbatim        string
	Timestamp       time.Time
}

type AddSessionPropertiesArgs struct {
	SessionSecureID  string
	PropertiesObject interface{}
}

type AddTrackPropertiesArgs struct {
	SessionSecureID  string
	PropertiesObject interface{}
}

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

type ConfigOverride struct {
	Async            *bool
	QueueCapacity    *int
	MinBytes         *int
	MaxWait          *time.Duration
	MessageSizeBytes *int64
	OnAssignGroups   func()
}

type ErrorGroupDataSyncArgs struct {
	ErrorGroupID int
}

type ErrorObjectDataSyncArgs struct {
	ErrorObjectID int
}

type GetTopicOptions struct {
	Type TopicType
}

type IdentifySessionArgs struct {
	SessionSecureID string
	UserIdentifier  string
	UserObject      interface{}
}

type InitializeSessionArgs struct {
	SessionSecureID                string
	CreatedAt                      time.Time
	ProjectVerboseID               string
	EnableStrictPrivacy            bool
	PrivacySetting                 *string
	EnableRecordingNetworkContents bool
	ClientVersion                  string
	FirstloadVersion               string
	ClientConfig                   string
	Environment                    string
	AppVersion                     *string
	Fingerprint                    string
	UserAgent                      string
	AcceptLanguage                 string
	IP                             string
	ClientID                       string
	NetworkRecordingDomains        []string
	DisableSessionRecording        *bool
	ServiceName                    string
}

type LogRowMessage struct {
	Type         PayloadType
	Failures     int
	MaxRetries   int
	KafkaMessage *kafka.Message `json:",omitempty"`
	*clickhouse.LogRow
}

type Message struct {
	Type                  PayloadType
	Failures              int
	MaxRetries            int
	KafkaMessage          *kafka.Message             `json:",omitempty"`
	PushPayload           *PushPayloadArgs           `json:",omitempty"`
	InitializeSession     *InitializeSessionArgs     `json:",omitempty"`
	IdentifySession       *IdentifySessionArgs       `json:",omitempty"`
	AddTrackProperties    *AddTrackPropertiesArgs    `json:",omitempty"`
	AddSessionProperties  *AddSessionPropertiesArgs  `json:",omitempty"`
	PushBackendPayload    *PushBackendPayloadArgs    `json:",omitempty"`
	PushMetrics           *PushMetricsArgs           `json:",omitempty"`
	AddSessionFeedback    *AddSessionFeedbackArgs    `json:",omitempty"`
	PushLogs              *PushLogsArgs              `json:",omitempty"`
	PushTraces            *PushTracesArgs            `json:",omitempty"`
	SessionDataSync       *SessionDataSyncArgs       `json:",omitempty"`
	ErrorGroupDataSync    *ErrorGroupDataSyncArgs    `json:",omitempty"`
	ErrorObjectDataSync   *ErrorObjectDataSyncArgs   `json:",omitempty"`
	PushCompressedPayload *PushCompressedPayloadArgs `json:",omitempty"`
}

type MessageQueue interface {
	Stop(context.Context)
	Receive(context.Context) RetryableMessage
	Submit(context.Context, string, ...RetryableMessage) error
	LogStats()
}

type MockMessageQueue struct{}

type Mode int

type PayloadType = int

type PushBackendPayloadArgs struct {
	ProjectVerboseID *string
	SessionSecureID  *string
	Errors           []*customModels.BackendErrorObjectInput
}

type PushCompressedPayloadArgs struct {
	SessionSecureID string
	PayloadID       int
	Data            string `json:"data"`
}

type PushLogsArgs struct {
	LogRow *clickhouse.LogRow
}

type PushMetricsArgs struct {
	ProjectVerboseID *string
	SessionSecureID  *string
	Metrics          []*customModels.MetricInput
}

type PushPayloadArgs struct {
	SessionSecureID    string
	PayloadID          *int
	Events             customModels.ReplayEventsInput   `json:"events"`
	Messages           string                           `json:"messages"`
	Resources          string                           `json:"resources"`
	WebSocketEvents    *string                          `json:"web_socket_events"`
	Errors             []*customModels.ErrorObjectInput `json:"errors"`
	IsBeacon           *bool                            `json:"is_beacon"`
	HasSessionUnloaded *bool                            `json:"has_session_unloaded"`
	HighlightLogs      *string                          `json:"highlight_logs"`
}

type PushTracesArgs struct {
	TraceRow *clickhouse.TraceRow
}

type Queue struct {
	Topic            string
	ConsumerGroup    string
	MessageSizeBytes int64
	Client           *kafka.Client
	// contains filtered or unexported fields
}

type RetryableMessage interface {
	GetType() PayloadType
	GetFailures() int
	SetFailures(value int)
	GetMaxRetries() int
	SetMaxRetries(value int)
	GetKafkaMessage() *kafka.Message
	SetKafkaMessage(value *kafka.Message)
}

type SessionDataSyncArgs struct {
	SessionID int
}

type TopicType string

type TraceRowMessage struct {
	Type         PayloadType
	Failures     int
	MaxRetries   int
	KafkaMessage *kafka.Message `json:",omitempty"`
	*clickhouse.TraceRow
}