cron

Documentation

Index

• type Cluster
  • func TripplePartition(t *testing.T) *Cluster
  • func TripplePartitionRun(t *testing.T) *Cluster
  • func (c *Cluster) Stop(t *testing.T)
• type Cron
  • func SinglePartition(t *testing.T) *Cron
  • func SinglePartitionRun(t *testing.T) *Cron
  • func (c *Cron) Counters(t *testing.T) *clientv3.GetResponse
  • func (c *Cron) Jobs(t *testing.T) *clientv3.GetResponse
  • func (c *Cron) Stop(t *testing.T)

Types

type Cluster

type Cluster struct {
	*Cron
	Crons [3]*Cron
}

func TripplePartition

func TripplePartition(t *testing.T) *Cluster

func TripplePartitionRun

func TripplePartitionRun(t *testing.T) *Cluster

func (*Cluster) Stop

func (c *Cluster) Stop(t *testing.T)

type Cron

type Cron struct {
	api.Interface
	KV    clientv3.KV
	Calls *atomic.Int64
	// contains filtered or unexported fields
}

func SinglePartition

func SinglePartition(t *testing.T) *Cron

func SinglePartitionRun

func SinglePartitionRun(t *testing.T) *Cron

func (*Cron) Counters

func (c *Cron) Counters(t *testing.T) *clientv3.GetResponse

func (*Cron) Jobs

func (c *Cron) Jobs(t *testing.T) *clientv3.GetResponse

func (*Cron) Stop

func (c *Cron) Stop(t *testing.T)