nwpd

type AgentService interface {
	GetObservations(context.Context, *GetObservationsRequest) (*GetObservationsResponse, error)

	GetAggregatedObservations(context.Context, *GetObservationsRequest) (*GetAggregatedObservationsResponse, error)
}

type AggregatedObservation struct {
	SrcHost        string                          `protobuf:"bytes,1,opt,name=srcHost,proto3" json:"srcHost,omitempty"`
	DestHost       string                          `protobuf:"bytes,2,opt,name=destHost,proto3" json:"destHost,omitempty"`
	PeriodStart    *timestamppb.Timestamp          `protobuf:"bytes,3,opt,name=periodStart,proto3" json:"periodStart,omitempty"`
	PeriodEnd      *timestamppb.Timestamp          `protobuf:"bytes,4,opt,name=periodEnd,proto3" json:"periodEnd,omitempty"`
	JobsOkCount    map[string]int32                `` /* 164-byte string literal not displayed */
	JobsNotOkCount map[string]int32                `` /* 170-byte string literal not displayed */
	MeanOkDuration map[string]*durationpb.Duration `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetAggregatedObservationsResponse struct {
	AggregatedObservations []*AggregatedObservation `protobuf:"bytes,1,rep,name=aggregatedObservations,proto3" json:"aggregatedObservations,omitempty"`
	// contains filtered or unexported fields
}

type GetObservationsRequest struct {
	Start               *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                 *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Limit               int32                  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	RestrictToJobIDs    []string               `protobuf:"bytes,4,rep,name=restrictToJobIDs,proto3" json:"restrictToJobIDs,omitempty"`
	RestrictToSrcHosts  []string               `protobuf:"bytes,5,rep,name=restrictToSrcHosts,proto3" json:"restrictToSrcHosts,omitempty"`
	RestrictToDestHosts []string               `protobuf:"bytes,6,rep,name=restrictToDestHosts,proto3" json:"restrictToDestHosts,omitempty"`
	AggregationWindow   *durationpb.Duration   `protobuf:"bytes,7,opt,name=aggregationWindow,proto3" json:"aggregationWindow,omitempty"`
	FailuresOnly        bool                   `protobuf:"varint,8,opt,name=failuresOnly,proto3" json:"failuresOnly,omitempty"`
	// contains filtered or unexported fields
}

type GetObservationsResponse struct {
	Observations []*Observation `protobuf:"bytes,1,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type Int64Arrays struct {
	Array []int64 `protobuf:"varint,1,rep,packed,name=array,proto3" json:"array,omitempty"`
	// contains filtered or unexported fields
}

type IntObservation struct {
	JobID          int64 `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty"`
	SrcHost        int64 `protobuf:"varint,2,opt,name=srcHost,proto3" json:"srcHost,omitempty"`
	DestHost       int64 `protobuf:"varint,3,opt,name=destHost,proto3" json:"destHost,omitempty"`
	TimeMillis     int64 `protobuf:"varint,4,opt,name=timeMillis,proto3" json:"timeMillis,omitempty"`
	DurationMillis int32 `protobuf:"varint,5,opt,name=durationMillis,proto3" json:"durationMillis,omitempty"`
	Ok             bool  `protobuf:"varint,6,opt,name=ok,proto3" json:"ok,omitempty"`
	PeriodMillis   int32 `protobuf:"varint,7,opt,name=periodMillis,proto3" json:"periodMillis,omitempty"`
	// contains filtered or unexported fields
}

type IntString struct {
	Key   int64  `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ListObservationsOptions struct {
	Start           time.Time
	End             time.Time
	Limit           int
	FilterJobIDs    []string
	FilterSrcHosts  []string
	FilterDestHosts []string
	FailuresOnly    bool
}

type Observation struct {
	JobID     string                 `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	SrcHost   string                 `protobuf:"bytes,2,opt,name=srcHost,proto3" json:"srcHost,omitempty"`
	DestHost  string                 `protobuf:"bytes,3,opt,name=destHost,proto3" json:"destHost,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Duration  *durationpb.Duration   `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	Result    string                 `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"` // not persisted
	Ok        bool                   `protobuf:"varint,7,opt,name=ok,proto3" json:"ok,omitempty"`
	Period    *durationpb.Duration   `protobuf:"bytes,8,opt,name=period,proto3" json:"period,omitempty"`
	// contains filtered or unexported fields
}

type ObservationListener interface {
	Add(obs *Observation)
}

type ObservationWriter interface {
	ObservationListener
	Run()
	Stop()
	ListObservations(options ListObservationsOptions) (Observations, error)
}

type Observations []*Observation

type TwirpServer interface {
	http.Handler

	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// google.golang.org/protobuf/types/descriptorpb.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)

	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string

	// PathPrefix returns the HTTP URL path prefix for all methods handled by this
	// service. This can be used with an HTTP mux to route Twirp requests.
	// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
	// that is, everything in a Twirp route except for the <Method> at the end.
	PathPrefix() string
}