infra

Documentation

Index

• Variables
• type BaseProvider
  • func NewBaseProvider(cfg *Config) *BaseProvider
  • func (p *BaseProvider) GetConfig() *Config
  • func (p *BaseProvider) UpdateConfig(cfg *Config) error
• type Config
• type Error
  • func NewError(msg string, code int) *Error
  • func (e *Error) Code() int
  • func (e *Error) Error() string
• type NoopProvider
  • func NewNoopProvider(cfg *Config) *NoopProvider
  • func (p *NoopProvider) GetMetrics(ctx context.Context) (*ResourceMetrics, error)
  • func (p *NoopProvider) IsHealthy(ctx context.Context) bool
  • func (p *NoopProvider) Setup(ctx context.Context) error
  • func (p *NoopProvider) Status(ctx context.Context) (Status, error)
  • func (p *NoopProvider) Teardown(ctx context.Context) error
• type Provider
• type ResourceMetrics
• type Status

Variables

var (
	ErrInvalidConfig      = NewError("invalid configuration", 1)
	ErrProvisionFailed    = NewError("failed to provision resources", 2)
	ErrCleanupFailed      = NewError("failed to cleanup resources", 3)
	ErrMetricsUnavailable = NewError("metrics unavailable", 4)
)

Types

type BaseProvider

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

func NewBaseProvider

func NewBaseProvider(cfg *Config) *BaseProvider

func (*BaseProvider) GetConfig

func (p *BaseProvider) GetConfig() *Config

func (*BaseProvider) UpdateConfig

func (p *BaseProvider) UpdateConfig(cfg *Config) error

type Config

type Config struct {
	Timeout    time.Duration
	RetryCount int
	Tags       map[string]string

	// Baron Chain specific configurations
	QueueSize        int
	MaxConnections   int
	PersistInterval  uint64
	SnapshotInterval uint64
}

type Error

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

func NewError

func NewError(msg string, code int) *Error

func (*Error) Code

func (e *Error) Code() int

func (*Error) Error

func (e *Error) Error() string

type NoopProvider

type NoopProvider struct {
	*BaseProvider
}

func NewNoopProvider

func NewNoopProvider(cfg *Config) *NoopProvider

func (*NoopProvider) GetMetrics

func (p *NoopProvider) GetMetrics(ctx context.Context) (*ResourceMetrics, error)

func (*NoopProvider) IsHealthy

func (p *NoopProvider) IsHealthy(ctx context.Context) bool

func (*NoopProvider) Setup

func (p *NoopProvider) Setup(ctx context.Context) error

func (*NoopProvider) Status

func (p *NoopProvider) Status(ctx context.Context) (Status, error)

func (*NoopProvider) Teardown

func (p *NoopProvider) Teardown(ctx context.Context) error

type Provider

type Provider interface {
	Setup(ctx context.Context) error
	Teardown(ctx context.Context) error
	Status(ctx context.Context) (Status, error)
	GetMetrics(ctx context.Context) (*ResourceMetrics, error)
	IsHealthy(ctx context.Context) bool
	GetConfig() *Config
	UpdateConfig(cfg *Config) error
}

type ResourceMetrics

type ResourceMetrics struct {
	CPUUsage    float64
	MemoryUsage float64
	DiskUsage   float64
	NetworkIn   int64
	NetworkOut  int64

	// Baron Chain specific metrics
	ActiveValidators int
	PendingTxs       int
	BlockHeight      int64
	ConsensusRound   int
	PeerCount        int
}

type Status

type Status string

const (
	StatusUnknown    Status = "unknown"
	StatusReady      Status = "ready"
	StatusError      Status = "error"
	StatusInProgress Status = "in_progress"
)