service

type Client interface {
	Close() error
	GetID() string
	Send(*pb.TheRequest) (*pb.TheResponse, error)
}

type Config struct {
	ID                          string
	GRPCServerPort              int
	H1ServerPort                int
	GRPCDownstreamServers       []string
	GRPCProxy                   string
	H1DownstreamServers         []string
	PercentageFailedRequests    int
	SleepInMillis               int
	TerminateAfter              int
	FireAndForget               bool
	DownstreamConnectionTimeout time.Duration
	ExtraArguments              map[string]string
}

type MockClient struct {
	IDToReturn         string
	ResponseToReturn   *pb.TheResponse
	ErrorToReturn      error
	RequestReceived    *pb.TheRequest
	RequestInterceptor func(req *pb.TheRequest)
	CloseWasCalled     bool
}

type MockServer struct {
	IDToReturn string
}

type MockStrategy struct {
	ContextReceived  context.Context
	RequestReceived  *pb.TheRequest
	ResponseToReturn *pb.TheResponse
	ErrorToReturn    error
}

type RequestHandler struct {
	Strategy Strategy // public due to circular dependency between server and strategy
	// contains filtered or unexported fields
}

type Server interface {
	GetID() string
	Shutdown() error
}

type Service struct {
	Servers  []Server
	Clients  []Client
	Strategy Strategy
}

type Strategy interface {
	Do(context.Context, *pb.TheRequest) (*pb.TheResponse, error)
}