cohort

Documentation

Index

• type Cohort
• type CohortImpl
  • func NewCohort(tracer *zipkin.Tracer, committer *commitalgo.Committer, commitType Mode) *CohortImpl
  • func (c *CohortImpl) Commit(ctx context.Context, in *entity.CommitRequest) (resp *entity.CohortResponse, err error)
  • func (c *CohortImpl) Height() uint64
  • func (s *CohortImpl) Precommit(ctx context.Context, index uint64, votes []*entity.Vote) (*entity.CohortResponse, error)
  • func (c *CohortImpl) Propose(ctx context.Context, req *entity.ProposeRequest) (*entity.CohortResponse, error)
• type Mode
• type PrecommitRequest

Types

type Cohort

type Cohort interface {
	Propose(ctx context.Context, req *entity.ProposeRequest) (*entity.CohortResponse, error)
	Precommit(ctx context.Context, index uint64, votes []*entity.Vote) (*entity.CohortResponse, error)
	Commit(ctx context.Context, in *entity.CommitRequest) (*entity.CohortResponse, error)
	Height() uint64
}

type CohortImpl

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

func NewCohort

func NewCohort(
	tracer *zipkin.Tracer,
	committer *commitalgo.Committer,
	commitType Mode) *CohortImpl

func (*CohortImpl) Commit

func (c *CohortImpl) Commit(ctx context.Context, in *entity.CommitRequest) (resp *entity.CohortResponse, err error)

func (*CohortImpl) Height

func (c *CohortImpl) Height() uint64

func (*CohortImpl) Precommit

func (s *CohortImpl) Precommit(ctx context.Context, index uint64, votes []*entity.Vote) (*entity.CohortResponse, error)

func (*CohortImpl) Propose

func (c *CohortImpl) Propose(ctx context.Context, req *entity.ProposeRequest) (*entity.CohortResponse, error)

type Mode

type Mode string

const THREE_PHASE Mode = "three-phase"

type PrecommitRequest

type PrecommitRequest struct {
	Index uint64         `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Votes []*entity.Vote `protobuf:"bytes,2,rep,name=votes,proto3" json:"votes,omitempty"`
}