coordinator

Documentation

Index

• Variables
• type Coordinator
  • func NewCoordinator(c CoordinatorConfig) *Coordinator
  • func (co *Coordinator) Bootstrap(ctx context.Context) error
  • func (co *Coordinator) Close(ctx context.Context) error
  • func (co *Coordinator) Run(ctx context.Context) error
• type CoordinatorConfig

Variables

var ErrRoundNotMatch = errors.New("start and end round not match")

Types

type Coordinator

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

func NewCoordinator

func NewCoordinator(c CoordinatorConfig) *Coordinator

func (*Coordinator) Bootstrap

func (co *Coordinator) Bootstrap(ctx context.Context) error

func (*Coordinator) Close

func (co *Coordinator) Close(ctx context.Context) error

func (*Coordinator) Run

func (co *Coordinator) Run(ctx context.Context) error

type CoordinatorConfig

type CoordinatorConfig struct {
	ServerN int

	// Redis addr
	RAddr string
	// MongoDB URI
	MURI string
}