monitor

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 27, 2026 License: PostgreSQL Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const ResourceTypeInstanceMonitorResource resource.Type = "monitor.instance"
View Source 
const ResourceTypeServiceInstanceMonitorResource resource.Type = "monitor.service_instance"

Variables

This section is empty.

Functions

func InstanceMonitorResourceIdentifier 

func InstanceMonitorResourceIdentifier(instanceID string) resource.Identifier

func Provide 

func Provide(i *do.Injector)

func RegisterResourceTypes 

func RegisterResourceTypes(registry *resource.Registry)

func ServiceInstanceMonitorResourceIdentifier added in v0.7.0 

func ServiceInstanceMonitorResourceIdentifier(serviceInstanceID string) resource.Identifier

Types

type Check 

type Check func(ctx context.Context) error

type HostMonitor 

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

func NewHostMonitor 

func NewHostMonitor(
	logger zerolog.Logger,
	svc *host.Service,
) *HostMonitor

func (*HostMonitor) Start 

func (m *HostMonitor) Start(ctx context.Context)

func (*HostMonitor) Stop 

func (m *HostMonitor) Stop()

type InstanceMonitor 

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

func NewInstanceMonitor 

func NewInstanceMonitor(
	dbSvc *database.Service,
	certSvc *certificates.Service,
	logger zerolog.Logger,
	databaseID string,
	instanceID string,
	dbName string,
) *InstanceMonitor

func (*InstanceMonitor) Start 

func (m *InstanceMonitor) Start(ctx context.Context)

func (*InstanceMonitor) Stop 

func (m *InstanceMonitor) Stop()

type InstanceMonitorResource 

type InstanceMonitorResource struct {
	DatabaseID   string `json:"database_id"`
	InstanceID   string `json:"instance_id"`
	DatabaseName string `json:"db_name"`
	HostID       string `json:"host_id"`
}

func (*InstanceMonitorResource) Create 

func (m *InstanceMonitorResource) Create(ctx context.Context, rc *resource.Context) error

func (*InstanceMonitorResource) Delete 

func (m *InstanceMonitorResource) Delete(ctx context.Context, rc *resource.Context) error

func (*InstanceMonitorResource) Dependencies 

func (m *InstanceMonitorResource) Dependencies() []resource.Identifier

func (*InstanceMonitorResource) DiffIgnore 

func (m *InstanceMonitorResource) DiffIgnore() []string

func (*InstanceMonitorResource) Executor 

func (m *InstanceMonitorResource) Executor() resource.Executor

func (*InstanceMonitorResource) Identifier 

func (m *InstanceMonitorResource) Identifier() resource.Identifier

func (*InstanceMonitorResource) Refresh 

func (m *InstanceMonitorResource) Refresh(ctx context.Context, rc *resource.Context) error

func (*InstanceMonitorResource) ResourceVersion 

func (m *InstanceMonitorResource) ResourceVersion() string

func (*InstanceMonitorResource) TypeDependencies added in v0.7.0 

func (m *InstanceMonitorResource) TypeDependencies() []resource.Type

func (*InstanceMonitorResource) Update 

func (m *InstanceMonitorResource) Update(ctx context.Context, rc *resource.Context) error

type InstanceMonitorStore 

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

func NewInstanceMonitorStore 

func NewInstanceMonitorStore(client *clientv3.Client, root string) *InstanceMonitorStore

func (*InstanceMonitorStore) DeleteByHostID 

func (s *InstanceMonitorStore) DeleteByHostID(hostID string) storage.DeleteOp

func (*InstanceMonitorStore) DeleteByKey 

func (s *InstanceMonitorStore) DeleteByKey(hostID, instanceID string) storage.DeleteOp

func (*InstanceMonitorStore) GetAllByHostID 

func (s *InstanceMonitorStore) GetAllByHostID(hostID string) storage.GetMultipleOp[*StoredInstanceMonitor]

func (*InstanceMonitorStore) GetByKey 

func (s *InstanceMonitorStore) GetByKey(hostID, instanceID string) storage.GetOp[*StoredInstanceMonitor]

func (*InstanceMonitorStore) HostPrefix 

func (s *InstanceMonitorStore) HostPrefix(hostID string) string

func (*InstanceMonitorStore) Key 

func (s *InstanceMonitorStore) Key(hostID, instanceID string) string

func (*InstanceMonitorStore) Prefix 

func (s *InstanceMonitorStore) Prefix() string

func (*InstanceMonitorStore) Put 

func (s *InstanceMonitorStore) Put(item *StoredInstanceMonitor) storage.PutOp[*StoredInstanceMonitor]

type Monitor 

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

func NewMonitor 

func NewMonitor(
	logger zerolog.Logger,
	interval time.Duration,
	checks ...Check,
) *Monitor

func (*Monitor) Check 

func (m *Monitor) Check(ctx context.Context)

func (*Monitor) Start 

func (m *Monitor) Start(ctx context.Context)

func (*Monitor) Stop 

func (m *Monitor) Stop()

type Service 

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

func NewService 

func NewService(
	cfg config.Config,
	logger zerolog.Logger,
	dbSvc *database.Service,
	certSvc *certificates.Service,
	dbOrch database.Orchestrator,
	store *Store,
	hostSvc *host.Service,
) *Service

func (*Service) CreateInstanceMonitor 

func (s *Service) CreateInstanceMonitor(ctx context.Context, databaseID, instanceID, dbName string) error

func (*Service) CreateServiceInstanceMonitor added in v0.7.0 

func (s *Service) CreateServiceInstanceMonitor(ctx context.Context, databaseID, serviceInstanceID string) error

func (*Service) DeleteInstanceMonitor 

func (s *Service) DeleteInstanceMonitor(ctx context.Context, instanceID string) error

func (*Service) DeleteServiceInstanceMonitor added in v0.7.0 

func (s *Service) DeleteServiceInstanceMonitor(ctx context.Context, serviceInstanceID string) error

func (*Service) HasInstanceMonitor 

func (s *Service) HasInstanceMonitor(instanceID string) bool

func (*Service) HasServiceInstanceMonitor added in v0.7.0 

func (s *Service) HasServiceInstanceMonitor(serviceInstanceID string) bool

func (*Service) Shutdown 

func (s *Service) Shutdown() error

func (*Service) Start 

func (s *Service) Start(ctx context.Context) error

type ServiceInstanceMonitor added in v0.7.0 

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

func NewServiceInstanceMonitor added in v0.7.0 

func NewServiceInstanceMonitor(
	orch database.Orchestrator,
	dbSvc *database.Service,
	logger zerolog.Logger,
	databaseID string,
	serviceInstanceID string,
	hostID string,
) *ServiceInstanceMonitor

func (*ServiceInstanceMonitor) Start added in v0.7.0 

func (m *ServiceInstanceMonitor) Start(ctx context.Context)

func (*ServiceInstanceMonitor) Stop added in v0.7.0 

func (m *ServiceInstanceMonitor) Stop()

type ServiceInstanceMonitorResource added in v0.7.0 

type ServiceInstanceMonitorResource struct {
	DatabaseID        string `json:"database_id"`
	ServiceInstanceID string `json:"service_instance_id"`
	HostID            string `json:"host_id"`
}

func (*ServiceInstanceMonitorResource) Create added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Create(ctx context.Context, rc *resource.Context) error

func (*ServiceInstanceMonitorResource) Delete added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Delete(ctx context.Context, rc *resource.Context) error

func (*ServiceInstanceMonitorResource) Dependencies added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Dependencies() []resource.Identifier

func (*ServiceInstanceMonitorResource) DiffIgnore added in v0.7.0 

func (m *ServiceInstanceMonitorResource) DiffIgnore() []string

func (*ServiceInstanceMonitorResource) Executor added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Executor() resource.Executor

func (*ServiceInstanceMonitorResource) Identifier added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Identifier() resource.Identifier

func (*ServiceInstanceMonitorResource) Refresh added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Refresh(ctx context.Context, rc *resource.Context) error

func (*ServiceInstanceMonitorResource) ResourceVersion added in v0.7.0 

func (m *ServiceInstanceMonitorResource) ResourceVersion() string

func (*ServiceInstanceMonitorResource) TypeDependencies added in v0.7.0 

func (m *ServiceInstanceMonitorResource) TypeDependencies() []resource.Type

func (*ServiceInstanceMonitorResource) Update added in v0.7.0 

func (m *ServiceInstanceMonitorResource) Update(ctx context.Context, rc *resource.Context) error

type ServiceInstanceMonitorStore added in v0.7.0 

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

func NewServiceInstanceMonitorStore added in v0.7.0 

func NewServiceInstanceMonitorStore(client *clientv3.Client, root string) *ServiceInstanceMonitorStore

func (*ServiceInstanceMonitorStore) DeleteByHostID added in v0.7.0 

func (s *ServiceInstanceMonitorStore) DeleteByHostID(hostID string) storage.DeleteOp

func (*ServiceInstanceMonitorStore) DeleteByKey added in v0.7.0 

func (s *ServiceInstanceMonitorStore) DeleteByKey(hostID, serviceInstanceID string) storage.DeleteOp

func (*ServiceInstanceMonitorStore) GetAllByHostID added in v0.7.0 

func (s *ServiceInstanceMonitorStore) GetAllByHostID(hostID string) storage.GetMultipleOp[*StoredServiceInstanceMonitor]

func (*ServiceInstanceMonitorStore) GetByKey added in v0.7.0 

func (s *ServiceInstanceMonitorStore) GetByKey(hostID, serviceInstanceID string) storage.GetOp[*StoredServiceInstanceMonitor]

func (*ServiceInstanceMonitorStore) HostPrefix added in v0.7.0 

func (s *ServiceInstanceMonitorStore) HostPrefix(hostID string) string

func (*ServiceInstanceMonitorStore) Key added in v0.7.0 

func (s *ServiceInstanceMonitorStore) Key(hostID, serviceInstanceID string) string

func (*ServiceInstanceMonitorStore) Prefix added in v0.7.0 

func (s *ServiceInstanceMonitorStore) Prefix() string

func (*ServiceInstanceMonitorStore) Put added in v0.7.0 

func (s *ServiceInstanceMonitorStore) Put(item *StoredServiceInstanceMonitor) storage.PutOp[*StoredServiceInstanceMonitor]

type Store 

type Store struct {
	InstanceMonitor        *InstanceMonitorStore
	ServiceInstanceMonitor *ServiceInstanceMonitorStore
	// contains filtered or unexported fields
}

func NewStore 

func NewStore(client *clientv3.Client, root string) *Store

func (*Store) Txn 

func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

type StoredInstanceMonitor 

type StoredInstanceMonitor struct {
	storage.StoredValue
	HostID           string `json:"host_id"`
	DatabaseID       string `json:"database_id"`
	InstanceID       string `json:"instance_id"`
	DatabaseName     string `json:"database_name"`
	InstanceHostname string `json:"instance_hostname"`
}

type StoredServiceInstanceMonitor added in v0.7.0 

type StoredServiceInstanceMonitor struct {
	storage.StoredValue
	HostID            string `json:"host_id"`
	DatabaseID        string `json:"database_id"`
	ServiceInstanceID string `json:"service_instance_id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.