tm

Documentation

Index

• type ConsensusService
  • func NewConsensusService(params ConsensusServiceParams) *ConsensusService
  • func (s *ConsensusService) ConsensusStatus(ctx context.Context, opts api.ConsensusStatusOptions) (*api.ConsensusStatus, error)
  • func (s *ConsensusService) Type() api.ServiceType
• type ConsensusServiceParams
• type NodeStatusClient
• type SubmitClient
• type Submitter
  • func NewSubmitter(params SubmitterParams) *Submitter
  • func (s *Submitter) Submit(ctx context.Context, envelope *messaging.Envelope, opts api.SubmitOptions) ([]*api.Submission, error)
  • func (s *Submitter) Type() api.ServiceType
• type SubmitterParams
• type ValidateClient
• type Validator
  • func NewValidator(params ValidatorParams) *Validator
  • func (s *Validator) Type() api.ServiceType
  • func (s *Validator) Validate(ctx context.Context, envelope *messaging.Envelope, opts api.ValidateOptions) ([]*api.Submission, error)
• type ValidatorParams

Types

type ConsensusService

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

func NewConsensusService

func NewConsensusService(params ConsensusServiceParams) *ConsensusService

func (*ConsensusService) ConsensusStatus

func (s *ConsensusService) ConsensusStatus(ctx context.Context, opts api.ConsensusStatusOptions) (*api.ConsensusStatus, error)

func (*ConsensusService) Type

func (s *ConsensusService) Type() api.ServiceType

type ConsensusServiceParams

type ConsensusServiceParams struct {
	Logger           log.Logger
	Local            NodeStatusClient
	Database         database.Viewer
	PartitionID      string
	PartitionType    protocol.PartitionType
	EventBus         *events.Bus
	NodeKeyHash      [32]byte
	ValidatorKeyHash [32]byte
}

type NodeStatusClient

type NodeStatusClient interface {
	Status(context.Context) (*coretypes.ResultStatus, error)
	NetInfo(context.Context) (*coretypes.ResultNetInfo, error)
}

type SubmitClient

type SubmitClient interface {
	BroadcastTxAsync(context.Context, types.Tx) (*coretypes.ResultBroadcastTx, error)
	BroadcastTxSync(context.Context, types.Tx) (*coretypes.ResultBroadcastTx, error)
}

type Submitter

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

func NewSubmitter

func NewSubmitter(params SubmitterParams) *Submitter

func (*Submitter) Submit

func (s *Submitter) Submit(ctx context.Context, envelope *messaging.Envelope, opts api.SubmitOptions) ([]*api.Submission, error)

func (*Submitter) Type

func (s *Submitter) Type() api.ServiceType

type SubmitterParams

type SubmitterParams struct {
	Logger log.Logger
	Local  SubmitClient
}

type ValidateClient

type ValidateClient interface {
	CheckTx(context.Context, types.Tx) (*coretypes.ResultCheckTx, error)
}

type Validator

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

func NewValidator

func NewValidator(params ValidatorParams) *Validator

func (*Validator) Type

func (s *Validator) Type() api.ServiceType

func (*Validator) Validate

func (s *Validator) Validate(ctx context.Context, envelope *messaging.Envelope, opts api.ValidateOptions) ([]*api.Submission, error)

type ValidatorParams

type ValidatorParams struct {
	Logger log.Logger
	Local  ValidateClient
}