core

type CollectMetricsPayload struct {
	*SourcePayload
	Metrics              *SacloudMetrics
	MackerelMetricsParam []*mkr.HostMetricValue
}

type CreateHostPayload struct {
	// SourcePayload ソースとなるサーバー/ホスト情報
	*SourcePayload

	// MackerelHostParam mackerelへのサーバー登録用パラメータ
	MackerelHostParam *mkr.CreateHostParam
}

type Job struct {
	Name       string
	WorkerFunc WorkerFunc
	Payload    interface{}
}

type JobAPI interface {
	GetName() string
	GetPayload() interface{}
	Start(*Queue, *Option)
}

type JobRequestAPI interface {
	GetName() string
	GetPayload() interface{}
}

type JobRouterFunc func(*Queue, *Option, JobRequestAPI)

type LogQueue struct {
	Info  chan string
	Trace chan string
	Warn  chan error
	Error chan error
}

type MackerelFindParamHolder interface {
	GetFindParam() *mkr.FindHostsParam
}

type MackerelHostStatus string

type MackerelOption struct {
	APIKey              string
	RequestQueueBufSize int
	TraceMode           bool
}

type Option struct {
	SakuraCloudOption           *SakuraCloudOption
	MackerelOption              *MackerelOption
	JobQueueBufSize             int
	ThrottledAPIReqQueueBufSize int
	TimerJobInterval            time.Duration
	ReconcileJobInterval        time.Duration
	MetricsHistoryPeriod        time.Duration
	APICallInterval             time.Duration
	HealthCheckWebServerPort    int
	DisableHealthCheck          bool
	SkipInit                    bool
	TraceLog                    bool
	InfoLog                     bool
	WarnLog                     bool
	ErrorLog                    bool
	IgnoreTag                   string
	AgentTag                    string
}

type Queue struct {
	Request          chan JobRequestAPI
	Internal         chan JobAPI
	SakuraRequest    chan JobAPI
	MackerelRequest  chan JobAPI
	ThrottledRequest chan JobAPI
	Logs             *LogQueue
	Quit             chan error
}

type ReconcileHostsPayload struct {
	// FromSackerelHost sackerelが登録したホスト
	FromSackerelHost *mkr.Host
	// FromAgentHost mackerel-agentが登録したホスト
	FromAgentHost *mkr.Host
}

type SacloudMetrics struct {
	CPU       []*sacloud.MonitorValues
	Disk      []*sacloud.MonitorValues
	Interface []*sacloud.MonitorValues
	Database  []*sacloud.MonitorValues
}

type SakuraCloudOption struct {
	AccessToken         string
	AccessTokenSecret   string
	Zone                []string
	IgnoreTags          []string
	TraceMode           bool
	ReuqestQueueBufSize int
}

type SourcePayload struct {
	SacloudSource      interface{}
	SacloudZone        string
	SacloudResourceID  int64
	SourceType         reflect.Type
	MackerelID         string
	MackerelHost       *mkr.Host
	MackerelHostStatus MackerelHostStatus
}

type SourcePayloadHolder interface {
	GetSourcePayload() *SourcePayload
}

type TimerJob struct {
	*Job
	TickerDuration time.Duration
}

type TimerJobAPI interface {
	JobAPI
	GetTickerDuration() time.Duration
}

type WorkerFunc func(*Queue, *Option, JobAPI)