executor

Documentation

Index

• type RPCExecutor
  • func NewRPCExecutor(catService *services.CatService, birdsService *services.BirdService, ...) *RPCExecutor
  • func (RPCexecutor RPCExecutor) GetAllPets() (result *RPCResult, err error)
• type RPCResult

Types

type RPCExecutor

type RPCExecutor struct {
	CatService *services.CatService

	BirdsService *services.BirdService

	DogsService *services.DogsService
}

RPCExecutor is in charge of performing all the RPC requests.

func NewRPCExecutor

func NewRPCExecutor(catService *services.CatService, birdsService *services.BirdService,
	dogsService *services.DogsService) *RPCExecutor

func (RPCExecutor) GetAllPets

func (RPCexecutor RPCExecutor) GetAllPets() (result *RPCResult, err error)

GetAllPets calls the various pet RPCs in parallel, collects all the results and returns them. If there is an error, or time report and return.

type RPCResult

type RPCResult struct {
	Cats  []*catModels.Cat    `json:"cats"`
	Birds []*birdsModels.Bird `json:"birds"`
	Dogs  []*dogsModels.Dog   `json:"dogs"`
}