staking

Documentation

Index

• type BeginRedelegateMsg
  • func (msg BeginRedelegateMsg) String() string
• type CreateValidatorMsg
  • func (msg CreateValidatorMsg) String() string
• type DelegateMsg
  • func (msg DelegateMsg) String() string
• type StakingProcessor
  • func NewStakingProcessor(cfg StakingProcessorConfig, cosmosClient *cosmos.CosmosClient, db *store.Store, ...) (*StakingProcessor, error)
  • func (p *StakingProcessor) Process(ctx context.Context, receipt *sdk.TxResponse) error
  • func (p *StakingProcessor) Queue(msg interface{})
  • func (p *StakingProcessor) Start(ctx context.Context)
• type StakingProcessorConfig
  • func DefaultConfig() StakingProcessorConfig
  • func (cfg StakingProcessorConfig) IsValid() (bool, error)
• type UndelegateMsg
  • func (msg UndelegateMsg) String() string

Types

type BeginRedelegateMsg

type BeginRedelegateMsg struct {
	processorCommon.TxMsg
	FromValidator string
	ToValidator   string
}

func (BeginRedelegateMsg) String

func (msg BeginRedelegateMsg) String() string

type CreateValidatorMsg

type CreateValidatorMsg struct {
	processorCommon.TxMsg
	Address    string
	Name       string
	Commission float64
}

func (CreateValidatorMsg) String

func (msg CreateValidatorMsg) String() string

type DelegateMsg

type DelegateMsg struct {
	processorCommon.TxMsg
	Validator string
}

func (DelegateMsg) String

func (msg DelegateMsg) String() string

type StakingProcessor

type StakingProcessor struct {
	*processorCommon.BaseProcessor
	*cosmos.CosmosClient
	// contains filtered or unexported fields
}

func NewStakingProcessor

func NewStakingProcessor(cfg StakingProcessorConfig,
	cosmosClient *cosmos.CosmosClient,
	db *store.Store,
	log logger.Logger,
) (*StakingProcessor, error)

func (*StakingProcessor) Process

func (p *StakingProcessor) Process(ctx context.Context, receipt *sdk.TxResponse) error

func (*StakingProcessor) Queue

func (p *StakingProcessor) Queue(msg interface{})

func (*StakingProcessor) Start

func (p *StakingProcessor) Start(ctx context.Context)

type StakingProcessorConfig

type StakingProcessorConfig struct {
	common.BaseConfig
}

func DefaultConfig

func DefaultConfig() StakingProcessorConfig

func (StakingProcessorConfig) IsValid

func (cfg StakingProcessorConfig) IsValid() (bool, error)

type UndelegateMsg

type UndelegateMsg struct {
	processorCommon.TxMsg
	Validator string
}

func (UndelegateMsg) String

func (msg UndelegateMsg) String() string