monitoring

type AssignedTreatmentLog struct {
	ProjectID         models.ProjectId
	RequestID         string
	Experiment        *_pubsub.Experiment
	Treatment         *_pubsub.ExperimentTreatment
	TreatmentMetadata *TreatmentMetadata
	Request           *Request
	Segmenters        []models.SegmentFilter
	Error             *ErrorResponseLog
}

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

type AssignedTreatmentPublisher interface {
	Publish(log []*AssignedTreatmentLog) error
}

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

type BQLogRow struct {
	EventTimestamp time.Time `bigquery:"event_timestamp"`

	ProjectId models.ProjectId `bigquery:"project_id"`
	RequestId string           `bigquery:"request_id"`

	Request *Request `bigquery:"request"`
	Segment string   `bigquery:"segment"`

	ExperimentId   int64  `bigquery:"experiment_id"`
	ExperimentName string `bigquery:"experiment_name"`

	TreatmentName     string `bigquery:"treatment_name"`
	TreatmentConfig   string `bigquery:"treatment_config"`
	TreatmentMetadata string `bigquery:"treatment_metadata"`

	Error string `bigquery:"error"`
}

type ErrorResponseLog struct {
	Code  int
	Error string
}

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

type Request struct {

	// The header from the incoming request to XP services. The map value is a
	// comma-delimited string.
	Header string `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// The JSON body of the request to XP services, UTF-8-encoded
	Body string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type TreatmentMetadata struct {
	ExperimentType     string `json:"experiment_type"`
	ExperimentVersion  int64  `json:"experiment_version"`
	SwitchbackWindowId *int64 `json:"switchback_window_id"`
}

type TreatmentServiceResultLogKey struct {

	// The unique request id generated by Treatment Service, for every incoming
	// request
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// The time at which the final response from Treatment Service is generated
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

type TreatmentServiceResultLogMessage struct {

	// The unique request id generated by Treatment Service, for every incoming
	// request
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// The time at which the final response from Treatment Service is generated
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// The original request to Treatment Service
	Request *Request `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// The parsed segment based on registered experiment variables via Project
	// Settings
	Segment string `protobuf:"bytes,4,opt,name=segment,proto3" json:"segment,omitempty"`
	// The project's id of the request
	ProjectId uint32 `protobuf:"varint,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The matched experiment's id based on request's segment values
	ExperimentId int64 `protobuf:"varint,6,opt,name=experiment_id,json=experimentId,proto3" json:"experiment_id,omitempty"`
	// The matched experiment's name based on request's segment values
	ExperimentName string `protobuf:"bytes,7,opt,name=experiment_name,json=experimentName,proto3" json:"experiment_name,omitempty"`
	// The assigned treatment's name based on matched experiment
	TreatmentName string `protobuf:"bytes,8,opt,name=treatment_name,json=treatmentName,proto3" json:"treatment_name,omitempty"`
	// The assigned treatment's config (JSON string) in based on matched
	// experiment
	TreatmentConfig string `protobuf:"bytes,9,opt,name=treatment_config,json=treatmentConfig,proto3" json:"treatment_config,omitempty"`
	// The error (if any) of the request
	Error string `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"`
	// The assigned treatment metadata, if any
	TreatmentMetadata string `protobuf:"bytes,11,opt,name=treatment_metadata,json=treatmentMetadata,proto3" json:"treatment_metadata,omitempty"`
	// contains filtered or unexported fields
}