pb

type Config struct {
	Samples    int32       `protobuf:"varint,1,opt,name=Samples,proto3" json:"Samples,omitempty"`
	IPBytes    []byte      `protobuf:"bytes,2,opt,name=IPBytes,proto3" json:"IPBytes,omitempty"`
	IPNatBytes []byte      `protobuf:"bytes,3,opt,name=IPNatBytes,proto3" json:"IPNatBytes,omitempty"`
	BaseChecks [][]byte    `protobuf:"bytes,4,rep,name=BaseChecks,proto3" json:"BaseChecks,omitempty"`
	MQTTConfig *MQTTConfig `protobuf:"bytes,5,opt,name=MQTTConfig,proto3" json:"MQTTConfig,omitempty"`
	// contains filtered or unexported fields
}

type GetConfigParams struct {
	// contains filtered or unexported fields
}

type GetServersParams struct {
	// contains filtered or unexported fields
}

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

type MQTTConfig struct {
	Host   []byte `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Port   int32  `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	JWT    []byte `protobuf:"bytes,3,opt,name=JWT,proto3" json:"JWT,omitempty"`
	Prefix []byte `protobuf:"bytes,4,opt,name=Prefix,proto3" json:"Prefix,omitempty"` // base prefix for topic ("/devel/monitors/" for example)
	// contains filtered or unexported fields
}

type Monitor interface {
	GetConfig(context.Context, *GetConfigParams) (*Config, error)

	// GetServers fetches list of NTP servers to check
	GetServers(context.Context, *GetServersParams) (*ServerList, error)

	// SubmitResults returns the specified list ServerStatus to the monitoring server
	SubmitResults(context.Context, *ServerStatusList) (*ServerStatusResult, error)
}

type Server struct {
	IPBytes []byte `protobuf:"bytes,1,opt,name=IPBytes,proto3" json:"IPBytes,omitempty"`
	Ticket  []byte `protobuf:"bytes,2,opt,name=Ticket,proto3" json:"Ticket,omitempty"`
	Trace   bool   `protobuf:"varint,3,opt,name=Trace,proto3" json:"Trace,omitempty"`
	// contains filtered or unexported fields
}

type ServerList struct {
	Config  *Config   `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Servers []*Server `protobuf:"bytes,2,rep,name=Servers,proto3" json:"Servers,omitempty"`
	BatchID []byte    `protobuf:"bytes,3,opt,name=BatchID,proto3" json:"BatchID,omitempty"` // todo future api: move this first
	// contains filtered or unexported fields
}

type ServerStatus struct {
	Ticket     []byte                 `protobuf:"bytes,1,opt,name=Ticket,proto3" json:"Ticket,omitempty"`
	IPBytes    []byte                 `protobuf:"bytes,2,opt,name=IPBytes,proto3" json:"IPBytes,omitempty"`
	TS         *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=TS,proto3" json:"TS,omitempty"`
	Offset     *durationpb.Duration   `protobuf:"bytes,4,opt,name=Offset,proto3" json:"Offset,omitempty"`
	RTT        *durationpb.Duration   `protobuf:"bytes,5,opt,name=RTT,proto3" json:"RTT,omitempty"`
	Stratum    int32                  `protobuf:"varint,6,opt,name=Stratum,proto3" json:"Stratum,omitempty"`
	Leap       int32                  `protobuf:"zigzag32,7,opt,name=Leap,proto3" json:"Leap,omitempty"`
	Error      string                 `protobuf:"bytes,8,opt,name=Error,proto3" json:"Error,omitempty"`
	NoResponse bool                   `protobuf:"varint,9,opt,name=NoResponse,proto3" json:"NoResponse,omitempty"`
	// contains filtered or unexported fields
}

type ServerStatusList struct {
	Version int32           `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	List    []*ServerStatus `protobuf:"bytes,2,rep,name=List,proto3" json:"List,omitempty"`
	BatchID []byte          `protobuf:"bytes,3,opt,name=BatchID,proto3" json:"BatchID,omitempty"`
	// contains filtered or unexported fields
}

type ServerStatusResult struct {
	Ok bool `protobuf:"varint,1,opt,name=Ok,proto3" json:"Ok,omitempty"`
	// contains filtered or unexported fields
}

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
}