tm

Documentation

Index

• type NodeService
  • func NewNodeService(params NodeServiceParams) *NodeService
  • func (s *NodeService) NodeStatus(ctx context.Context, _ api.NodeStatusOptions) (*api.NodeStatus, error)
• type NodeServiceParams
• type NodeStatusClient
• type SubmitClient
• type Submitter
  • func NewSubmitter(params SubmitterParams) *Submitter
  • func (s *Submitter) Submit(ctx context.Context, envelope *protocol.Envelope, opts api.SubmitOptions) ([]*api.Submission, error)
• type SubmitterParams
• type ValidateClient
• type Validator
  • func NewValidator(params ValidatorParams) *Validator
  • func (s *Validator) Validate(ctx context.Context, envelope *protocol.Envelope, opts api.ValidateOptions) ([]*api.Submission, error)
• type ValidatorParams

Types

type NodeService

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

func NewNodeService

func NewNodeService(params NodeServiceParams) *NodeService

func (*NodeService) NodeStatus

func (s *NodeService) NodeStatus(ctx context.Context, _ api.NodeStatusOptions) (*api.NodeStatus, error)

type NodeServiceParams

type NodeServiceParams 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 *protocol.Envelope, opts api.SubmitOptions) ([]*api.Submission, error)

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) Validate

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

type ValidatorParams

type ValidatorParams struct {
	Logger log.Logger
	Local  ValidateClient
}