system

Documentation

Index

• type Process
  • func (c *Process) HeartBeat(ctx context.Context, lead chan bool)
  • func (c *Process) Register(ctx context.Context, kind string, stg storage.Storage) (*types.Process, error)

Types

type Process

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

func (*Process) HeartBeat

func (c *Process) HeartBeat(ctx context.Context, lead chan bool)

HeartBeat function - updates current process state and master election ttl option

func (*Process) Register

func (c *Process) Register(ctx context.Context, kind string, stg storage.Storage) (*types.Process, error)

Process register function The main purpose is to register process in the system If we need to distribution and need master/replicas, use WaitElected function