types

Documentation

Index

• type Host
• type ProcessPoll
• type ProcessSnapshots
• type Receiver

Types

type Host

type Host interface {
	ReportFatalError(err error)
}

type ProcessPoll

type ProcessPoll func(ctx context.Context, pollRequest *pb.PollRequest) (*pb.PollResponse, error)

type ProcessSnapshots

type ProcessSnapshots func(ctx context.Context, in *tp.Snapshot) (*tp.SnapshotResponse, error)

type Receiver

type Receiver interface {
	Start(ctx context.Context, host Host) error

	Shutdown(ctx context.Context) error
}