handlers

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

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

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

type CachedEvent struct {
	Malformed     string          `json:"malformed,omitempty"`
	Original      json.RawMessage `json:"original,omitempty"`
	Success       json.RawMessage `json:"success,omitempty"`
	Error         string          `json:"error,omitempty"`
	Skip          string          `json:"skip,omitempty"`
	Timestamp     string          `json:"timestamp,omitempty"`
	UID           string          `json:"uid,omitempty"`
	DestinationID string          `json:"destination_id"`
	TokenID       string          `json:"token_id"`
}

type CachedEventsResponse struct {
	TotalEvents              int           `json:"total_events"`
	LastMinuteLimited        uint64        `json:"last_minute_limited"`
	CacheCapacityPerInterval int           `json:"cache_capacity_per_interval"`
	IntervalSeconds          int           `json:"interval_seconds"`
	ResponseEvents           int           `json:"response_events"`
	Events                   []CachedEvent `json:"events"`
}

type CatalogResponse struct {
	middleware.StatusResponse

	Catalog interface{} `json:"catalog"`
}

type ClearCacheRequest struct {
	Source     string `json:"source"`
	Collection string `json:"collection"`
}

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

type ClusterInfo struct {
	Instances []InstanceInfo `json:"instances"`
}

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

type DockerHubResponse struct {
	Next    string          `json:"next"`
	Results []*DockerHubTag `json:"results"`
}

type DockerHubTag struct {
	Name          string `json:"name"`
	TagLastPushed string `json:"tag_last_pushed"`
}

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

type EvaluateLog struct {
	Level   string `json:"level"`
	Message string `json:"message"`
}

type EvaluateTemplateRequest struct {
	Config            map[string]interface{} `json:"config,omitempty"`
	Object            map[string]interface{} `json:"object,omitempty"`
	Expression        string                 `json:"expression,omitempty"`
	Reformat          bool                   `json:"reformat,omitempty"`
	Type              string                 `json:"type,omitempty"`
	Uid               string                 `json:"uid,omitempty"`
	Field             string                 `json:"field,omitempty"`
	TemplateVariables map[string]interface{} `json:"template_variables,omitempty"`
}

type EvaluateTemplateResponse struct {
	Result     string        `json:"result"`
	Logs       []EvaluateLog `json:"logs,omitempty"`
	Error      string        `json:"error"`
	UserResult string        `json:"user_result"`
	UserError  string        `json:"user_error"`
	Format     string        `json:"format"`
}

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

type EventResponse struct {
	Status       string                   `json:"status"`
	DeleteCookie bool                     `json:"delete_cookie,omitempty"`
	SdkExtras    []map[string]interface{} `json:"jitsu_sdk_extras,omitempty"`
}

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

type FallbackFilesResponse struct {
	Files []*fallback.FileStatus `json:"files"`
}

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

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

type GeoDataResolverTestRequest struct {
	MaxMindURL string `json:"maxmind_url"`
}

type GeoDataResolverTestResponse struct {
	middleware.StatusResponse

	Editions []*geo.EditionRule `json:"editions"`
}

type InstanceInfo struct {
	Name string `json:"name"`
}

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

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

type ReplayRequest struct {
	FileName      string `json:"file_name"`
	DestinationID string `json:"destination_id"`
	FileFormat    string `json:"file_format"`
	SkipMalformed bool   `json:"skip_malformed"`
}

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

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

type SingerHandler struct {
}

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

type SpecResponse struct {
	middleware.StatusResponse

	Spec interface{} `json:"spec"`
}

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

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

type StatisticsResponse struct {
	Status string               `json:"status"`
	Data   []meta.EventsPerTime `json:"data"`
}

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

type TaskIDResponse struct {
	ID string `json:"task_id"`
}

type TaskLogsResponse struct {
	Logs []synchronization.LogRecordDto `json:"logs"`
}

type TasksResponse struct {
	Tasks []synchronization.TaskDto `json:"tasks"`
}

type VersionsResponse struct {
	Versions []string `json:"versions"`
}