proto

package
v0.0.0-...-bfb58f9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 14, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CapturerStatus_name = map[int32]string{
		0: "CAPTURER_STATUS_OK",
		1: "CAPTURER_STATUS_CONNECTION_RETRY",
	}
	CapturerStatus_value = map[string]int32{
		"CAPTURER_STATUS_OK":               0,
		"CAPTURER_STATUS_CONNECTION_RETRY": 1,
	}
)

Enum value maps for CapturerStatus.

View Source 
var (
	HealthCheckResponse_ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	HealthCheckResponse_ServingStatus_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for HealthCheckResponse_ServingStatus.

View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var File_system_proto protoreflect.FileDescriptor

Functions

func RegisterHealthServer 

func RegisterHealthServer(s *grpc.Server, srv HealthServer)

func RegisterNodeServer 

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type AddCapturerRequest 

type AddCapturerRequest struct {
	CapturerUuid string `protobuf:"bytes,1,opt,name=capturer_uuid,json=capturerUuid,proto3" json:"capturer_uuid,omitempty"`
	CapturerUrl  string `protobuf:"bytes,2,opt,name=capturer_url,json=capturerUrl,proto3" json:"capturer_url,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCapturerRequest) Descriptor deprecated 

func (*AddCapturerRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddCapturerRequest.ProtoReflect.Descriptor instead.

func (*AddCapturerRequest) GetCapturerUrl 

func (x *AddCapturerRequest) GetCapturerUrl() string

func (*AddCapturerRequest) GetCapturerUuid 

func (x *AddCapturerRequest) GetCapturerUuid() string

func (*AddCapturerRequest) ProtoMessage 

func (*AddCapturerRequest) ProtoMessage()

func (*AddCapturerRequest) ProtoReflect 

func (x *AddCapturerRequest) ProtoReflect() protoreflect.Message

func (*AddCapturerRequest) Reset 

func (x *AddCapturerRequest) Reset()

func (*AddCapturerRequest) String 

func (x *AddCapturerRequest) String() string

type Capturer 

type Capturer struct {
	Uuid   string         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Url    string         `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Status CapturerStatus `protobuf:"varint,3,opt,name=status,proto3,enum=proto.CapturerStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Capturer) Descriptor deprecated 

func (*Capturer) Descriptor() ([]byte, []int)

Deprecated: Use Capturer.ProtoReflect.Descriptor instead.

func (*Capturer) GetStatus 

func (x *Capturer) GetStatus() CapturerStatus

func (*Capturer) GetUrl 

func (x *Capturer) GetUrl() string

func (*Capturer) GetUuid 

func (x *Capturer) GetUuid() string

func (*Capturer) ProtoMessage 

func (*Capturer) ProtoMessage()

func (*Capturer) ProtoReflect 

func (x *Capturer) ProtoReflect() protoreflect.Message

func (*Capturer) Reset 

func (x *Capturer) Reset()

func (*Capturer) String 

func (x *Capturer) String() string

type CapturerStatus 

type CapturerStatus int32
const (
	CapturerStatus_CAPTURER_STATUS_OK               CapturerStatus = 0
	CapturerStatus_CAPTURER_STATUS_CONNECTION_RETRY CapturerStatus = 1
)

func (CapturerStatus) Descriptor 

func (CapturerStatus) Descriptor() protoreflect.EnumDescriptor

func (CapturerStatus) Enum 

func (x CapturerStatus) Enum() *CapturerStatus

func (CapturerStatus) EnumDescriptor deprecated 

func (CapturerStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use CapturerStatus.Descriptor instead.

func (CapturerStatus) Number 

func (x CapturerStatus) Number() protoreflect.EnumNumber

func (CapturerStatus) String 

func (x CapturerStatus) String() string

func (CapturerStatus) Type 

func (CapturerStatus) Type() protoreflect.EnumType

type HealthCheckRequest 

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequest) Descriptor deprecated 

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService 

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=proto.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) Descriptor 

func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthCheckResponse_ServingStatus) Enum 

func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus

func (HealthCheckResponse_ServingStatus) EnumDescriptor deprecated 

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.

func (HealthCheckResponse_ServingStatus) Number 

func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

func (HealthCheckResponse_ServingStatus) Type 

func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType

type HealthClient 

type HealthClient interface {
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error)
}

HealthClient is the client API for Health service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHealthClient 

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthServer 

type HealthServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	Watch(*HealthCheckRequest, Health_WatchServer) error
}

HealthServer is the server API for Health service.

type Health_WatchClient 

type Health_WatchClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type Health_WatchServer 

type Health_WatchServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

type InformStatusRequest 

type InformStatusRequest struct {
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*InformStatusRequest) Descriptor deprecated 

func (*InformStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use InformStatusRequest.ProtoReflect.Descriptor instead.

func (*InformStatusRequest) GetInterval 

func (x *InformStatusRequest) GetInterval() *duration.Duration

func (*InformStatusRequest) ProtoMessage 

func (*InformStatusRequest) ProtoMessage()

func (*InformStatusRequest) ProtoReflect 

func (x *InformStatusRequest) ProtoReflect() protoreflect.Message

func (*InformStatusRequest) Reset 

func (x *InformStatusRequest) Reset()

func (*InformStatusRequest) String 

func (x *InformStatusRequest) String() string

type LoadAverage 

type LoadAverage struct {
	Avg_1  float64 `protobuf:"fixed64,1,opt,name=avg_1,json=avg1,proto3" json:"avg_1,omitempty"`
	Avg_5  float64 `protobuf:"fixed64,2,opt,name=avg_5,json=avg5,proto3" json:"avg_5,omitempty"`
	Avg_15 float64 `protobuf:"fixed64,3,opt,name=avg_15,json=avg15,proto3" json:"avg_15,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadAverage) Descriptor deprecated 

func (*LoadAverage) Descriptor() ([]byte, []int)

Deprecated: Use LoadAverage.ProtoReflect.Descriptor instead.

func (*LoadAverage) GetAvg_1 

func (x *LoadAverage) GetAvg_1() float64

func (*LoadAverage) GetAvg_15 

func (x *LoadAverage) GetAvg_15() float64

func (*LoadAverage) GetAvg_5 

func (x *LoadAverage) GetAvg_5() float64

func (*LoadAverage) ProtoMessage 

func (*LoadAverage) ProtoMessage()

func (*LoadAverage) ProtoReflect 

func (x *LoadAverage) ProtoReflect() protoreflect.Message

func (*LoadAverage) Reset 

func (x *LoadAverage) Reset()

func (*LoadAverage) String 

func (x *LoadAverage) String() string

type LoadCategoriesRequest 

type LoadCategoriesRequest struct {
	Categories []string `protobuf:"bytes,1,rep,name=categories,proto3" json:"categories,omitempty"`
	Image      []byte   `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadCategoriesRequest) Descriptor deprecated 

func (*LoadCategoriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadCategoriesRequest.ProtoReflect.Descriptor instead.

func (*LoadCategoriesRequest) GetCategories 

func (x *LoadCategoriesRequest) GetCategories() []string

func (*LoadCategoriesRequest) GetImage 

func (x *LoadCategoriesRequest) GetImage() []byte

func (*LoadCategoriesRequest) ProtoMessage 

func (*LoadCategoriesRequest) ProtoMessage()

func (*LoadCategoriesRequest) ProtoReflect 

func (x *LoadCategoriesRequest) ProtoReflect() protoreflect.Message

func (*LoadCategoriesRequest) Reset 

func (x *LoadCategoriesRequest) Reset()

func (*LoadCategoriesRequest) String 

func (x *LoadCategoriesRequest) String() string

type Memory 

type Memory struct {
	TotalMemoryBytes uint64 `protobuf:"varint,1,opt,name=total_memory_bytes,json=totalMemoryBytes,proto3" json:"total_memory_bytes,omitempty"`
	UsedMemoryBytes  uint64 `protobuf:"varint,2,opt,name=used_memory_bytes,json=usedMemoryBytes,proto3" json:"used_memory_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*Memory) Descriptor deprecated 

func (*Memory) Descriptor() ([]byte, []int)

Deprecated: Use Memory.ProtoReflect.Descriptor instead.

func (*Memory) GetTotalMemoryBytes 

func (x *Memory) GetTotalMemoryBytes() uint64

func (*Memory) GetUsedMemoryBytes 

func (x *Memory) GetUsedMemoryBytes() uint64

func (*Memory) ProtoMessage 

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect 

func (x *Memory) ProtoReflect() protoreflect.Message

func (*Memory) Reset 

func (x *Memory) Reset()

func (*Memory) String 

func (x *Memory) String() string

type Network 

type Network struct {
	TxBytesSec uint64 `protobuf:"varint,1,opt,name=tx_bytes_sec,json=txBytesSec,proto3" json:"tx_bytes_sec,omitempty"`
	RxBytesSec uint64 `protobuf:"varint,2,opt,name=rx_bytes_sec,json=rxBytesSec,proto3" json:"rx_bytes_sec,omitempty"`
	// contains filtered or unexported fields
}

func (*Network) Descriptor deprecated 

func (*Network) Descriptor() ([]byte, []int)

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetRxBytesSec 

func (x *Network) GetRxBytesSec() uint64

func (*Network) GetTxBytesSec 

func (x *Network) GetTxBytesSec() uint64

func (*Network) ProtoMessage 

func (*Network) ProtoMessage()

func (*Network) ProtoReflect 

func (x *Network) ProtoReflect() protoreflect.Message

func (*Network) Reset 

func (x *Network) Reset()

func (*Network) String 

func (x *Network) String() string

type NodeClient 

type NodeClient interface {
	LoadCategories(ctx context.Context, in *LoadCategoriesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	InformStatus(ctx context.Context, in *InformStatusRequest, opts ...grpc.CallOption) (Node_InformStatusClient, error)
	ProcessResults(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Node_ProcessResultsClient, error)
	AddCapturer(ctx context.Context, in *AddCapturerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RemoveCapturer(ctx context.Context, in *RemoveCapturerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient 

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeServer 

type NodeServer interface {
	LoadCategories(context.Context, *LoadCategoriesRequest) (*empty.Empty, error)
	InformStatus(*InformStatusRequest, Node_InformStatusServer) error
	ProcessResults(*empty.Empty, Node_ProcessResultsServer) error
	AddCapturer(context.Context, *AddCapturerRequest) (*empty.Empty, error)
	RemoveCapturer(context.Context, *RemoveCapturerRequest) (*empty.Empty, error)
}

NodeServer is the server API for Node service.

type Node_InformStatusClient 

type Node_InformStatusClient interface {
	Recv() (*Status, error)
	grpc.ClientStream
}

type Node_InformStatusServer 

type Node_InformStatusServer interface {
	Send(*Status) error
	grpc.ServerStream
}

type Node_ProcessResultsClient 

type Node_ProcessResultsClient interface {
	Recv() (*Result, error)
	grpc.ClientStream
}

type Node_ProcessResultsServer 

type Node_ProcessResultsServer interface {
	Send(*Result) error
	grpc.ServerStream
}

type RemoveCapturerRequest 

type RemoveCapturerRequest struct {
	CapturerUuid string `protobuf:"bytes,1,opt,name=capturer_uuid,json=capturerUuid,proto3" json:"capturer_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveCapturerRequest) Descriptor deprecated 

func (*RemoveCapturerRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveCapturerRequest.ProtoReflect.Descriptor instead.

func (*RemoveCapturerRequest) GetCapturerUuid 

func (x *RemoveCapturerRequest) GetCapturerUuid() string

func (*RemoveCapturerRequest) ProtoMessage 

func (*RemoveCapturerRequest) ProtoMessage()

func (*RemoveCapturerRequest) ProtoReflect 

func (x *RemoveCapturerRequest) ProtoReflect() protoreflect.Message

func (*RemoveCapturerRequest) Reset 

func (x *RemoveCapturerRequest) Reset()

func (*RemoveCapturerRequest) String 

func (x *RemoveCapturerRequest) String() string

type Result 

type Result struct {
	CapturerUuid  string               `protobuf:"bytes,1,opt,name=capturer_uuid,json=capturerUuid,proto3" json:"capturer_uuid,omitempty"`
	Recognized    []string             `protobuf:"bytes,2,rep,name=recognized,proto3" json:"recognized,omitempty"`
	TotalEntities int32                `protobuf:"varint,3,opt,name=totalEntities,proto3" json:"totalEntities,omitempty"`
	RecognizedAt  *timestamp.Timestamp `protobuf:"bytes,4,opt,name=recognized_at,json=recognizedAt,proto3" json:"recognized_at,omitempty"`
	CapturedAt    *timestamp.Timestamp `protobuf:"bytes,5,opt,name=captured_at,json=capturedAt,proto3" json:"captured_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Result) Descriptor deprecated 

func (*Result) Descriptor() ([]byte, []int)

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetCapturedAt 

func (x *Result) GetCapturedAt() *timestamp.Timestamp

func (*Result) GetCapturerUuid 

func (x *Result) GetCapturerUuid() string

func (*Result) GetRecognized 

func (x *Result) GetRecognized() []string

func (*Result) GetRecognizedAt 

func (x *Result) GetRecognizedAt() *timestamp.Timestamp

func (*Result) GetTotalEntities 

func (x *Result) GetTotalEntities() int32

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

func (x *Result) ProtoReflect() protoreflect.Message

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type Status 

type Status struct {
	Description string      `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Capturers   []*Capturer `protobuf:"bytes,2,rep,name=capturers,proto3" json:"capturers,omitempty"`
	System      *System     `protobuf:"bytes,3,opt,name=system,proto3" json:"system,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCapturers 

func (x *Status) GetCapturers() []*Capturer

func (*Status) GetDescription 

func (x *Status) GetDescription() string

func (*Status) GetSystem 

func (x *Status) GetSystem() *System

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type System 

type System struct {
	CpuCount    int32        `protobuf:"varint,1,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	Memory      *Memory      `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	LoadAverage *LoadAverage `protobuf:"bytes,3,opt,name=load_average,json=loadAverage,proto3" json:"load_average,omitempty"`
	Network     *Network     `protobuf:"bytes,4,opt,name=network,proto3" json:"network,omitempty"`
	// contains filtered or unexported fields
}

func (*System) Descriptor deprecated 

func (*System) Descriptor() ([]byte, []int)

Deprecated: Use System.ProtoReflect.Descriptor instead.

func (*System) GetCpuCount 

func (x *System) GetCpuCount() int32

func (*System) GetLoadAverage 

func (x *System) GetLoadAverage() *LoadAverage

func (*System) GetMemory 

func (x *System) GetMemory() *Memory

func (*System) GetNetwork 

func (x *System) GetNetwork() *Network

func (*System) ProtoMessage 

func (*System) ProtoMessage()

func (*System) ProtoReflect 

func (x *System) ProtoReflect() protoreflect.Message

func (*System) Reset 

func (x *System) Reset()

func (*System) String 

func (x *System) String() string

type UnimplementedHealthServer 

type UnimplementedHealthServer struct {
}

UnimplementedHealthServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthServer) Check 

func (*UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (*UnimplementedHealthServer) Watch 

func (*UnimplementedHealthServer) Watch(*HealthCheckRequest, Health_WatchServer) error

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeServer) AddCapturer 

func (*UnimplementedNodeServer) AddCapturer(context.Context, *AddCapturerRequest) (*empty.Empty, error)

func (*UnimplementedNodeServer) InformStatus 

func (*UnimplementedNodeServer) InformStatus(*InformStatusRequest, Node_InformStatusServer) error

func (*UnimplementedNodeServer) LoadCategories 

func (*UnimplementedNodeServer) LoadCategories(context.Context, *LoadCategoriesRequest) (*empty.Empty, error)

func (*UnimplementedNodeServer) ProcessResults 

func (*UnimplementedNodeServer) ProcessResults(*empty.Empty, Node_ProcessResultsServer) error

func (*UnimplementedNodeServer) RemoveCapturer 

func (*UnimplementedNodeServer) RemoveCapturer(context.Context, *RemoveCapturerRequest) (*empty.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.