cluster

type Authentication struct {
	Key  string `json:"key"`
	Type string `json:"type"`
}

type Authorization struct {
	Policy     string `json:"policy"`
	Url        string `json:"url"`
	AutoReload int    `json:"auto_reload"`
}

type Cluster struct {
	Name           string            `json:"name"`
	Namespace      string            `json:"namespace"`
	Replicas       int               `json:"replicas"`
	Authentication *Authentication   `json:"authentication"`
	Authorization  *Authorization    `json:"authorization"`
	Health         *Health           `json:"health"`
	Image          *Image            `json:"image"`
	License        string            `json:"license"`
	Log            *Log              `json:"log"`
	NodeSelectors  map[string]string `json:"node_selectors"`
	Notification   *Notification     `json:"notification"`
	Queue          *Queue            `json:"queue"`
	Resource       *Resource         `json:"resource"`
	Api            *Service          `json:"api"`
	Grpc           *Service          `json:"grpc"`
	Rest           *Service          `json:"rest"`
	Routing        *Routing          `json:"routing"`
	Store          *Store            `json:"store"`
	Tls            *Tls              `json:"tls"`
	Volume         *Volume           `json:"volume"`
	Status         *Status           `json:"-" yaml:"-"`

	ImageSpec          string `json:"-" yaml:"-"`
	AuthenticationSpec string `json:"-" yaml:"-"`
	AuthorizationSpec  string `json:"-" yaml:"-"`
	HealthSpec         string `json:"-" yaml:"-"`
	NotificationSpec   string `json:"-" yaml:"-"`
	QueueSpec          string `json:"-" yaml:"-"`
	StoreSpec          string `json:"-" yaml:"-"`
	ApiServiceSpec     string `json:"-" yaml:"-"`
	GrpcServiceSpec    string `json:"-" yaml:"-"`
	RestServiceSpec    string `json:"-" yaml:"-"`
	VolumeSpec         string `json:"-" yaml:"-"`
	TlsSpec            string `json:"-" yaml:"-"`
	ResourcesSpec      string `json:"-" yaml:"-"`
	RoutingSpec        string `json:"-" yaml:"-"`
	LogSpec            string `json:"-" yaml:"-"`
	NodeSelectorsSpec  string `json:"-" yaml:"-"`
	LicenseSpec        string `json:"-" yaml:"-"`
	// contains filtered or unexported fields
}

type ClustersHandler interface {
	Name() string
	Add(cluster *Cluster) error
	Edit(cluster *Cluster) error
	Delete(cluster *Cluster) error
	Get(namespace, name string) (*Cluster, error)
	List() ([]*Cluster, error)
	ConnectorsHandler() connector.ConnectorsHandler
}

type Health struct {
	Enabled             bool `json:"enabled"`
	InitialDelaySeconds int  `json:"initial_delay_seconds"`
	PeriodSeconds       int  `json:"period_seconds"`
	TimeoutSeconds      int  `json:"timeout_seconds"`
	SuccessThreshold    int  `json:"success_threshold"`
	FailureThreshold    int  `json:"failure_threshold"`
}

type Image struct {
	Image      string `json:"image"`
	PullPolicy string `json:"pull_policy"`
}

type License struct {
	Data string
}

type Log struct {
	Level int `json:"level"`
	// contains filtered or unexported fields
}

type Name struct {
	Name string
	// contains filtered or unexported fields
}

type Namespace struct {
	Namespace string
	// contains filtered or unexported fields
}

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

type Notification struct {
	Prefix  string `json:"prefix"`
	Enabled bool   `json:"enabled"`
}

type Queue struct {
	MaxReceiveMessagesRequest int `json:"max_receive_messages_request"`
	MaxWaitTimeoutSeconds     int `json:"max_wait_timeout_seconds"`
	MaxExpirationSeconds      int `json:"max_expiration_seconds"`
	MaxDelaySeconds           int `json:"max_delay_seconds"`
	MaxReQueues               int `json:"max_re_queues"`
	MaxVisibilitySeconds      int `json:"max_visibility_seconds"`
	DefaultVisibilitySeconds  int `json:"default_visibility_seconds"`
	DefaultWaitTimeoutSeconds int `json:"default_wait_timeout_seconds"`
}

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

type Resource struct {
	LimitsCpu      string `json:"limits_cpu"`
	LimitsMemory   string `json:"limits_memory"`
	RequestsCpu    string `json:"requests_cpu"`
	RequestsMemory string `json:"requests_memory"`
}

type Routing struct {
	Data       string `json:"data"`
	Url        string `json:"url"`
	AutoReload int    `json:"auto_reload"`
}

type Service struct {
	NodePort   int    `json:"node_port"`
	Expose     string `json:"expose"`
	BufferSize int    `json:"buffer_size"`
	BodyLimit  int    `json:"body_limit"`
	// contains filtered or unexported fields
}

type Status struct {
	Replicas      int32  `json:"replicas"`
	Version       string `json:"version"`
	Ready         int32  `json:"ready"`
	Grpc          string `json:"grpc"`
	Rest          string `json:"rest"`
	Api           string `json:"api"`
	Selector      string `json:"selector"`
	LicenseType   string `json:"license_type"`
	LicenseTo     string `json:"license_to"`
	LicenseExpire string `json:"license_expire"`
	Status        string `json:"status"`
}

type Store struct {
	Clean                    bool   `json:"clean"`
	Path                     string `json:"path"`
	MaxChannels              int    `json:"max_channels"`
	MaxSubscribers           int    `json:"max_subscribers"`
	MaxMessages              int    `json:"max_messages"`
	MaxChannelSize           int    `json:"max_channel_size"`
	MessagesRetentionMinutes int    `json:"messages_retention_minutes"`
	PurgeInactiveMinutes     int    `json:"purge_inactive_minutes"`
}

type Template struct {
	Structure string
	Data      interface{}
	// contains filtered or unexported fields
}

type Tls struct {
	Cert string `json:"cert"`
	Key  string `json:"key"`
	Ca   string `json:"ca"`
}

type Validator interface {
	Validate() error
}

type Volume struct {
	Size         string `json:"size"`
	StorageClass string `json:"storage_class"`
	// contains filtered or unexported fields
}