conduit_common

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package conduit_common is a generated protocol buffer package.

It is generated from these files: 

common/common.proto

It has these top-level messages: 

HttpMethod
Scheme
IPAddress
IPv6
TcpAddress
Destination
Eos
TapEvent

Index

Constants

This section is empty.

Variables

View Source 
var HttpMethod_Registered_name = map[int32]string{
	0: "GET",
	1: "POST",
	2: "PUT",
	3: "DELETE",
	4: "PATCH",
	5: "OPTIONS",
	6: "CONNECT",
	7: "HEAD",
	8: "TRACE",
}
View Source 
var HttpMethod_Registered_value = map[string]int32{
	"GET":     0,
	"POST":    1,
	"PUT":     2,
	"DELETE":  3,
	"PATCH":   4,
	"OPTIONS": 5,
	"CONNECT": 6,
	"HEAD":    7,
	"TRACE":   8,
}
View Source 
var Protocol_name = map[int32]string{
	0: "HTTP",
	1: "TCP",
}
View Source 
var Protocol_value = map[string]int32{
	"HTTP": 0,
	"TCP":  1,
}
View Source 
var Scheme_Registered_name = map[int32]string{
	0: "HTTP",
	1: "HTTPS",
}
View Source 
var Scheme_Registered_value = map[string]int32{
	"HTTP":  0,
	"HTTPS": 1,
}

Functions

This section is empty.

Types

type Destination 

type Destination struct {
	Scheme string `protobuf:"bytes,1,opt,name=scheme" json:"scheme,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
}

func (*Destination) Descriptor 

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

func (*Destination) GetPath 

func (m *Destination) GetPath() string

func (*Destination) GetScheme 

func (m *Destination) GetScheme() string

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) Reset 

func (m *Destination) Reset()

func (*Destination) String 

func (m *Destination) String() string

type Eos added in v0.2.0 

type Eos struct {
	// Types that are valid to be assigned to End:
	//	*Eos_GrpcStatusCode
	//	*Eos_ResetErrorCode
	End isEos_End `protobuf_oneof:"end"`
}

func (*Eos) Descriptor added in v0.2.0 

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

func (*Eos) GetEnd added in v0.2.0 

func (m *Eos) GetEnd() isEos_End

func (*Eos) GetGrpcStatusCode added in v0.2.0 

func (m *Eos) GetGrpcStatusCode() uint32

func (*Eos) GetResetErrorCode added in v0.2.0 

func (m *Eos) GetResetErrorCode() uint32

func (*Eos) ProtoMessage added in v0.2.0 

func (*Eos) ProtoMessage()

func (*Eos) Reset added in v0.2.0 

func (m *Eos) Reset()

func (*Eos) String added in v0.2.0 

func (m *Eos) String() string

func (*Eos) XXX_OneofFuncs added in v0.2.0 

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

XXX_OneofFuncs is for the internal use of the proto package.

type Eos_GrpcStatusCode added in v0.2.0 

type Eos_GrpcStatusCode struct {
	GrpcStatusCode uint32 `protobuf:"varint,1,opt,name=grpc_status_code,json=grpcStatusCode,oneof"`
}

type Eos_ResetErrorCode added in v0.2.0 

type Eos_ResetErrorCode struct {
	ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,oneof"`
}

type HttpMethod 

type HttpMethod struct {
	// Types that are valid to be assigned to Type:
	//	*HttpMethod_Registered_
	//	*HttpMethod_Unregistered
	Type isHttpMethod_Type `protobuf_oneof:"type"`
}

func (*HttpMethod) Descriptor 

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

func (*HttpMethod) GetRegistered 

func (m *HttpMethod) GetRegistered() HttpMethod_Registered

func (*HttpMethod) GetType 

func (m *HttpMethod) GetType() isHttpMethod_Type

func (*HttpMethod) GetUnregistered 

func (m *HttpMethod) GetUnregistered() string

func (*HttpMethod) ProtoMessage 

func (*HttpMethod) ProtoMessage()

func (*HttpMethod) Reset 

func (m *HttpMethod) Reset()

func (*HttpMethod) String 

func (m *HttpMethod) String() string

func (*HttpMethod) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type HttpMethod_Registered 

type HttpMethod_Registered int32
const (
	HttpMethod_GET     HttpMethod_Registered = 0
	HttpMethod_POST    HttpMethod_Registered = 1
	HttpMethod_PUT     HttpMethod_Registered = 2
	HttpMethod_DELETE  HttpMethod_Registered = 3
	HttpMethod_PATCH   HttpMethod_Registered = 4
	HttpMethod_OPTIONS HttpMethod_Registered = 5
	HttpMethod_CONNECT HttpMethod_Registered = 6
	HttpMethod_HEAD    HttpMethod_Registered = 7
	HttpMethod_TRACE   HttpMethod_Registered = 8
)

func (HttpMethod_Registered) EnumDescriptor 

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

func (HttpMethod_Registered) String 

func (x HttpMethod_Registered) String() string

type HttpMethod_Registered_ 

type HttpMethod_Registered_ struct {
	Registered HttpMethod_Registered `protobuf:"varint,1,opt,name=registered,enum=conduit.common.HttpMethod_Registered,oneof"`
}

type HttpMethod_Unregistered 

type HttpMethod_Unregistered struct {
	Unregistered string `protobuf:"bytes,2,opt,name=unregistered,oneof"`
}

type IPAddress 

type IPAddress struct {
	// Types that are valid to be assigned to Ip:
	//	*IPAddress_Ipv4
	//	*IPAddress_Ipv6
	Ip isIPAddress_Ip `protobuf_oneof:"ip"`
}

func (*IPAddress) Descriptor 

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

func (*IPAddress) GetIp 

func (m *IPAddress) GetIp() isIPAddress_Ip

func (*IPAddress) GetIpv4 

func (m *IPAddress) GetIpv4() uint32

func (*IPAddress) GetIpv6 

func (m *IPAddress) GetIpv6() *IPv6

func (*IPAddress) ProtoMessage 

func (*IPAddress) ProtoMessage()

func (*IPAddress) Reset 

func (m *IPAddress) Reset()

func (*IPAddress) String 

func (m *IPAddress) String() string

func (*IPAddress) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type IPAddress_Ipv4 

type IPAddress_Ipv4 struct {
	Ipv4 uint32 `protobuf:"fixed32,1,opt,name=ipv4,oneof"`
}

type IPAddress_Ipv6 

type IPAddress_Ipv6 struct {
	Ipv6 *IPv6 `protobuf:"bytes,2,opt,name=ipv6,oneof"`
}

type IPv6 

type IPv6 struct {
	First uint64 `protobuf:"fixed64,1,opt,name=first" json:"first,omitempty"`
	Last  uint64 `protobuf:"fixed64,2,opt,name=last" json:"last,omitempty"`
}

func (*IPv6) Descriptor 

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

func (*IPv6) GetFirst 

func (m *IPv6) GetFirst() uint64

func (*IPv6) GetLast 

func (m *IPv6) GetLast() uint64

func (*IPv6) ProtoMessage 

func (*IPv6) ProtoMessage()

func (*IPv6) Reset 

func (m *IPv6) Reset()

func (*IPv6) String 

func (m *IPv6) String() string

type Protocol added in v0.1.2 

type Protocol int32
const (
	Protocol_HTTP Protocol = 0
	Protocol_TCP  Protocol = 1
)

func (Protocol) EnumDescriptor added in v0.1.2 

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

func (Protocol) String added in v0.1.2 

func (x Protocol) String() string

type Scheme 

type Scheme struct {
	// Types that are valid to be assigned to Type:
	//	*Scheme_Registered_
	//	*Scheme_Unregistered
	Type isScheme_Type `protobuf_oneof:"type"`
}

func (*Scheme) Descriptor 

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

func (*Scheme) GetRegistered 

func (m *Scheme) GetRegistered() Scheme_Registered

func (*Scheme) GetType 

func (m *Scheme) GetType() isScheme_Type

func (*Scheme) GetUnregistered 

func (m *Scheme) GetUnregistered() string

func (*Scheme) ProtoMessage 

func (*Scheme) ProtoMessage()

func (*Scheme) Reset 

func (m *Scheme) Reset()

func (*Scheme) String 

func (m *Scheme) String() string

func (*Scheme) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type Scheme_Registered 

type Scheme_Registered int32
const (
	Scheme_HTTP  Scheme_Registered = 0
	Scheme_HTTPS Scheme_Registered = 1
)

func (Scheme_Registered) EnumDescriptor 

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

func (Scheme_Registered) String 

func (x Scheme_Registered) String() string

type Scheme_Registered_ 

type Scheme_Registered_ struct {
	Registered Scheme_Registered `protobuf:"varint,1,opt,name=registered,enum=conduit.common.Scheme_Registered,oneof"`
}

type Scheme_Unregistered 

type Scheme_Unregistered struct {
	Unregistered string `protobuf:"bytes,2,opt,name=unregistered,oneof"`
}

type TapEvent 

type TapEvent struct {
	Source          *TcpAddress            `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"`
	Destination     *TcpAddress            `protobuf:"bytes,2,opt,name=destination" json:"destination,omitempty"`
	DestinationMeta *TapEvent_EndpointMeta `protobuf:"bytes,4,opt,name=destination_meta,json=destinationMeta" json:"destination_meta,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*TapEvent_Http_
	Event isTapEvent_Event `protobuf_oneof:"event"`
}

func (*TapEvent) Descriptor 

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

func (*TapEvent) GetDestination added in v0.4.1 

func (m *TapEvent) GetDestination() *TcpAddress

func (*TapEvent) GetDestinationMeta added in v0.4.1 

func (m *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta

func (*TapEvent) GetEvent 

func (m *TapEvent) GetEvent() isTapEvent_Event

func (*TapEvent) GetHttp 

func (m *TapEvent) GetHttp() *TapEvent_Http

func (*TapEvent) GetSource 

func (m *TapEvent) GetSource() *TcpAddress

func (*TapEvent) ProtoMessage 

func (*TapEvent) ProtoMessage()

func (*TapEvent) Reset 

func (m *TapEvent) Reset()

func (*TapEvent) String 

func (m *TapEvent) String() string

func (*TapEvent) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type TapEvent_EndpointMeta added in v0.4.1 

type TapEvent_EndpointMeta struct {
	Labels map[string]string `` /* 132-byte string literal not displayed */
}

func (*TapEvent_EndpointMeta) Descriptor added in v0.4.1 

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

func (*TapEvent_EndpointMeta) GetLabels added in v0.4.1 

func (m *TapEvent_EndpointMeta) GetLabels() map[string]string

func (*TapEvent_EndpointMeta) ProtoMessage added in v0.4.1 

func (*TapEvent_EndpointMeta) ProtoMessage()

func (*TapEvent_EndpointMeta) Reset added in v0.4.1 

func (m *TapEvent_EndpointMeta) Reset()

func (*TapEvent_EndpointMeta) String added in v0.4.1 

func (m *TapEvent_EndpointMeta) String() string

type TapEvent_Http 

type TapEvent_Http struct {
	// Types that are valid to be assigned to Event:
	//	*TapEvent_Http_RequestInit_
	//	*TapEvent_Http_ResponseInit_
	//	*TapEvent_Http_ResponseEnd_
	Event isTapEvent_Http_Event `protobuf_oneof:"event"`
}

func (*TapEvent_Http) Descriptor 

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

func (*TapEvent_Http) GetEvent 

func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event

func (*TapEvent_Http) GetRequestInit 

func (m *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit

func (*TapEvent_Http) GetResponseEnd 

func (m *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd

func (*TapEvent_Http) GetResponseInit 

func (m *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit

func (*TapEvent_Http) ProtoMessage 

func (*TapEvent_Http) ProtoMessage()

func (*TapEvent_Http) Reset 

func (m *TapEvent_Http) Reset()

func (*TapEvent_Http) String 

func (m *TapEvent_Http) String() string

func (*TapEvent_Http) XXX_OneofFuncs 

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

XXX_OneofFuncs is for the internal use of the proto package.

type TapEvent_Http_ 

type TapEvent_Http_ struct {
	Http *TapEvent_Http `protobuf:"bytes,3,opt,name=http,oneof"`
}

type TapEvent_Http_RequestInit 

type TapEvent_Http_RequestInit struct {
	Id        *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Method    *HttpMethod             `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	Scheme    *Scheme                 `protobuf:"bytes,3,opt,name=scheme" json:"scheme,omitempty"`
	Authority string                  `protobuf:"bytes,4,opt,name=authority" json:"authority,omitempty"`
	Path      string                  `protobuf:"bytes,5,opt,name=path" json:"path,omitempty"`
}

func (*TapEvent_Http_RequestInit) Descriptor 

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

func (*TapEvent_Http_RequestInit) GetAuthority 

func (m *TapEvent_Http_RequestInit) GetAuthority() string

func (*TapEvent_Http_RequestInit) GetId 

func (m *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_RequestInit) GetMethod 

func (m *TapEvent_Http_RequestInit) GetMethod() *HttpMethod

func (*TapEvent_Http_RequestInit) GetPath 

func (m *TapEvent_Http_RequestInit) GetPath() string

func (*TapEvent_Http_RequestInit) GetScheme 

func (m *TapEvent_Http_RequestInit) GetScheme() *Scheme

func (*TapEvent_Http_RequestInit) ProtoMessage 

func (*TapEvent_Http_RequestInit) ProtoMessage()

func (*TapEvent_Http_RequestInit) Reset 

func (m *TapEvent_Http_RequestInit) Reset()

func (*TapEvent_Http_RequestInit) String 

func (m *TapEvent_Http_RequestInit) String() string

type TapEvent_Http_RequestInit_ 

type TapEvent_Http_RequestInit_ struct {
	RequestInit *TapEvent_Http_RequestInit `protobuf:"bytes,1,opt,name=request_init,json=requestInit,oneof"`
}

type TapEvent_Http_ResponseEnd 

type TapEvent_Http_ResponseEnd struct {
	Id                *TapEvent_Http_StreamId   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	SinceRequestInit  *google_protobuf.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit" json:"since_request_init,omitempty"`
	SinceResponseInit *google_protobuf.Duration `protobuf:"bytes,3,opt,name=since_response_init,json=sinceResponseInit" json:"since_response_init,omitempty"`
	ResponseBytes     uint64                    `protobuf:"varint,4,opt,name=response_bytes,json=responseBytes" json:"response_bytes,omitempty"`
	Eos               *Eos                      `protobuf:"bytes,5,opt,name=eos" json:"eos,omitempty"`
}

func (*TapEvent_Http_ResponseEnd) Descriptor 

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

func (*TapEvent_Http_ResponseEnd) GetEos added in v0.2.0 

func (m *TapEvent_Http_ResponseEnd) GetEos() *Eos

func (*TapEvent_Http_ResponseEnd) GetId 

func (m *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseEnd) GetResponseBytes 

func (m *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64

func (*TapEvent_Http_ResponseEnd) GetSinceRequestInit 

func (m *TapEvent_Http_ResponseEnd) GetSinceRequestInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseEnd) GetSinceResponseInit 

func (m *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseEnd) ProtoMessage 

func (*TapEvent_Http_ResponseEnd) ProtoMessage()

func (*TapEvent_Http_ResponseEnd) Reset 

func (m *TapEvent_Http_ResponseEnd) Reset()

func (*TapEvent_Http_ResponseEnd) String 

func (m *TapEvent_Http_ResponseEnd) String() string

type TapEvent_Http_ResponseEnd_ 

type TapEvent_Http_ResponseEnd_ struct {
	ResponseEnd *TapEvent_Http_ResponseEnd `protobuf:"bytes,3,opt,name=response_end,json=responseEnd,oneof"`
}

type TapEvent_Http_ResponseInit 

type TapEvent_Http_ResponseInit struct {
	Id               *TapEvent_Http_StreamId   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	SinceRequestInit *google_protobuf.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit" json:"since_request_init,omitempty"`
	HttpStatus       uint32                    `protobuf:"varint,3,opt,name=http_status,json=httpStatus" json:"http_status,omitempty"`
}

func (*TapEvent_Http_ResponseInit) Descriptor 

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

func (*TapEvent_Http_ResponseInit) GetHttpStatus 

func (m *TapEvent_Http_ResponseInit) GetHttpStatus() uint32

func (*TapEvent_Http_ResponseInit) GetId 

func (m *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId

func (*TapEvent_Http_ResponseInit) GetSinceRequestInit 

func (m *TapEvent_Http_ResponseInit) GetSinceRequestInit() *google_protobuf.Duration

func (*TapEvent_Http_ResponseInit) ProtoMessage 

func (*TapEvent_Http_ResponseInit) ProtoMessage()

func (*TapEvent_Http_ResponseInit) Reset 

func (m *TapEvent_Http_ResponseInit) Reset()

func (*TapEvent_Http_ResponseInit) String 

func (m *TapEvent_Http_ResponseInit) String() string

type TapEvent_Http_ResponseInit_ 

type TapEvent_Http_ResponseInit_ struct {
	ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,oneof"`
}

type TapEvent_Http_StreamId 

type TapEvent_Http_StreamId struct {
	// A randomized base (stable across a process's runtime)
	Base uint32 `protobuf:"varint,1,opt,name=base" json:"base,omitempty"`
	// A stream id unique within the lifetime of `base`.
	Stream uint64 `protobuf:"varint,2,opt,name=stream" json:"stream,omitempty"`
}

func (*TapEvent_Http_StreamId) Descriptor 

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

func (*TapEvent_Http_StreamId) GetBase 

func (m *TapEvent_Http_StreamId) GetBase() uint32

func (*TapEvent_Http_StreamId) GetStream 

func (m *TapEvent_Http_StreamId) GetStream() uint64

func (*TapEvent_Http_StreamId) ProtoMessage 

func (*TapEvent_Http_StreamId) ProtoMessage()

func (*TapEvent_Http_StreamId) Reset 

func (m *TapEvent_Http_StreamId) Reset()

func (*TapEvent_Http_StreamId) String 

func (m *TapEvent_Http_StreamId) String() string

type TcpAddress 

type TcpAddress struct {
	Ip   *IPAddress `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Port uint32     `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

func (*TcpAddress) Descriptor 

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

func (*TcpAddress) GetIp 

func (m *TcpAddress) GetIp() *IPAddress

func (*TcpAddress) GetPort 

func (m *TcpAddress) GetPort() uint32

func (*TcpAddress) ProtoMessage 

func (*TcpAddress) ProtoMessage()

func (*TcpAddress) Reset 

func (m *TcpAddress) Reset()

func (*TcpAddress) String 

func (m *TcpAddress) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package conduit_common_healthcheck is a generated protocol buffer package.
 Package conduit_common_healthcheck is a generated protocol buffer package.

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.