svc

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 18, 2020 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.0.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL