common

type AppConfig struct {
	AppCode            string
	ParsedAppCode      string
	AppDeployState     string
	AppName            string
	AppLocation        string
	AppState           string
	AppVersion         string
	FunctionID         uint32
	FunctionInstanceID string
	LastDeploy         string
	Settings           map[string]interface{}
	UserPrefix         string
	FunctionScope      FunctionScope
}

type AppRebalanceProgress struct {
	ToOwn               []uint16 `json:"to_own"`
	ToClose             []uint16 `json:"to_close"`
	OwnedVbs            []uint16 `json:"currently_owned"`
	RebalanceInProgress bool     `json:"running_rebalance"`
}

type AppStatus struct {
	CompositeStatus       string                   `json:"composite_status"`
	Name                  string                   `json:"name"`
	FunctionScope         application.OldNamespace `json:"function_scope"`
	NumBootstrappingNodes int                      `json:"num_bootstrapping_nodes"`
	NumDeployedNodes      int                      `json:"num_deployed_nodes"`
	DeploymentStatus      bool                     `json:"deployment_status"`
	ProcessingStatus      bool                     `json:"processing_status"`
	RedeployRequired      bool                     `json:"redeploy_required"`
	AppState              stateMachine.AppState    `json:"-"`
}

type AppStatusResponse struct {
	Apps             []*AppStatus `json:"apps"`
	NumEventingNodes int          `json:"num_eventing_nodes"`
}

type Application struct {
	AppHandlers        string                 `json:"appcode"`
	DeploymentConfig   DepCfg                 `json:"depcfg"`
	EventingVersion    string                 `json:"version"`
	EnforceSchema      bool                   `json:"enforce_schema"`
	FunctionID         uint32                 `json:"handleruuid"`
	FunctionInstanceID string                 `json:"function_instance_id"`
	Name               string                 `json:"appname"`
	Settings           map[string]interface{} `json:"settings"`
	Metainfo           map[string]interface{} `json:"metainfo,omitempty"`
	Owner              *Owner
	FunctionScope      FunctionScope `json:"function_scope"`
}

type AtomicTypes[T any] struct {
	// contains filtered or unexported fields
}

type Broadcaster interface {
	Request(onlyThisNode bool, dontSkipOthersOnError bool, path string, request *pc.Request) ([][]byte, *pc.Response, error)
	RequestFor(nodeUUID string, path string, request *pc.Request) ([][]byte, *pc.Response, error)

	CloseBroadcaster()
}

type Bucket struct {
	Alias          string `json:"alias"`
	BucketName     string `json:"bucket_name"`
	ScopeName      string `json:"scope_name"`
	CollectionName string `json:"collection_name"`
	Access         string `json:"access"`
}

type ChangeType string

type ClusterSettings struct {
	LocalUsername string
	LocalPassword string
	LocalAddress  string

	AdminHTTPPort string
	AdminSSLPort  string

	SslCAFile       string
	SslCertFile     string
	SslKeyFile      string
	ClientKeyFile   string
	ClientCertFile  string
	ExecutablePath  string
	EventingDir     string
	KvPort          string
	RestPort        string
	DebugPort       string
	UUID            string
	DiagDir         string
	MaxRunningNodes int
	IpMode          IpMode

	NodeCompatVersion *notifier.Version
}

type CompileStatus struct {
	Area           string `json:"area"`
	Column         int    `json:"column_number"`
	CompileSuccess bool   `json:"compile_success"`
	Description    string `json:"description"`
	Index          int    `json:"index"`
	Language       string `json:"language"`
	Line           int    `json:"line_number"`
}

type Config map[string]interface{}

type Constant struct {
	Value   string `json:"value"`
	Literal string `json:"literal"`
}

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

type Credential struct {
	Username  string `json:"username"`
	Password  string `json:"password"`
	BearerKey string `json:"bearer_key"`
}

type Curl struct {
	Hostname               string `json:"hostname"`
	Value                  string `json:"value"`
	AuthType               string `json:"auth_type"`
	Username               string `json:"username"`
	Password               string `json:"password"`
	BearerKey              string `json:"bearer_key"`
	AllowCookies           bool   `json:"allow_cookies"`
	ValidateSSLCertificate bool   `json:"validate_ssl_certificate"`
}

type CursorRegistryMgr interface {
	UpdateLimit(newlimit uint8)
	CursorRegistryWriter
	CursorRegistryReader
}

type CursorRegistryReader interface {
	GetCursors(k KeyspaceName) (map[string]struct{}, bool)
	PrintTree()
}

type CursorRegistryWriter interface {
	Register(k KeyspaceName, funcId string) bool
	Unregister(k KeyspaceName, funcId string)
}

type DcpStreamBoundary string

type DebuggerInstance struct {
	Token           string   `json:"token"`             // An ID for a debugging session
	Host            string   `json:"host"`              // The node where debugger has been spawned
	Status          string   `json:"status"`            // Possible values are WaitingForMutation, MutationTrapped
	URL             string   `json:"url"`               // Chrome-Devtools URL for debugging
	NodesExternalIP []string `json:"nodes_external_ip"` // List of external IP address of the nodes in the cluster
}

type DebuggerOp uint8

type DepCfg struct {
	Buckets            []Bucket   `json:"buckets,omitempty"`
	Curl               []Curl     `json:"curl,omitempty"`
	Constants          []Constant `json:"constants,omitempty"`
	SourceBucket       string     `json:"source_bucket"`
	SourceScope        string     `json:"source_scope"`
	SourceCollection   string     `json:"source_collection"`
	MetadataBucket     string     `json:"metadata_bucket"`
	MetadataScope      string     `json:"metadata_scope"`
	MetadataCollection string     `json:"metadata_collection"`
}

type EventProcessingStats struct {
	DcpEventsProcessedPSec   int    `json:"dcp_events_processed_psec"`
	TimerEventsProcessedPSec int    `json:"timer_events_processed_psec"`
	Timestamp                string `json:"timestamp"`
}

type EventingConsumer interface {
	BootstrapStatus() bool
	CheckIfQueuesAreDrained() error
	ClearEventStats()
	CloseAllRunningDcpFeeds()
	ConsumerName() string
	DcpEventsRemainingToProcess() uint64
	EventingNodeUUIDs() []string
	EventsProcessedPSec() *EventProcessingStats
	GetEventProcessingStats() map[string]uint64
	GetExecutionStats() map[string]interface{}
	GetFailureStats() map[string]interface{}
	GetInsight() *Insight
	GetLcbExceptionsStats() map[string]uint64
	GetMetaStoreStats() map[string]uint64
	HandleV8Worker() error
	HostPortAddr() string
	Index() int
	InternalVbDistributionStats() []uint16
	NodeUUID() string
	NotifyClusterChange()
	NotifyRebalanceStop()
	NotifySettingsChange()
	Pid() int
	RebalanceStatus() bool
	RebalanceTaskProgress() *RebalanceProgress
	RemoveSupervisorToken() error
	ResetBootstrapDone()
	ResetCounters()
	Serve()
	SetConnHandle(net.Conn)
	SetFeedbackConnHandle(net.Conn)
	SetRebalanceStatus(status bool)
	GetRebalanceStatus() bool
	GetPrevRebalanceInCompleteStatus() bool
	SignalBootstrapFinish()
	SignalConnected()
	SignalFeedbackConnected()
	SignalStopDebugger() error
	SpawnCompilationWorker(appCode, appContent, appName, eventingPort string, handlerHeaders, handlerFooters []string) (*CompileStatus, error)
	Stop(context string)
	String() string
	TimerDebugStats() map[int]map[string]interface{}
	NotifyPrepareTopologyChange(keepNodes, ejectNodes []string)
	UpdateEncryptionLevel(enforceTLS, encryptOn bool)
	UpdateWorkerQueueMemCap(quota int64)
	VbDcpEventsRemainingToProcess() map[int]int64
	VbEventingNodeAssignMapUpdate(map[uint16]string)
	VbProcessingStats() map[uint16]map[string]interface{}
	VbSeqnoStats() map[int]map[string]interface{}
	WorkerVbMapUpdate(map[string][]uint16)

	SendAssignedVbs()
	PauseConsumer()
	GetAssignedVbs(workerName string) ([]uint16, error)
	NotifyWorker()
	GetOwner() *Owner

	SetFeatureMatrix(featureMatrix uint32)

	GetSuperSup() EventingSuperSup
}

type EventingProducer interface {
	AddMetadataPrefix(key string) Key
	AppendCurlLatencyStats(deltas StatsData)
	AppendLatencyStats(deltas StatsData)
	BootstrapStatus() bool
	CfgData() string
	CheckpointBlobDump() map[string]interface{}
	CleanupMetadataBucket(skipCheckpointBlobs bool) error
	CleanupUDSs()
	ClearEventStats()
	DcpFeedBoundary() string
	GetAppCode() string
	GetAppLog(sz int64) []string
	GetDcpEventsRemainingToProcess() uint64
	GetDebuggerURL() (string, error)
	GetEventingConsumerPids() map[string]int
	GetEventProcessingStats() map[string]uint64
	GetExecutionStats() map[string]interface{}
	GetFailureStats() map[string]interface{}
	GetLatencyStats() StatsData
	GetCurlLatencyStats() StatsData
	GetInsight() *Insight
	GetLcbExceptionsStats() map[string]uint64
	GetMetaStoreStats() map[string]uint64
	GetMetadataPrefix() string
	GetNsServerPort() string
	GetVbOwner(vb uint16) (string, string, error)
	GetSeqsProcessed() map[int]int64
	GetDebuggerToken() string
	InternalVbDistributionStats() map[string]string
	IsEventingNodeAlive(eventingHostPortAddr, nodeUUID string) bool
	IsPlannerRunning() bool
	IsTrapEvent() bool
	KillAllConsumers()
	KillAndRespawnEventingConsumer(consumer EventingConsumer)
	KvHostPorts() []string
	LenRunningConsumers() int
	MetadataBucket() string
	MetadataScope() string
	MetadataCollection() string
	NotifyInit()
	NotifyPrepareTopologyChange(ejectNodes, keepNodes []string, changeType service.TopologyChangeType)
	NotifySettingsChange()
	NotifySupervisor()
	NotifyTopologyChange(msg *TopologyChangeMsg)
	NsServerHostPort() string
	NsServerNodeCount() int
	PauseProducer()
	PlannerStats() []*PlannerNodeVbMapping
	ResumeProducer()
	RebalanceStatus() bool
	RebalanceTaskProgress() *RebalanceProgress
	RemoveConsumerToken(workerName string)
	ResetCounters()
	SignalBootstrapFinish()
	SignalStartDebugger(token string) error
	SignalStopDebugger() error
	SetRetryCount(retryCount int64)
	SpanBlobDump() map[string]interface{}
	Serve()
	SourceBucket() string
	SourceScope() string
	SourceCollection() string
	GetSourceKeyspaceID() (KeyspaceID, bool)
	GetMetadataKeyspaceID() (KeyspaceID, bool)
	GetFunctionInstanceId() string
	GetCursorAware() bool
	SrcMutation() bool
	Stop(context string)
	StopRunningConsumers()
	String() string
	SetTrapEvent(value bool)
	TimerDebugStats() map[int]map[string]interface{}
	UndeployHandler(msg UndeployAction)
	UpdateEncryptionLevel(enforceTLS, encryptOn bool)
	UpdateMemoryQuota(quota int64)
	UsingTimer() bool
	VbDcpEventsRemainingToProcess() map[int]int64
	VbDistributionStatsFromMetadata() map[string]map[string]string
	VbSeqnoStats() map[int][]map[string]interface{}
	WriteAppLog(log string)
	WriteDebuggerURL(url string)
	WriteDebuggerToken(token string, hostnames []string) error
	GetOwner() *Owner
	GetFuncScopeDetails() (string, uint32)
	FunctionManageBucket() string
	FunctionManageScope() string
	SetFeatureMatrix(featureMatrix uint32)
}

type EventingServiceMgr interface {
	UpdateBucketGraphFromMetakv(functionName string) error
	ResetFailoverStatus()
	GetFailoverStatus() (failoverNotifTs int64, changeId string)
	CheckLifeCycleOpsDuringRebalance() bool
	NotifySupervisorWaitCh()
	// TODO: Replace it with getting back the whole application.
	GetFunctionId(id Identity) (uint32, error)
	GetPreparedApp(appLocation string) Application
	GetAdminHTTPPort() string
	SetSettings(appLocation string, data []byte, force bool)
}

type EventingSuperSup interface {
	PausingAppList() map[string]string
	BootstrapAppList() map[string]string
	BootstrapAppStatus(appName string) bool
	BootstrapStatus() bool
	CheckAndSwitchgocbBucket(bucketName, appName string, setting *SecuritySetting) error
	CheckpointBlobDump(appName string) (interface{}, error)
	ClearEventStats() []string
	DcpFeedBoundary(fnName string) (string, error)
	DeployedAppList() []string
	GetEventProcessingStats(appName string) map[string]uint64
	GetAppCode(appName string) string
	GetAppLog(appName string, sz int64) []string
	GetAppCompositeState(appName string) int8
	GetDcpEventsRemainingToProcess(appName string) uint64
	GetDebuggerURL(appName string) (string, error)
	GetDeployedApps() map[string]string
	GetUndeployedApps() []string
	GetEventingConsumerPids(appName string) map[string]int
	GetExecutionStats(appName string) map[string]interface{}
	GetFailureStats(appName string) map[string]interface{}
	GetLatencyStats(appName string) StatsData
	GetCurlLatencyStats(appName string) StatsData
	GetInsight(appName string) *Insight
	GetLcbExceptionsStats(appName string) map[string]uint64
	GetLocallyDeployedApps() map[string]string
	GetMetaStoreStats(appName string) map[string]uint64
	GetBucket(bucketName, appName string) (*couchbase.Bucket, error)
	GetMetadataHandle(bucketName, scopeName, collectionName, appName string) (*gocb.Collection, error)
	GetKeyspaceID(bucketName, scopeName, collectionName string) (keyspaceID KeyspaceID, err error)
	GetCurrentManifestId(bucketName string) (string, error)
	GetRegisteredPool() string
	GetSeqsProcessed(appName string) map[int]int64
	GetNumVbucketsForBucket(bucketName string) int
	InternalVbDistributionStats(appName string) map[string]string
	KillAllConsumers()
	NotifyPrepareTopologyChange(ejectNodes, keepNodes []string, changeType service.TopologyChangeType)
	TopologyChangeNotifCallback(kve metakv.KVEntry) error
	PlannerStats(appName string) []*PlannerNodeVbMapping
	RebalanceStatus() bool
	RebalanceTaskProgress(appName string) (*RebalanceProgress, error)
	RemoveProducerToken(appName string)
	RestPort() string
	ResetCounters(appName string) error
	SetSecuritySetting(setting *SecuritySetting) bool
	GetSecuritySetting() *SecuritySetting
	EncryptionChangedDuringLifecycle() bool
	GetGocbSubscribedApps(encryptionEnabled bool) map[string]struct{}
	SignalStopDebugger(appName string) error
	SpanBlobDump(appName string) (interface{}, error)
	StopProducer(appName string, msg UndeployAction)
	TimerDebugStats(appName string) (map[int]map[string]interface{}, error)
	UpdateEncryptionLevel(enforceTLS, encryptOn bool)
	VbDcpEventsRemainingToProcess(appName string) map[int]int64
	VbDistributionStatsFromMetadata(appName string) map[string]map[string]string
	VbSeqnoStats(appName string) (map[int][]map[string]interface{}, error)
	WriteDebuggerURL(appName, url string)
	WriteDebuggerToken(appName, token string, hostnames []string)
	IncWorkerRespawnedCount()
	WorkerRespawnedCount() uint32
	CheckLifeCycleOpsDuringRebalance() bool
	GetBSCSnapshot() (map[string]map[string][]string, error)
	GetSystemMemoryQuota() float64
	ReadOnDeployDoc(string) (string, string, string)
	RemoveOnDeployLeader(string)
	PublishOnDeployStatus(string, string)
	WritePauseTimestamp(string, time.Time)
	RemovePauseTimestampDoc(appName string)
	WriteOnDeployMsgBuffer(appName, msg string)
	GetOnDeployMsgBuffer(appName string) []string
	ClearOnDeployMsgBuffer(appName string)
	UpdateFailedOnDeployStatus(appName string)
	CleanupOnDeployTimers(appName string, skipCheckpointBlobs bool) error

	WatchBucket(keyspace Keyspace, appName string, mType MonitorType) error
	UnwatchBucket(keyspace Keyspace, appName string)
}

type FunctionScope struct {
	BucketName string `json:"bucket"`
	ScopeName  string `json:"scope"`
}

type GlobalStatsCounter struct {
	LcbCredsStats  atomic.Uint64
	GocbCredsStats atomic.Uint64
}

type HandlerConfig struct {
	N1qlPrepareAll            bool
	LanguageCompatibility     string
	AllowTransactionMutations bool
	AllowSyncDocuments        bool
	CursorAware               bool
	AggDCPFeedMemCap          int64
	CheckpointInterval        int
	IdleCheckpointInterval    int
	CPPWorkerThrCount         int
	ExecuteTimerRoutineCount  int
	ExecutionTimeout          int
	CursorCheckpointTimeout   int
	FeedbackBatchSize         int
	FeedbackQueueCap          int64
	FeedbackReadBufferSize    int
	HandlerHeaders            []string
	HandlerFooters            []string
	LcbInstCapacity           int
	N1qlConsistency           string
	LogLevel                  string
	SocketWriteBatchSize      int
	SourceKeyspace            *Keyspace
	StatsLogInterval          int
	StreamBoundary            DcpStreamBoundary
	TimerContextSize          int64
	TimerQueueMemCap          uint64
	TimerQueueSize            uint64
	UndeployRoutineCount      int
	WorkerCount               int
	WorkerQueueCap            int64
	WorkerQueueMemCap         int64
	WorkerResponseTimeout     int
	LcbRetryCount             int
	LcbTimeout                int
	BucketCacheSize           int64
	BucketCacheAge            int64
	NumTimerPartitions        int
	CurlMaxAllowedRespSize    int
}

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

type Identity struct {
	AppName string
	Bucket  string
	Scope   string
}

type Insight struct {
	Script string              `json:"script"`
	Lines  map[int]InsightLine `json:"lines"`
}

type InsightLine struct {
	CallCount      int64   `json:"call_count"`
	CallTime       float64 `json:"call_time"`
	ExceptionCount int64   `json:"error_count"`
	LastException  string  `json:"error_msg"`
	LastLog        string  `json:"last_log"`
}

type Insights map[string]*Insight

type IpMode string

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

type Keyspace struct {
	BucketName     string
	ScopeName      string
	CollectionName string
}

type KeyspaceConvertor[T any] interface {
	MarshalJSON() ([]byte, error)
	GetOriginalKeyspace() T
}

type KeyspaceID struct {
	Bid        string
	Cid        uint32
	Sid        uint32
	StreamType StreamType
}

type KeyspaceName struct {
	Bucket     string `json:"bucket_name"`
	Scope      string `json:"scope_name"`
	Collection string `json:"collection_name"`
}

type LifecycleMsg struct {
	InstanceID  string
	Applocation application.AppLocation
	Description string
	Revert      bool

	DeleteFunction  bool
	PauseFunction   bool
	UndeloyFunction bool
}

type MarshalledData[T any] struct {
	// contains filtered or unexported fields
}

type MonitorType int8

type Owner struct {
	UUID   string
	User   string
	Domain string
}

type OwnershipRoutine interface {
	GetVbMap(namespace *application.KeyspaceInfo, numVb uint16) (string, []uint16, error)
	IsFunctionOwnedByThisNode(namespace *application.KeyspaceInfo) (bool, error)
}

type PlannerNodeVbMapping struct {
	Hostname string `json:"host_name"`
	StartVb  int    `json:"start_vb"`
	VbsCount int    `json:"vb_count"`
}

type ProcessConfig struct {
	BreakpadOn             bool
	DebuggerPort           string
	DiagDir                string
	EventingDir            string
	EventingPort           string
	EventingSSLPort        string
	FeedbackSockIdentifier string
	IPCType                string
	SockIdentifier         string
}

type RebalanceConfig struct {
	VBOwnershipGiveUpRoutineCount   int
	VBOwnershipTakeoverRoutineCount int
}

type RebalanceProgress struct {
	CloseStreamVbsLen     int
	StreamReqVbsLen       int
	VbsRemainingToShuffle int
	VbsOwnedPerPlan       int
	NodeLevelStats        interface{}
}

type SecuritySetting struct {
	EncryptData        bool
	DisableNonSSLPorts bool
	CAFile             string
	CertFile           string
	KeyFile            string
	RootCAs            *x509.CertPool
}

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

type SingleAppStatusResponse struct {
	App              *AppStatus `json:"app"`
	NumEventingNodes int        `json:"num_eventing_nodes"`
}

type Stats struct {
	ExecutionStats          map[string]interface{} `json:"execution_stats"`
	FailureStats            map[string]interface{} `json:"failure_stats"`
	EventProcessingStats    map[string]uint64      `json:"event_processing_stats"`
	LCBExceptionStats       map[string]uint64      `json:"lcb_exception_stats"`
	FunctionScope           application.Namespace  `json:"function_scope"`
	FunctionName            string                 `json:"function_name"`
	FunctionID              uint32                 `json:"function_id"`
	DcpFeedBoundary         string                 `json:"dcp_feed_boundary"`
	EventRemaining          map[string]uint64      `json:"events_remaining"`
	LcbCredsRequestCounter  uint64                 `json:"lcb_creds_request_counter,omitempty"`
	GoCbCredsRequestCounter uint64                 `json:"gocb_creds_request_counter,omitempty"`

	// full stats
	InternalVbDistributionStats map[string]string `json:"internal_vb_distribution_stats,omitempty"`
	WorkerPids                  map[string]int    `json:"worker_pids,omitempty"`
	LatencyPercentileStats      map[string]int    `json:"latency_percentile_stats"`
	CurlLatency                 *HistogramStats   `json:"curl_latency_stats,omitempty"`

	LatencyHistogram *HistogramStats `json:"latency_stats,omitempty"`

	// Full debug stats
	ProcessStats    map[string]interface{} `json:"function_process_stats,omitempty"`
	CheckPointStats map[string]interface{} `json:"function_checkpoint_stats,omitempty"`
	VbStats         map[string]interface{} `json:"vb_stats,omitempty"`

	Insight              *Insight          `json:"-"`
	TempLatencyHistogram *HistogramStats   `json:"-"`
	ProcessedSeq         map[uint16]uint64 `json:"-"`
}

type StatsData map[string]uint64

type StatsInterface interface {
	json.Marshaler
}

type StatsType uint8

type StorageEngine string

type StreamType uint8

type TopologyChangeMsg struct {
	CType     ChangeType
	MsgSource string
}

type UndeployAction struct {
	UpdateMetakv        bool
	SkipMetadataCleanup bool
	DeleteFunction      bool

	Reason string
}