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 {
	Kind        protobuf.TimerKind
	InventoryID string
	Reply       string
	Amount      int64
	Start       time.Time
	Interval    time.Duration
	Data        map[string]interface{}
}