ingest

type BatchEventsSender struct {
	PayLoadBytes int
	BatchSize    int
	EventsChan   chan Event
	EventsQueue  []Event
	QuitChan     chan struct{}
	EventService *Service
	IngestTicker *util.Ticker
	WaitGroup    *sync.WaitGroup
	ErrorChan    chan struct{}
	IsRunning    bool

	Errors []ingestError
	// contains filtered or unexported fields
}

type Error struct {
	Code    *string                `json:"code,omitempty"`
	Details map[string]interface{} `json:"details,omitempty"`
	Message *string                `json:"message,omitempty"`
}

type Event struct {
	// The raw event content. It can be a string, number, string array, number array, JSON object, map, list, a JSON array, or a byte array.
	Body interface{} `json:"body"`
	// Specifies a JSON object that contains explicit custom fields to be defined at index time.
	Attributes map[string]interface{} `json:"attributes,omitempty"`
	// The host value assigned to the event data. Typically, this is the hostname of the client from which you are sending data.
	Host *string `json:"host,omitempty"`
	// An optional ID that uniquely identifies the event data. It is used to deduplicate the data if same data is set multiple times. If ID is not specified, it will be assigned by the system.
	Id *string `json:"id,omitempty"`
	// Optional nanoseconds part of the timestamp.
	Nanos *int32 `json:"nanos,omitempty"`
	// The source value to assign to the event data. For example, if you are sending data from an app that you are developing, set this key to the name of the app.
	Source *string `json:"source,omitempty"`
	// The sourcetype value assigned to the event data.
	Sourcetype *string `json:"sourcetype,omitempty"`
	// Epoch time in milliseconds.
	Timestamp *int64 `json:"timestamp,omitempty"`
}

type FileUploadDetails struct {
	Filename *string `json:"filename,omitempty"`
}

type HecResponse struct {
	// code defines the status of the response. For a complete list of the possible error codes, see https://docs.splunk.com/Documentation/SplunkCloud/latest/Data/TroubleshootHTTPEventCollector#Possible_error_codes
	Code *int64 `json:"code,omitempty"`
	// invalid-event-number defines the index of the first event in error.
	InvalidEventNumber *int64 `json:"invalid-event-number,omitempty"`
	// text describes the response status
	Text *string `json:"text,omitempty"`
}

type HecTokenAccessResponse struct {
	// ack_enabled is set to true if events sent with the auth token should support indexer acknowledgement  type: bool
	AckEnabled *bool `json:"ack_enabled,omitempty"`
	// allow_query_string_auth is set to true if this token can be passed into the ingest endpoint's query parameter for auth  type: bool
	AllowQueryStringAuth *bool `json:"allow_query_string_auth,omitempty"`
	// created_at is a timestamp that captures when this token was created.  type: string format: date-time
	CreatedAt *string `json:"created_at,omitempty"`
	// created_by is the principal that created the token.  type: string
	CreatedBy *string `json:"created_by,omitempty"`
	// description is an optional description of the token.  type: string
	Description *string `json:"description,omitempty"`
	// disabled is set to true if this auth token has been disabled and cannot be used to send events to HECv1  type: bool
	Disabled *bool `json:"disabled,omitempty"`
	// index is the default value of the index field for records collected using this token.  type: string
	Index *string `json:"index,omitempty"`
	// indexes is a list of index names that this token is allowed to send events to  type: []string
	Indexes []string `json:"indexes,omitempty"`
	// last_modified_at is a timestamp that captures when this token was last modified.  type: string format: date-time
	LastModifiedAt *string `json:"last_modified_at,omitempty"`
	// last_modified_by is the principal that last modified the token.  type: string
	LastModifiedBy *string `json:"last_modified_by,omitempty"`
	// name is the name of the token (unique within the tenant that it belongs to).  type: string
	Name *string `json:"name,omitempty"`
	// source is the default value of the source field for records collected using this token.  type: string
	Source *string `json:"source,omitempty"`
	// sourcetype is the default value of the sourcetype field for records collected using this token.  type: string
	Sourcetype *string `json:"sourcetype,omitempty"`
	// tenant is the tenant that this token belongs to  type: string
	Tenant *string `json:"tenant,omitempty"`
}

type HecTokenCreateRequest struct {
	// name is the name of the token (unique within the tenant that it belongs to).  type: string
	Name string `json:"name"`
	// ack_enabled is set to true if events sent with the auth token should support indexer acknowledgement  type: bool
	AckEnabled *bool `json:"ack_enabled,omitempty"`
	// allow_query_string_auth is set to true if this token can be passed into the ingest endpoint's query parameter for auth  type: bool
	AllowQueryStringAuth *bool `json:"allow_query_string_auth,omitempty"`
	// description is an optional description of the token.  type: string
	Description *string `json:"description,omitempty"`
	// disabled is set to true if this auth token has been disabled and cannot be used to send events to HECv1  type: bool
	Disabled *bool `json:"disabled,omitempty"`
	// index is the default value of the index field for records collected using this token.  type: string
	Index *string `json:"index,omitempty"`
	// indexes is a list of index names that this token is allowed to send events to  type: []string
	Indexes []string `json:"indexes,omitempty"`
	// source is the default value of the source field for records collected using this token.  type: string
	Source *string `json:"source,omitempty"`
	// sourcetype is the default value of the sourcetype field for records collected using this token.  type: string
	Sourcetype *string `json:"sourcetype,omitempty"`
}

type HecTokenCreateResponse struct {
	// ack_enabled is set to true if events sent with the auth token should support indexer acknowledgement  type: bool
	AckEnabled *bool `json:"ack_enabled,omitempty"`
	// allow_query_string_auth is set to true if this token can be passed into the ingest endpoint's query parameter for auth  type: bool
	AllowQueryStringAuth *bool `json:"allow_query_string_auth,omitempty"`
	// created_at is a timestamp that captures when this token was created.  type: string format: date-time
	CreatedAt *string `json:"created_at,omitempty"`
	// created_by is the principal that created the token.  type: string
	CreatedBy *string `json:"created_by,omitempty"`
	// description is an optional description of the token.  type: string
	Description *string `json:"description,omitempty"`
	// disabled is set to true if this auth token has been disabled and cannot be used to send events to HECv1  type: bool
	Disabled *bool `json:"disabled,omitempty"`
	// index is the default value of the index field for records collected using this token.  type: string
	Index *string `json:"index,omitempty"`
	// indexes is a list of index names that this token is allowed to send events to  type: []string
	Indexes []string `json:"indexes,omitempty"`
	// last_modified_at is a timestamp that captures when this token was last modified.  type: string format: date-time
	LastModifiedAt *string `json:"last_modified_at,omitempty"`
	// last_modified_by is the principal that last modified the token.  type: string
	LastModifiedBy *string `json:"last_modified_by,omitempty"`
	// name is the name of the token (unique within the tenant that it belongs to).  type: string
	Name *string `json:"name,omitempty"`
	// source is the default value of the source field for records collected using this token.  type: string
	Source *string `json:"source,omitempty"`
	// sourcetype is the default value of the sourcetype field for records collected using this token.  type: string
	Sourcetype *string `json:"sourcetype,omitempty"`
	// tenant is the tenant that this token belongs to.  type: string
	Tenant *string `json:"tenant,omitempty"`
	// token is the token value.  type: string
	Token *string `json:"token,omitempty"`
}

type HecTokenDeleteResponse map[string]interface{}

type HecTokenUpdateRequest struct {
	// ack_enabled is set to true if events sent with the auth token should support indexer acknowledgement  type: *bool
	AckEnabled *bool `json:"ack_enabled,omitempty"`
	// allow_query_string_auth is set to true if this token can be passed into the ingest endpoint's query parameter for auth  type: *bool
	AllowQueryStringAuth *bool `json:"allow_query_string_auth,omitempty"`
	// description is an optional description of the token.  type: *string
	Description *string `json:"description,omitempty"`
	// disabled is set to true if this auth token has been disabled and cannot be used to send events to HECv1  type: *bool
	Disabled *bool `json:"disabled,omitempty"`
	// index is the default value of the index field for records collected using this token  type: *string
	Index *string `json:"index,omitempty"`
	// indexes is a list of index names that this token is allowed to send events to  type: []string
	Indexes []string `json:"indexes,omitempty"`
	// source is the default value of the source field for records collected using this token  type: *string
	Source *string `json:"source,omitempty"`
	// sourcetype is the default value of the sourcetype field for records collected using this token  type: *string
	Sourcetype *string `json:"sourcetype,omitempty"`
}

type HttpResponse struct {
	Code    *string                `json:"code,omitempty"`
	Details map[string]interface{} `json:"details,omitempty"`
	Message *string                `json:"message,omitempty"`
}

type InlineObject struct {
	Upfile **os.File `json:"upfile,omitempty"`
}

type ListCollectorTokensQueryParams struct {
	Limit  *int64 `key:"limit"`
	Offset *int64 `key:"offset"`
}

type Metric struct {
	// Name of the metric e.g. CPU, Memory etc.
	Name string `json:"name"`
	// Dimensions allow metrics to be classified e.g. {\"Server\":\"nginx\", \"Region\":\"us-west-1\", ...}
	Dimensions map[string]string `json:"dimensions,omitempty"`
	// Type of metric. Default is g for gauge.
	Type *string `json:"type,omitempty"`
	// Unit of the metric e.g. percent, megabytes, seconds etc.
	Unit *string `json:"unit,omitempty"`
	// Value of the metric. If not specified, it will be defaulted to 0.
	Value *float64 `json:"value,omitempty"`
}

type MetricAttribute struct {
	// Optional. If set, individual metrics inherit these dimensions and can override any and/or all of them.
	DefaultDimensions map[string]string `json:"defaultDimensions,omitempty"`
	// Optional. If set, individual metrics inherit this type and can optionally override.
	DefaultType *string `json:"defaultType,omitempty"`
	// Optional. If set, individual metrics inherit this unit and can optionally override.
	DefaultUnit *string `json:"defaultUnit,omitempty"`
}

type MetricEvent struct {
	// Specifies multiple related metrics e.g. Memory, CPU etc.
	Body       []Metric         `json:"body"`
	Attributes *MetricAttribute `json:"attributes,omitempty"`
	// The host value assigned to the event data. Typically, this is the hostname of the client from which you are sending data.
	Host *string `json:"host,omitempty"`
	// An optional ID that uniquely identifies the metric data. It is used to deduplicate the data if same data is set multiple times. If ID is not specified, it will be assigned by the system.
	Id *string `json:"id,omitempty"`
	// Optional nanoseconds part of the timestamp.
	Nanos *int32 `json:"nanos,omitempty"`
	// The source value to assign to the event data. For example, if you are sending data from an app that you are developing, set this key to the name of the app.
	Source *string `json:"source,omitempty"`
	// The sourcetype value assigned to the event data.
	Sourcetype *string `json:"sourcetype,omitempty"`
	// Epoch time in milliseconds.
	Timestamp *int64 `json:"timestamp,omitempty"`
}

type PostCollectorRawQueryParams struct {
	// Host : Sets a default host field value for all events in the request.
	Host string `key:"host"`
	// Index : Sets a default index field value for all events in the request.
	Index string `key:"index"`
	// Source : Sets a default source field value for all events in the request.
	Source string `key:"source"`
	// Sourcetype : Sets a default sourcetype field value for all events in the request.
	Sourcetype string `key:"sourcetype"`
	// Time : Sets a default time field value for all events in the request.
	Time string `key:"time"`
}

type PostCollectorRawV1QueryParams struct {
	// Host : Sets a default host field value for all events in the request.
	Host string `key:"host"`
	// Index : Sets a default index field value for all events in the request.
	Index string `key:"index"`
	// Source : Sets a default source field value for all events in the request.
	Source string `key:"source"`
	// Sourcetype : Sets a default sourcetype field value for all events in the request.
	Sourcetype string `key:"sourcetype"`
	// Time : Sets a default time field value for all events in the request.
	Time string `key:"time"`
}

type Service services.BaseService

type Servicer interface {
	//interfaces that cannot be auto-generated from codegen
	/*
	   	NewBatchEventsSenderWithMaxAllowedError initializes a BatchEventsSender to collect events and send them as a single
	           batched request when a maximum event batch size, time interval, or maximum payload size is reached. It also
	           validates the user input for BatchEventSender.
	   	Parameters:
	   		batchSize: maximum number of events to reach before sending the batch, default maximum is 500
	   		interval: milliseconds to wait before sending the batch if other conditions have not been met
	   		dataSize: bytes that the overall payload should not exceed before sending, default maximum is 1040000 ~1MiB
	   		maxErrorsAllowed: number of errors after which the BatchEventsSender will stop
	*/
	NewBatchEventsSenderWithMaxAllowedError(batchSize int, interval int64, dataSize int, maxErrorsAllowed int) (*BatchEventsSender, error)
	/*
	   	NewBatchEventsSender initializes a BatchEventsSender to collect events and send them as a single batched
	           request when a maximum event batch size, time interval, or maximum payload size is reached.
	   	Parameters:
	   		batchSize: maximum number of events to reach before sending the batch, default maximum is 500
	   		interval: milliseconds to wait before sending the batch if other conditions have not been met
	   		payLoadSize: bytes that the overall payload should not exceed before sending, default maximum is 1040000 ~1MiB
	*/
	NewBatchEventsSender(batchSize int, interval int64, payLoadSize int) (*BatchEventsSender, error)
	/*
		UploadFilesStream - Upload stream of io.Reader.
		Parameters:
			stream
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	UploadFilesStream(stream io.Reader, resp ...*http.Response) error

	//interfaces that are auto-generated in interface_generated.go
	ServicerGenerated
}

type ServicerGenerated interface {
	/*
		DeleteAllCollectorTokens - Delete All dsphec tokens for a given tenant.
		Parameters:
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteAllCollectorTokens(resp ...*http.Response) (*map[string]interface{}, error)
	/*
		DeleteCollectorToken - Delete dsphec token by name.
		Parameters:
			tokenName
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	DeleteCollectorToken(tokenName string, resp ...*http.Response) (*map[string]interface{}, error)
	/*
		GetCollectorToken - Get the metadata of a dsphec token by name.
		Parameters:
			tokenName
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	GetCollectorToken(tokenName string, resp ...*http.Response) (*HecTokenAccessResponse, error)
	/*
		ListCollectorTokens - List dsphec tokens for a tenant.
		Parameters:
			query: a struct pointer of valid query parameters for the endpoint, nil to send no query parameters
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	ListCollectorTokens(query *ListCollectorTokensQueryParams, resp ...*http.Response) ([]HecTokenAccessResponse, error)
	/*
		PostCollectorRaw - Sends collector raw events.
		Parameters:
			body: The payload uses concatenated JSON format. See https://docs.splunk.com/Documentation/Splunk/latest/Data/FormateventsforHTTPEventCollector#Event_data for more information.
			query: a struct pointer of valid query parameters for the endpoint, nil to send no query parameters
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PostCollectorRaw(body *string, query *PostCollectorRawQueryParams, resp ...*http.Response) (*HecResponse, error)
	/*
		PostCollectorRawV1 - Sends collector raw events.
		Parameters:
			body: The payload uses concatenated JSON format. See https://docs.splunk.com/Documentation/Splunk/latest/Data/FormateventsforHTTPEventCollector#Event_data for more information.
			query: a struct pointer of valid query parameters for the endpoint, nil to send no query parameters
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PostCollectorRawV1(body *string, query *PostCollectorRawV1QueryParams, resp ...*http.Response) (*HecResponse, error)
	/*
		PostCollectorTokens - Creates dsphec tokens.
		Parameters:
			hecTokenCreateRequest: The API request schema for the token.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PostCollectorTokens(hecTokenCreateRequest HecTokenCreateRequest, resp ...*http.Response) (*HecTokenCreateResponse, error)
	/*
		PostEvents - Sends events.
		Parameters:
			event
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PostEvents(event []Event, resp ...*http.Response) (*HttpResponse, error)
	/*
		PostMetrics - Sends metric events.
		Parameters:
			metricEvent
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PostMetrics(metricEvent []MetricEvent, resp ...*http.Response) (*HttpResponse, error)
	/*
		PutCollectorToken - Update the metadata of a dsphec token by name.
		Parameters:
			tokenName
			hecTokenUpdateRequest: The API request schema for the token.
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	PutCollectorToken(tokenName string, hecTokenUpdateRequest HecTokenUpdateRequest, resp ...*http.Response) (*HecTokenAccessResponse, error)
	/*
		UploadFiles - Upload a CSV or text file that contains events.
		Parameters:
			upfile
			resp: an optional pointer to a http.Response to be populated by this method. NOTE: only the first resp pointer will be used if multiple are provided
	*/
	UploadFiles(upfile **os.File, resp ...*http.Response) (*UploadSuccessResponse, error)
}

type UploadSuccessResponse struct {
	Code    *string            `json:"code,omitempty"`
	Details *FileUploadDetails `json:"details,omitempty"`
	Message *string            `json:"message,omitempty"`
}

type UserErrHandler func(*BatchEventsSender)