balance

Documentation

Index

• func InitSealos(jwtKey string, accountURL string) error
• type GroupBalance
• type MockGroupBalance
  • func NewMockGroupBalance() *MockGroupBalance
  • func (q *MockGroupBalance) GetBalance(_ context.Context) (float64, error)
  • func (q *MockGroupBalance) GetGroupRemainBalance(_ context.Context, _ string) (float64, PostGroupConsumer, error)
  • func (q *MockGroupBalance) PostGroupConsume(_ context.Context, _ string, usage float64) (float64, error)
• type PostGroupConsumer
• type Sealos
  • func NewSealos(accountURL string) *Sealos
  • func (s *Sealos) GetGroupRemainBalance(ctx context.Context, group string) (float64, PostGroupConsumer, error)
• type SealosPostGroupConsumer
  • func (s *SealosPostGroupConsumer) GetBalance(_ context.Context) (float64, error)
  • func (s *SealosPostGroupConsumer) PostGroupConsume(ctx context.Context, tokenName string, usage float64) (float64, error)

Functions

func InitSealos

func InitSealos(jwtKey string, accountURL string) error

FIXME: 如果获取余额能成功，但是消费永远失败，需要加一个失败次数限制，如果失败次数超过一定阈值，暂停服务

Types

type GroupBalance

type GroupBalance interface {
	GetGroupRemainBalance(ctx context.Context, group string) (float64, PostGroupConsumer, error)
}

var Default GroupBalance = NewMockGroupBalance()

type MockGroupBalance

type MockGroupBalance struct{}

func NewMockGroupBalance

func NewMockGroupBalance() *MockGroupBalance

func (*MockGroupBalance) GetBalance

func (q *MockGroupBalance) GetBalance(_ context.Context) (float64, error)

func (*MockGroupBalance) GetGroupRemainBalance

func (q *MockGroupBalance) GetGroupRemainBalance(_ context.Context, _ string) (float64, PostGroupConsumer, error)

func (*MockGroupBalance) PostGroupConsume

func (q *MockGroupBalance) PostGroupConsume(_ context.Context, _ string, usage float64) (float64, error)

type PostGroupConsumer

type PostGroupConsumer interface {
	PostGroupConsume(ctx context.Context, tokenName string, usage float64) (float64, error)
	GetBalance(ctx context.Context) (float64, error)
}

type Sealos

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

func NewSealos

func NewSealos(accountURL string) *Sealos

func (*Sealos) GetGroupRemainBalance

func (s *Sealos) GetGroupRemainBalance(ctx context.Context, group string) (float64, PostGroupConsumer, error)

type SealosPostGroupConsumer

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

func (*SealosPostGroupConsumer) GetBalance

func (s *SealosPostGroupConsumer) GetBalance(_ context.Context) (float64, error)

func (*SealosPostGroupConsumer) PostGroupConsume

func (s *SealosPostGroupConsumer) PostGroupConsume(ctx context.Context, tokenName string, usage float64) (float64, error)