conduit_common

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2017 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
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 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 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 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"`
	Target *TcpAddress `protobuf:"bytes,2,opt,name=target" json:"target,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) 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) GetTarget

func (m *TapEvent) GetTarget() *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_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 (*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"`
	GrpcStatus        uint32                    `protobuf:"varint,5,opt,name=grpc_status,json=grpcStatus" json:"grpc_status,omitempty"`
}

func (*TapEvent_Http_ResponseEnd) Descriptor

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

func (*TapEvent_Http_ResponseEnd) GetGrpcStatus

func (m *TapEvent_Http_ResponseEnd) GetGrpcStatus() uint32

func (*TapEvent_Http_ResponseEnd) GetId

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 (*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

Jump to

Keyboard shortcuts

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