telemetry

type Exporter interface {
	SendSync(ctx context.Context, events []cloudevent.Event) error
	SendAsync(ctx context.Context, event cloudevent.Event) error
	SendAsyncList(ctx context.Context, events []cloudevent.Event) error
}

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

type KratosExporterConfig struct {
	// ClientCfg is the configuration of the base client
	ClientCfg *clients.BaseClientConfig
	// CollectorID is the ID of the kratos collector
	CollectorID string
	// NumRetries determines the number of retry attempts excluding the first request
	// zero of the value means no retry, and maximum allowed value of NumRetries is 2
	// The default value is 2, thus total attempts including the first attempt is 3.
	NumRetries int
	// FlushInterval determines the time interval in SECOND unit of the periodic flush operation when sending events asynchronously
	FlushInterval int
	// MaxBatchSize determines the maximum allowed number of events per request to be sent to the Kratos collector
	// The default value is 1000, and the goal is to decrease the number of hitting to the Kratos collector
	MaxBatchSize int
	// APIVersion specifies desired analytics API version
	APIVersion string
	// Base delay in seconds for exponential backoff retries
	BaseDelayInSeconds int
	// MaxEvents is the max number of events that the buffer can hold
	MaxEvents int
	// MaxWorkers is the number of worker go routines which are used to flush periodically
	MaxWorkers int
	// NumRetriesExponentialBackoff determines the number of retry attempts for exponential backoff
	// while sending events to Kratos
	NumRetriesExponentialBackoff int
	// MaxBufferSize determines the max buffer size of the task channel
	MaxBufferSize int
	// CustomHTTPClient allows providing a custom HTTP client to use instead of creating a new one
	CustomHTTPClient *http.Client
	// SyncMaxRetries defines the  number of retry attempts for the sync mode
	SyncMaxRetries int
	// SyncBaseDelayInSeconds defines delay in seconds for exponential backoff retries for the sync mode
	SyncBaseDelayInSeconds int
	// MaxBatchSizeInBytes defines the maximum batch size in bytes
	MaxBatchSizeInBytes int
	// SyncBatchTimeoutMs defines the timeout in ms for sync batch
	SyncBatchTimeoutMs int
	// SyncBatchQueueSize defines the initial size of the sync batch queue
	SyncBatchQueueSize int
}

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

type KratosStsToken struct {
	Status          int    `json:"status"`
	AccessKeyId     string `json:"accessKeyId"`
	SecretAccessKey string `json:"secretAccessKey"`
	SessionToken    string `json:"sessionToken"`
}

type Option func(config *KratosExporterConfig) error