timer

Documentation

Index

• type Grain
  • func (g *Grain) CreateTimer(req *protobuf.TimerRequest, ctx cluster.GrainContext) (*protobuf.TimerResponse, error)
  • func (g *Grain) Decode(b []byte) error
  • func (g *Grain) Encode() ([]byte, error)
  • func (g *Grain) Identity() string
  • func (g *Grain) Init(ctx cluster.GrainContext)
  • func (g *Grain) Kind() string
  • func (g *Grain) ReceiveDefault(ctx cluster.GrainContext)
  • func (g *Grain) Restore(req *protobuf.RestoreRequest, ctx cluster.GrainContext) (*protobuf.RestoreResponse, error)
  • func (g *Grain) Terminate(ctx cluster.GrainContext)
• type Timer

Types

type Grain

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

func (*Grain) CreateTimer

func (g *Grain) CreateTimer(req *protobuf.TimerRequest, ctx cluster.GrainContext) (*protobuf.TimerResponse, error)

func (*Grain) Decode

func (g *Grain) Decode(b []byte) error

func (*Grain) Encode

func (g *Grain) Encode() ([]byte, error)

func (*Grain) Identity

func (g *Grain) Identity() string

func (*Grain) Init

func (g *Grain) Init(ctx cluster.GrainContext)

func (*Grain) Kind

func (g *Grain) Kind() string

func (*Grain) ReceiveDefault

func (g *Grain) ReceiveDefault(ctx cluster.GrainContext)

func (*Grain) Restore

func (g *Grain) Restore(req *protobuf.RestoreRequest, ctx cluster.GrainContext) (*protobuf.RestoreResponse, error)

func (*Grain) Terminate

func (g *Grain) Terminate(ctx cluster.GrainContext)

type Timer

type Timer struct {
	Reply    string
	Amount   int64
	Start    time.Time
	Interval time.Duration
	Data     map[string]interface{}
}