svc

Documentation

Index

• type CancelArgs
  • func (a *CancelArgs) SetPending(p *Pending)
• type GoRPC
  • func (s *GoRPC) Cancel(ctx context.Context, args *CancelArgs, reply *bool) error
• type Pending
  • func NewPending(parent context.Context) *Pending
  • func (s *Pending) Cancel(seq uint64)
  • func (s *Pending) Start(seq uint64) context.Context

Types

type CancelArgs

type CancelArgs struct {
	// Seq is the sequence number for the rpc.Call to cancel.
	Seq uint64
	// contains filtered or unexported fields
}

func (*CancelArgs) SetPending

func (a *CancelArgs) SetPending(p *Pending)

SetPending sets the pending map for the server to use. Do not use on the client.

type GoRPC

type GoRPC struct{}

GoRPC is an internal service used by rpc.

func (*GoRPC) Cancel

func (s *GoRPC) Cancel(ctx context.Context, args *CancelArgs, reply *bool) error

type Pending

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

Pending manages a map of all pending requests to a rpc.Service for a connection (an rpc.ServerCodec).

func NewPending

func NewPending(parent context.Context) *Pending

func (*Pending) Cancel

func (s *Pending) Cancel(seq uint64)

func (*Pending) Start

func (s *Pending) Start(seq uint64) context.Context