proto

package
v0.0.0-...-dfbecc7 Latest Latest
Warning

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

Go to latest
Published: Oct 18, 2018 License: MIT Imports: 10 Imported by: 4

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

attributes.proto
endpoints.proto
health_check.proto
message.proto
routes.proto
telemetry.proto

It has these top-level messages:

Attributes
StringList
Int64List
DoubleList
BoolList
TimestampList
DurationList
EndpointsRequest
EndpointsCatalog
Node
ServiceInstance
Container
Port
HeathRequest
HeathInitialization
HealthStatus
HealthAssignments
HealthAssignment
Message
RoutesRequest
RoutesCatalog
Service
Operation
RoutingRules
Configuration
Version
Retry
HealthCheck
TelemetryReport
TelemetryResponse

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthAttributes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAttributes   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthEndpoints = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEndpoints   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthHealthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHealthCheck   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthRoutes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRoutes   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTelemetry = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTelemetry   = fmt.Errorf("proto: integer overflow")
)
View Source
var HealthStatus_Result_name = map[int32]string{
	0: "UNKNOWN",
	1: "HEALTHY",
	2: "UNHEALTH",
}
View Source
var HealthStatus_Result_value = map[string]int32{
	"UNKNOWN":  0,
	"HEALTHY":  1,
	"UNHEALTH": 2,
}

Functions

func RegisterEndpointDiscoveryServer

func RegisterEndpointDiscoveryServer(s *grpc.Server, srv EndpointDiscoveryServer)

func RegisterHealthCheckReporterServer

func RegisterHealthCheckReporterServer(s *grpc.Server, srv HealthCheckReporterServer)

func RegisterRouteDiscoveryServer

func RegisterRouteDiscoveryServer(s *grpc.Server, srv RouteDiscoveryServer)

func RegisterTelemetryReporterServer

func RegisterTelemetryReporterServer(s *grpc.Server, srv TelemetryReporterServer)

Types

type Attributes

type Attributes struct {
	// The message-level dictionary.
	Words []string `protobuf:"bytes,1,rep,name=words" json:"words,omitempty"`
	// Attribute payload. All `sint32` values represent indices into
	// one of the word dictionaries. Positive values are indices into the
	// global deployment-wide dictionary, negative values are indices into
	// the message-level dictionary.
	Strings       map[int32]int32         `` /* 154-byte string literal not displayed */
	StringList    map[int32]StringList    `` /* 158-byte string literal not displayed */
	Int64S        map[int32]int64         `` /* 150-byte string literal not displayed */
	Int64List     map[int32]Int64List     `` /* 155-byte string literal not displayed */
	Doubles       map[int32]float64       `` /* 153-byte string literal not displayed */
	DoubleList    map[int32]DoubleList    `` /* 158-byte string literal not displayed */
	Bools         map[int32]bool          `` /* 148-byte string literal not displayed */
	BoolList      map[int32]BoolList      `` /* 152-byte string literal not displayed */
	Timestamps    map[int32]time.Time     `` /* 149-byte string literal not displayed */
	TimestampList map[int32]TimestampList `` /* 168-byte string literal not displayed */
	Durations     map[int32]time.Duration `` /* 151-byte string literal not displayed */
	DurationList  map[int32]DurationList  `` /* 165-byte string literal not displayed */
	Bytes         map[int32][]byte        `` /* 148-byte string literal not displayed */
	Attributes    map[int32]Attributes    `` /* 141-byte string literal not displayed */
}

func (*Attributes) Descriptor

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

func (*Attributes) Marshal

func (m *Attributes) Marshal() (dAtA []byte, err error)

func (*Attributes) MarshalTo

func (m *Attributes) MarshalTo(dAtA []byte) (int, error)

func (*Attributes) ProtoMessage

func (*Attributes) ProtoMessage()

func (*Attributes) Reset

func (m *Attributes) Reset()

func (*Attributes) Size

func (m *Attributes) Size() (n int)

func (*Attributes) String

func (m *Attributes) String() string

func (*Attributes) Unmarshal

func (m *Attributes) Unmarshal(dAtA []byte) error

type BoolList

type BoolList struct {
	Items []bool `protobuf:"varint,1,rep,packed,name=items" json:"items,omitempty"`
}

func (*BoolList) Descriptor

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

func (*BoolList) Marshal

func (m *BoolList) Marshal() (dAtA []byte, err error)

func (*BoolList) MarshalTo

func (m *BoolList) MarshalTo(dAtA []byte) (int, error)

func (*BoolList) ProtoMessage

func (*BoolList) ProtoMessage()

func (*BoolList) Reset

func (m *BoolList) Reset()

func (*BoolList) Size

func (m *BoolList) Size() (n int)

func (*BoolList) String

func (m *BoolList) String() string

func (*BoolList) Unmarshal

func (m *BoolList) Unmarshal(dAtA []byte) error

type Configuration

type Configuration struct {
	Type   string     `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Config Attributes `protobuf:"bytes,2,opt,name=config" json:"config"`
}

func (*Configuration) Descriptor

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

func (*Configuration) Marshal

func (m *Configuration) Marshal() (dAtA []byte, err error)

func (*Configuration) MarshalTo

func (m *Configuration) MarshalTo(dAtA []byte) (int, error)

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) Reset

func (m *Configuration) Reset()

func (*Configuration) Size

func (m *Configuration) Size() (n int)

func (*Configuration) String

func (m *Configuration) String() string

func (*Configuration) Unmarshal

func (m *Configuration) Unmarshal(dAtA []byte) error

type Container

type Container struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
}

func (*Container) Descriptor

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

func (*Container) Marshal

func (m *Container) Marshal() (dAtA []byte, err error)

func (*Container) MarshalTo

func (m *Container) MarshalTo(dAtA []byte) (int, error)

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) Reset

func (m *Container) Reset()

func (*Container) Size

func (m *Container) Size() (n int)

func (*Container) String

func (m *Container) String() string

func (*Container) Unmarshal

func (m *Container) Unmarshal(dAtA []byte) error

type DoubleList

type DoubleList struct {
	Items []float64 `protobuf:"fixed64,1,rep,packed,name=items" json:"items,omitempty"`
}

func (*DoubleList) Descriptor

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

func (*DoubleList) Marshal

func (m *DoubleList) Marshal() (dAtA []byte, err error)

func (*DoubleList) MarshalTo

func (m *DoubleList) MarshalTo(dAtA []byte) (int, error)

func (*DoubleList) ProtoMessage

func (*DoubleList) ProtoMessage()

func (*DoubleList) Reset

func (m *DoubleList) Reset()

func (*DoubleList) Size

func (m *DoubleList) Size() (n int)

func (*DoubleList) String

func (m *DoubleList) String() string

func (*DoubleList) Unmarshal

func (m *DoubleList) Unmarshal(dAtA []byte) error

type DurationList

type DurationList struct {
	Items []time.Duration `protobuf:"bytes,1,rep,name=items,stdduration" json:"items"`
}

func (*DurationList) Descriptor

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

func (*DurationList) Marshal

func (m *DurationList) Marshal() (dAtA []byte, err error)

func (*DurationList) MarshalTo

func (m *DurationList) MarshalTo(dAtA []byte) (int, error)

func (*DurationList) ProtoMessage

func (*DurationList) ProtoMessage()

func (*DurationList) Reset

func (m *DurationList) Reset()

func (*DurationList) Size

func (m *DurationList) Size() (n int)

func (*DurationList) String

func (m *DurationList) String() string

func (*DurationList) Unmarshal

func (m *DurationList) Unmarshal(dAtA []byte) error

type EndpointDiscoveryClient

type EndpointDiscoveryClient interface {
	GetEndpoints(ctx context.Context, in *EndpointsRequest, opts ...grpc.CallOption) (*EndpointsCatalog, error)
	StreamEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscovery_StreamEndpointsClient, error)
}

func NewEndpointDiscoveryClient

func NewEndpointDiscoveryClient(cc *grpc.ClientConn) EndpointDiscoveryClient

type EndpointDiscoveryServer

type EndpointDiscoveryServer interface {
	GetEndpoints(context.Context, *EndpointsRequest) (*EndpointsCatalog, error)
	StreamEndpoints(EndpointDiscovery_StreamEndpointsServer) error
}

type EndpointDiscovery_StreamEndpointsClient

type EndpointDiscovery_StreamEndpointsClient interface {
	Send(*EndpointsRequest) error
	Recv() (*EndpointsCatalog, error)
	grpc.ClientStream
}

type EndpointDiscovery_StreamEndpointsServer

type EndpointDiscovery_StreamEndpointsServer interface {
	Send(*EndpointsCatalog) error
	Recv() (*EndpointsRequest, error)
	grpc.ServerStream
}

type EndpointsCatalog

type EndpointsCatalog struct {
	UseCache bool   `protobuf:"varint,1,opt,name=use_cache,json=useCache,proto3" json:"use_cache,omitempty"`
	Version  int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Nodes    []Node `protobuf:"bytes,3,rep,name=nodes" json:"nodes"`
}

func (*EndpointsCatalog) Descriptor

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

func (*EndpointsCatalog) Marshal

func (m *EndpointsCatalog) Marshal() (dAtA []byte, err error)

func (*EndpointsCatalog) MarshalTo

func (m *EndpointsCatalog) MarshalTo(dAtA []byte) (int, error)

func (*EndpointsCatalog) ProtoMessage

func (*EndpointsCatalog) ProtoMessage()

func (*EndpointsCatalog) Reset

func (m *EndpointsCatalog) Reset()

func (*EndpointsCatalog) Size

func (m *EndpointsCatalog) Size() (n int)

func (*EndpointsCatalog) String

func (m *EndpointsCatalog) String() string

func (*EndpointsCatalog) Unmarshal

func (m *EndpointsCatalog) Unmarshal(dAtA []byte) error

type EndpointsRequest

type EndpointsRequest struct {
	NodeID  string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Version int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

func (*EndpointsRequest) Descriptor

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

func (*EndpointsRequest) Marshal

func (m *EndpointsRequest) Marshal() (dAtA []byte, err error)

func (*EndpointsRequest) MarshalTo

func (m *EndpointsRequest) MarshalTo(dAtA []byte) (int, error)

func (*EndpointsRequest) ProtoMessage

func (*EndpointsRequest) ProtoMessage()

func (*EndpointsRequest) Reset

func (m *EndpointsRequest) Reset()

func (*EndpointsRequest) Size

func (m *EndpointsRequest) Size() (n int)

func (*EndpointsRequest) String

func (m *EndpointsRequest) String() string

func (*EndpointsRequest) Unmarshal

func (m *EndpointsRequest) Unmarshal(dAtA []byte) error

type HealthAssignment

type HealthAssignment struct {
	NodeID  string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
}

func (*HealthAssignment) Descriptor

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

func (*HealthAssignment) Marshal

func (m *HealthAssignment) Marshal() (dAtA []byte, err error)

func (*HealthAssignment) MarshalTo

func (m *HealthAssignment) MarshalTo(dAtA []byte) (int, error)

func (*HealthAssignment) ProtoMessage

func (*HealthAssignment) ProtoMessage()

func (*HealthAssignment) Reset

func (m *HealthAssignment) Reset()

func (*HealthAssignment) Size

func (m *HealthAssignment) Size() (n int)

func (*HealthAssignment) String

func (m *HealthAssignment) String() string

func (*HealthAssignment) Unmarshal

func (m *HealthAssignment) Unmarshal(dAtA []byte) error

type HealthAssignments

type HealthAssignments struct {
	Assignments []HealthAssignment `protobuf:"bytes,1,rep,name=assignments" json:"assignments"`
}

func (*HealthAssignments) Descriptor

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

func (*HealthAssignments) Marshal

func (m *HealthAssignments) Marshal() (dAtA []byte, err error)

func (*HealthAssignments) MarshalTo

func (m *HealthAssignments) MarshalTo(dAtA []byte) (int, error)

func (*HealthAssignments) ProtoMessage

func (*HealthAssignments) ProtoMessage()

func (*HealthAssignments) Reset

func (m *HealthAssignments) Reset()

func (*HealthAssignments) Size

func (m *HealthAssignments) Size() (n int)

func (*HealthAssignments) String

func (m *HealthAssignments) String() string

func (*HealthAssignments) Unmarshal

func (m *HealthAssignments) Unmarshal(dAtA []byte) error

type HealthCheck

type HealthCheck struct {
	Timeout            time.Duration `protobuf:"bytes,1,opt,name=timeout,stdduration" json:"timeout"`
	Interval           time.Duration `protobuf:"bytes,2,opt,name=interval,stdduration" json:"interval"`
	UnhealthyThreshold uint32        `protobuf:"varint,3,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"`
	HealthyThreshold   uint32        `protobuf:"varint,4,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"`
	CheckType          string        `protobuf:"bytes,5,opt,name=check_type,json=checkType,proto3" json:"check_type,omitempty"`
	CheckConfig        Attributes    `protobuf:"bytes,6,opt,name=check_config,json=checkConfig" json:"check_config"`
}

func (*HealthCheck) Descriptor

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

func (*HealthCheck) Marshal

func (m *HealthCheck) Marshal() (dAtA []byte, err error)

func (*HealthCheck) MarshalTo

func (m *HealthCheck) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheck) ProtoMessage

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset

func (m *HealthCheck) Reset()

func (*HealthCheck) Size

func (m *HealthCheck) Size() (n int)

func (*HealthCheck) String

func (m *HealthCheck) String() string

func (*HealthCheck) Unmarshal

func (m *HealthCheck) Unmarshal(dAtA []byte) error

type HealthCheckReporterClient

type HealthCheckReporterClient interface {
	Report(ctx context.Context, opts ...grpc.CallOption) (HealthCheckReporter_ReportClient, error)
}

func NewHealthCheckReporterClient

func NewHealthCheckReporterClient(cc *grpc.ClientConn) HealthCheckReporterClient

type HealthCheckReporterServer

type HealthCheckReporterServer interface {
	Report(HealthCheckReporter_ReportServer) error
}

type HealthCheckReporter_ReportClient

type HealthCheckReporter_ReportClient interface {
	Send(*HeathRequest) error
	Recv() (*HealthAssignments, error)
	grpc.ClientStream
}

type HealthCheckReporter_ReportServer

type HealthCheckReporter_ReportServer interface {
	Send(*HealthAssignments) error
	Recv() (*HeathRequest, error)
	grpc.ServerStream
}

type HealthStatus

type HealthStatus struct {
	NodeID  string              `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Service string              `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Status  HealthStatus_Result `protobuf:"varint,3,opt,name=status,proto3,enum=prizem.api.v1.HealthStatus_Result" json:"status,omitempty"`
}

func (*HealthStatus) Descriptor

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

func (*HealthStatus) Marshal

func (m *HealthStatus) Marshal() (dAtA []byte, err error)

func (*HealthStatus) MarshalTo

func (m *HealthStatus) MarshalTo(dAtA []byte) (int, error)

func (*HealthStatus) ProtoMessage

func (*HealthStatus) ProtoMessage()

func (*HealthStatus) Reset

func (m *HealthStatus) Reset()

func (*HealthStatus) Size

func (m *HealthStatus) Size() (n int)

func (*HealthStatus) String

func (m *HealthStatus) String() string

func (*HealthStatus) Unmarshal

func (m *HealthStatus) Unmarshal(dAtA []byte) error

type HealthStatus_Result

type HealthStatus_Result int32
const (
	HealthStatus_UNKNOWN  HealthStatus_Result = 0
	HealthStatus_HEALTHY  HealthStatus_Result = 1
	HealthStatus_UNHEALTH HealthStatus_Result = 2
)

func (HealthStatus_Result) EnumDescriptor

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

func (HealthStatus_Result) String

func (x HealthStatus_Result) String() string

type HeathInitialization

type HeathInitialization struct {
	NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*HeathInitialization) Descriptor

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

func (*HeathInitialization) Marshal

func (m *HeathInitialization) Marshal() (dAtA []byte, err error)

func (*HeathInitialization) MarshalTo

func (m *HeathInitialization) MarshalTo(dAtA []byte) (int, error)

func (*HeathInitialization) ProtoMessage

func (*HeathInitialization) ProtoMessage()

func (*HeathInitialization) Reset

func (m *HeathInitialization) Reset()

func (*HeathInitialization) Size

func (m *HeathInitialization) Size() (n int)

func (*HeathInitialization) String

func (m *HeathInitialization) String() string

func (*HeathInitialization) Unmarshal

func (m *HeathInitialization) Unmarshal(dAtA []byte) error

type HeathRequest

type HeathRequest struct {
	// Types that are valid to be assigned to HealthRequest:
	//	*HeathRequest_Initialization
	//	*HeathRequest_Status
	HealthRequest isHeathRequest_HealthRequest `protobuf_oneof:"health_request"`
}

func (*HeathRequest) Descriptor

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

func (*HeathRequest) GetHealthRequest

func (m *HeathRequest) GetHealthRequest() isHeathRequest_HealthRequest

func (*HeathRequest) GetInitialization

func (m *HeathRequest) GetInitialization() *HeathInitialization

func (*HeathRequest) GetStatus

func (m *HeathRequest) GetStatus() *HealthStatus

func (*HeathRequest) Marshal

func (m *HeathRequest) Marshal() (dAtA []byte, err error)

func (*HeathRequest) MarshalTo

func (m *HeathRequest) MarshalTo(dAtA []byte) (int, error)

func (*HeathRequest) ProtoMessage

func (*HeathRequest) ProtoMessage()

func (*HeathRequest) Reset

func (m *HeathRequest) Reset()

func (*HeathRequest) Size

func (m *HeathRequest) Size() (n int)

func (*HeathRequest) String

func (m *HeathRequest) String() string

func (*HeathRequest) Unmarshal

func (m *HeathRequest) Unmarshal(dAtA []byte) error

func (*HeathRequest) XXX_OneofFuncs

func (*HeathRequest) XXX_OneofFuncs() (func(msg proto1.Message, b *proto1.Buffer) error, func(msg proto1.Message, tag, wire int, b *proto1.Buffer) (bool, error), func(msg proto1.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type HeathRequest_Initialization

type HeathRequest_Initialization struct {
	Initialization *HeathInitialization `protobuf:"bytes,1,opt,name=initialization,oneof"`
}

func (*HeathRequest_Initialization) MarshalTo

func (m *HeathRequest_Initialization) MarshalTo(dAtA []byte) (int, error)

func (*HeathRequest_Initialization) Size

func (m *HeathRequest_Initialization) Size() (n int)

type HeathRequest_Status

type HeathRequest_Status struct {
	Status *HealthStatus `protobuf:"bytes,2,opt,name=status,oneof"`
}

func (*HeathRequest_Status) MarshalTo

func (m *HeathRequest_Status) MarshalTo(dAtA []byte) (int, error)

func (*HeathRequest_Status) Size

func (m *HeathRequest_Status) Size() (n int)

type Int64List

type Int64List struct {
	Items []int64 `protobuf:"varint,1,rep,packed,name=items" json:"items,omitempty"`
}

func (*Int64List) Descriptor

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

func (*Int64List) Marshal

func (m *Int64List) Marshal() (dAtA []byte, err error)

func (*Int64List) MarshalTo

func (m *Int64List) MarshalTo(dAtA []byte) (int, error)

func (*Int64List) ProtoMessage

func (*Int64List) ProtoMessage()

func (*Int64List) Reset

func (m *Int64List) Reset()

func (*Int64List) Size

func (m *Int64List) Size() (n int)

func (*Int64List) String

func (m *Int64List) String() string

func (*Int64List) Unmarshal

func (m *Int64List) Unmarshal(dAtA []byte) error

type Message

type Message struct {
	Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ServerID string `protobuf:"bytes,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Message) Descriptor

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

func (*Message) Marshal

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

func (m *Message) Size() (n int)

func (*Message) String

func (m *Message) String() string

func (*Message) Unmarshal

func (m *Message) Unmarshal(dAtA []byte) error

type Node

type Node struct {
	ID         string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Geography  string            `protobuf:"bytes,2,opt,name=geography,proto3" json:"geography,omitempty"`
	Datacenter string            `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	Address    string            `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Metadata   Attributes        `protobuf:"bytes,5,opt,name=metadata" json:"metadata"`
	Services   []ServiceInstance `protobuf:"bytes,6,rep,name=services" json:"services"`
}

func (*Node) Descriptor

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

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

type Operation

type Operation struct {
	Name         string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Method       string       `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	URIPattern   string       `protobuf:"bytes,3,opt,name=uri_pattern,json=uriPattern,proto3" json:"uri_pattern,omitempty"`
	RoutingRules RoutingRules `protobuf:"bytes,4,opt,name=routing_rules,json=routingRules" json:"routing_rules"`
}

func (*Operation) Descriptor

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

func (*Operation) Marshal

func (m *Operation) Marshal() (dAtA []byte, err error)

func (*Operation) MarshalTo

func (m *Operation) MarshalTo(dAtA []byte) (int, error)

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) Reset

func (m *Operation) Reset()

func (*Operation) Size

func (m *Operation) Size() (n int)

func (*Operation) String

func (m *Operation) String() string

func (*Operation) Unmarshal

func (m *Operation) Unmarshal(dAtA []byte) error

type Port

type Port struct {
	Port     int32  `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Secure   bool   `protobuf:"varint,3,opt,name=secure,proto3" json:"secure,omitempty"`
}

func (*Port) Descriptor

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

func (*Port) Marshal

func (m *Port) Marshal() (dAtA []byte, err error)

func (*Port) MarshalTo

func (m *Port) MarshalTo(dAtA []byte) (int, error)

func (*Port) ProtoMessage

func (*Port) ProtoMessage()

func (*Port) Reset

func (m *Port) Reset()

func (*Port) Size

func (m *Port) Size() (n int)

func (*Port) String

func (m *Port) String() string

func (*Port) Unmarshal

func (m *Port) Unmarshal(dAtA []byte) error

type Retry

type Retry struct {
	Attempts           int32         `protobuf:"varint,1,opt,name=attempts,proto3" json:"attempts,omitempty"`
	ResponseClassifier string        `protobuf:"bytes,2,opt,name=responseClassifier,proto3" json:"responseClassifier,omitempty"`
	PerTryTimeout      time.Duration `protobuf:"bytes,3,opt,name=per_try_timeout,json=perTryTimeout,stdduration" json:"per_try_timeout"`
}

func (*Retry) Descriptor

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

func (*Retry) Marshal

func (m *Retry) Marshal() (dAtA []byte, err error)

func (*Retry) MarshalTo

func (m *Retry) MarshalTo(dAtA []byte) (int, error)

func (*Retry) ProtoMessage

func (*Retry) ProtoMessage()

func (*Retry) Reset

func (m *Retry) Reset()

func (*Retry) Size

func (m *Retry) Size() (n int)

func (*Retry) String

func (m *Retry) String() string

func (*Retry) Unmarshal

func (m *Retry) Unmarshal(dAtA []byte) error

type RouteDiscoveryClient

type RouteDiscoveryClient interface {
	GetRoutes(ctx context.Context, in *RoutesRequest, opts ...grpc.CallOption) (*RoutesCatalog, error)
	StreamRoutes(ctx context.Context, opts ...grpc.CallOption) (RouteDiscovery_StreamRoutesClient, error)
}

func NewRouteDiscoveryClient

func NewRouteDiscoveryClient(cc *grpc.ClientConn) RouteDiscoveryClient

type RouteDiscoveryServer

type RouteDiscoveryServer interface {
	GetRoutes(context.Context, *RoutesRequest) (*RoutesCatalog, error)
	StreamRoutes(RouteDiscovery_StreamRoutesServer) error
}

type RouteDiscovery_StreamRoutesClient

type RouteDiscovery_StreamRoutesClient interface {
	Send(*RoutesRequest) error
	Recv() (*RoutesCatalog, error)
	grpc.ClientStream
}

type RouteDiscovery_StreamRoutesServer

type RouteDiscovery_StreamRoutesServer interface {
	Send(*RoutesCatalog) error
	Recv() (*RoutesRequest, error)
	grpc.ServerStream
}

type RoutesCatalog

type RoutesCatalog struct {
	UseCache bool      `protobuf:"varint,1,opt,name=use_cache,json=useCache,proto3" json:"use_cache,omitempty"`
	Version  int64     `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Services []Service `protobuf:"bytes,3,rep,name=services" json:"services"`
}

func (*RoutesCatalog) Descriptor

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

func (*RoutesCatalog) Marshal

func (m *RoutesCatalog) Marshal() (dAtA []byte, err error)

func (*RoutesCatalog) MarshalTo

func (m *RoutesCatalog) MarshalTo(dAtA []byte) (int, error)

func (*RoutesCatalog) ProtoMessage

func (*RoutesCatalog) ProtoMessage()

func (*RoutesCatalog) Reset

func (m *RoutesCatalog) Reset()

func (*RoutesCatalog) Size

func (m *RoutesCatalog) Size() (n int)

func (*RoutesCatalog) String

func (m *RoutesCatalog) String() string

func (*RoutesCatalog) Unmarshal

func (m *RoutesCatalog) Unmarshal(dAtA []byte) error

type RoutesRequest

type RoutesRequest struct {
	NodeID  string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Version int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

func (*RoutesRequest) Descriptor

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

func (*RoutesRequest) Marshal

func (m *RoutesRequest) Marshal() (dAtA []byte, err error)

func (*RoutesRequest) MarshalTo

func (m *RoutesRequest) MarshalTo(dAtA []byte) (int, error)

func (*RoutesRequest) ProtoMessage

func (*RoutesRequest) ProtoMessage()

func (*RoutesRequest) Reset

func (m *RoutesRequest) Reset()

func (*RoutesRequest) Size

func (m *RoutesRequest) Size() (n int)

func (*RoutesRequest) String

func (m *RoutesRequest) String() string

func (*RoutesRequest) Unmarshal

func (m *RoutesRequest) Unmarshal(dAtA []byte) error

type RoutingRules

type RoutingRules struct {
	Selectors    []string        `protobuf:"bytes,1,rep,name=selectors" json:"selectors,omitempty"`
	RewriteRules []Configuration `protobuf:"bytes,2,rep,name=rewrite_rules,json=rewriteRules" json:"rewrite_rules"`
	Timeout      *time.Duration  `protobuf:"bytes,3,opt,name=timeout,stdduration" json:"timeout,omitempty"`
	Retry        *Retry          `protobuf:"bytes,4,opt,name=retry" json:"retry,omitempty"`
	Policies     []Configuration `protobuf:"bytes,5,rep,name=policies" json:"policies"`
}

func (*RoutingRules) Descriptor

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

func (*RoutingRules) Marshal

func (m *RoutingRules) Marshal() (dAtA []byte, err error)

func (*RoutingRules) MarshalTo

func (m *RoutingRules) MarshalTo(dAtA []byte) (int, error)

func (*RoutingRules) ProtoMessage

func (*RoutingRules) ProtoMessage()

func (*RoutingRules) Reset

func (m *RoutingRules) Reset()

func (*RoutingRules) Size

func (m *RoutingRules) Size() (n int)

func (*RoutingRules) String

func (m *RoutingRules) String() string

func (*RoutingRules) Unmarshal

func (m *RoutingRules) Unmarshal(dAtA []byte) error

type Service

type Service struct {
	Name           string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace      string       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Description    string       `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Hostname       string       `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	URIPrefix      string       `protobuf:"bytes,5,opt,name=uri_prefix,json=uriPrefix,proto3" json:"uri_prefix,omitempty"`
	Version        *Version     `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	Authentication string       `protobuf:"bytes,7,opt,name=authentication,proto3" json:"authentication,omitempty"`
	RoutingRules   RoutingRules `protobuf:"bytes,8,opt,name=routing_rules,json=routingRules" json:"routing_rules"`
	Operations     []Operation  `protobuf:"bytes,9,rep,name=operations" json:"operations"`
	HealthCheck    *HealthCheck `protobuf:"bytes,10,opt,name=health_check,json=healthCheck" json:"health_check,omitempty"`
}

func (*Service) Descriptor

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

func (*Service) Marshal

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalTo

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) Reset

func (m *Service) Reset()

func (*Service) Size

func (m *Service) Size() (n int)

func (*Service) String

func (m *Service) String() string

func (*Service) Unmarshal

func (m *Service) Unmarshal(dAtA []byte) error

type ServiceInstance

type ServiceInstance struct {
	ID        string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Service   string     `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Name      string     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string     `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Principal string     `protobuf:"bytes,5,opt,name=principal,proto3" json:"principal,omitempty"`
	Owner     string     `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	Container *Container `protobuf:"bytes,7,opt,name=container" json:"container,omitempty"`
	Ports     []Port     `protobuf:"bytes,8,rep,name=ports" json:"ports"`
	Metadata  Attributes `protobuf:"bytes,9,opt,name=metadata" json:"metadata"`
	Labels    []string   `protobuf:"bytes,10,rep,name=labels" json:"labels,omitempty"`
}

func (*ServiceInstance) Descriptor

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

func (*ServiceInstance) Marshal

func (m *ServiceInstance) Marshal() (dAtA []byte, err error)

func (*ServiceInstance) MarshalTo

func (m *ServiceInstance) MarshalTo(dAtA []byte) (int, error)

func (*ServiceInstance) ProtoMessage

func (*ServiceInstance) ProtoMessage()

func (*ServiceInstance) Reset

func (m *ServiceInstance) Reset()

func (*ServiceInstance) Size

func (m *ServiceInstance) Size() (n int)

func (*ServiceInstance) String

func (m *ServiceInstance) String() string

func (*ServiceInstance) Unmarshal

func (m *ServiceInstance) Unmarshal(dAtA []byte) error

type StringList

type StringList struct {
	Items []int32 `protobuf:"zigzag32,1,rep,packed,name=items" json:"items,omitempty"`
}

func (*StringList) Descriptor

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

func (*StringList) Marshal

func (m *StringList) Marshal() (dAtA []byte, err error)

func (*StringList) MarshalTo

func (m *StringList) MarshalTo(dAtA []byte) (int, error)

func (*StringList) ProtoMessage

func (*StringList) ProtoMessage()

func (*StringList) Reset

func (m *StringList) Reset()

func (*StringList) Size

func (m *StringList) Size() (n int)

func (*StringList) String

func (m *StringList) String() string

func (*StringList) Unmarshal

func (m *StringList) Unmarshal(dAtA []byte) error

type TelemetryReport

type TelemetryReport struct {
	Attributes []Attributes `protobuf:"bytes,1,rep,name=attributes" json:"attributes"`
}

func (*TelemetryReport) Descriptor

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

func (*TelemetryReport) Marshal

func (m *TelemetryReport) Marshal() (dAtA []byte, err error)

func (*TelemetryReport) MarshalTo

func (m *TelemetryReport) MarshalTo(dAtA []byte) (int, error)

func (*TelemetryReport) ProtoMessage

func (*TelemetryReport) ProtoMessage()

func (*TelemetryReport) Reset

func (m *TelemetryReport) Reset()

func (*TelemetryReport) Size

func (m *TelemetryReport) Size() (n int)

func (*TelemetryReport) String

func (m *TelemetryReport) String() string

func (*TelemetryReport) Unmarshal

func (m *TelemetryReport) Unmarshal(dAtA []byte) error

type TelemetryReporterClient

type TelemetryReporterClient interface {
	Report(ctx context.Context, in *TelemetryReport, opts ...grpc.CallOption) (*TelemetryResponse, error)
}

func NewTelemetryReporterClient

func NewTelemetryReporterClient(cc *grpc.ClientConn) TelemetryReporterClient

type TelemetryReporterServer

type TelemetryReporterServer interface {
	Report(context.Context, *TelemetryReport) (*TelemetryResponse, error)
}

type TelemetryResponse

type TelemetryResponse struct {
}

func (*TelemetryResponse) Descriptor

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

func (*TelemetryResponse) Marshal

func (m *TelemetryResponse) Marshal() (dAtA []byte, err error)

func (*TelemetryResponse) MarshalTo

func (m *TelemetryResponse) MarshalTo(dAtA []byte) (int, error)

func (*TelemetryResponse) ProtoMessage

func (*TelemetryResponse) ProtoMessage()

func (*TelemetryResponse) Reset

func (m *TelemetryResponse) Reset()

func (*TelemetryResponse) Size

func (m *TelemetryResponse) Size() (n int)

func (*TelemetryResponse) String

func (m *TelemetryResponse) String() string

func (*TelemetryResponse) Unmarshal

func (m *TelemetryResponse) Unmarshal(dAtA []byte) error

type TimestampList

type TimestampList struct {
	Items []time.Time `protobuf:"bytes,1,rep,name=items,stdtime" json:"items"`
}

func (*TimestampList) Descriptor

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

func (*TimestampList) Marshal

func (m *TimestampList) Marshal() (dAtA []byte, err error)

func (*TimestampList) MarshalTo

func (m *TimestampList) MarshalTo(dAtA []byte) (int, error)

func (*TimestampList) ProtoMessage

func (*TimestampList) ProtoMessage()

func (*TimestampList) Reset

func (m *TimestampList) Reset()

func (*TimestampList) Size

func (m *TimestampList) Size() (n int)

func (*TimestampList) String

func (m *TimestampList) String() string

func (*TimestampList) Unmarshal

func (m *TimestampList) Unmarshal(dAtA []byte) error

type Version

type Version struct {
	VersionLocations []string `protobuf:"bytes,1,rep,name=version_locations,json=versionLocations" json:"version_locations,omitempty"`
	DefaultVersion   string   `protobuf:"bytes,2,opt,name=default_version,json=defaultVersion,proto3" json:"default_version,omitempty"`
}

func (*Version) Descriptor

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

func (*Version) Marshal

func (m *Version) Marshal() (dAtA []byte, err error)

func (*Version) MarshalTo

func (m *Version) MarshalTo(dAtA []byte) (int, error)

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

func (m *Version) Size() (n int)

func (*Version) String

func (m *Version) String() string

func (*Version) Unmarshal

func (m *Version) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL