sync

Documentation

Index

• type GoMakeRing
  • func (g *GoMakeRing) Play(ctx *runtime.Context) GoRingConn
• type GoRingConn
• type GoRingLease
  • func (g *GoRingLease) Play(ctx *runtime.Context) int64

Types

type GoMakeRing

type GoMakeRing struct {
	Cap int64 `ko:"name=cap,monadic"`
}

func (*GoMakeRing) Play

func (g *GoMakeRing) Play(ctx *runtime.Context) GoRingConn

type GoRingConn

type GoRingConn interface {
	GoRingConn()
	Lease() int64 // returns the sequential number of the lease
}

type GoRingLease

type GoRingLease struct {
	Conn GoRingConn `ko:"name=conn,monadic"`
}

func (*GoRingLease) Play

func (g *GoRingLease) Play(ctx *runtime.Context) int64