Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 Changes in this version + type ThriftFilter struct + Config *types.Struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ThriftFilter) Descriptor() ([]byte, []int) + func (*ThriftFilter) ProtoMessage() + func (dst *ThriftFilter) XXX_Merge(src proto.Message) + func (m *ThriftFilter) GetConfig() *types.Struct + func (m *ThriftFilter) GetName() string + func (m *ThriftFilter) Marshal() (dAtA []byte, err error) + func (m *ThriftFilter) MarshalTo(dAtA []byte) (int, error) + func (m *ThriftFilter) Reset() + func (m *ThriftFilter) Size() (n int) + func (m *ThriftFilter) String() string + func (m *ThriftFilter) Unmarshal(dAtA []byte) error + func (m *ThriftFilter) Validate() error + func (m *ThriftFilter) XXX_DiscardUnknown() + func (m *ThriftFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ThriftFilter) XXX_Size() int + func (m *ThriftFilter) XXX_Unmarshal(b []byte) error + type ThriftFilterValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ThriftFilterValidationError) Error() string type ThriftProxy + ThriftFilters []*ThriftFilter + func (m *ThriftProxy) GetThriftFilters() []*ThriftFilter v0.6.0 Sep 25, 2018 Changes in this version + var ProtocolType_name = map[int32]string + var ProtocolType_value = map[string]int32 + var TransportType_name = map[int32]string + var TransportType_value = map[string]int32 + type ProtocolType int32 + const TWITTER + func (ProtocolType) EnumDescriptor() ([]byte, []int) + func (x ProtocolType) String() string type RouteAction + ClusterSpecifier isRouteAction_ClusterSpecifier + MetadataMatch *core.Metadata + func (*RouteAction) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *RouteAction) GetClusterSpecifier() isRouteAction_ClusterSpecifier + func (m *RouteAction) GetMetadataMatch() *core.Metadata + func (m *RouteAction) GetWeightedClusters() *WeightedCluster + type RouteAction_Cluster struct + Cluster string + func (m *RouteAction_Cluster) MarshalTo(dAtA []byte) (int, error) + func (m *RouteAction_Cluster) Size() (n int) + type RouteAction_WeightedClusters struct + WeightedClusters *WeightedCluster + func (m *RouteAction_WeightedClusters) MarshalTo(dAtA []byte) (int, error) + func (m *RouteAction_WeightedClusters) Size() (n int) type RouteMatch + Headers []*route.HeaderMatcher + Invert bool + MatchSpecifier isRouteMatch_MatchSpecifier + func (*RouteMatch) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *RouteMatch) GetHeaders() []*route.HeaderMatcher + func (m *RouteMatch) GetInvert() bool + func (m *RouteMatch) GetMatchSpecifier() isRouteMatch_MatchSpecifier + func (m *RouteMatch) GetMethodName() string + func (m *RouteMatch) GetServiceName() string + type RouteMatch_MethodName struct + MethodName string + func (m *RouteMatch_MethodName) MarshalTo(dAtA []byte) (int, error) + func (m *RouteMatch_MethodName) Size() (n int) + type RouteMatch_ServiceName struct + ServiceName string + func (m *RouteMatch_ServiceName) MarshalTo(dAtA []byte) (int, error) + func (m *RouteMatch_ServiceName) Size() (n int) + type ThriftProtocolOptions struct + Protocol ProtocolType + Transport TransportType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ThriftProtocolOptions) Descriptor() ([]byte, []int) + func (*ThriftProtocolOptions) ProtoMessage() + func (dst *ThriftProtocolOptions) XXX_Merge(src proto.Message) + func (m *ThriftProtocolOptions) GetProtocol() ProtocolType + func (m *ThriftProtocolOptions) GetTransport() TransportType + func (m *ThriftProtocolOptions) Marshal() (dAtA []byte, err error) + func (m *ThriftProtocolOptions) MarshalTo(dAtA []byte) (int, error) + func (m *ThriftProtocolOptions) Reset() + func (m *ThriftProtocolOptions) Size() (n int) + func (m *ThriftProtocolOptions) String() string + func (m *ThriftProtocolOptions) Unmarshal(dAtA []byte) error + func (m *ThriftProtocolOptions) Validate() error + func (m *ThriftProtocolOptions) XXX_DiscardUnknown() + func (m *ThriftProtocolOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ThriftProtocolOptions) XXX_Size() int + func (m *ThriftProtocolOptions) XXX_Unmarshal(b []byte) error + type ThriftProtocolOptionsValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ThriftProtocolOptionsValidationError) Error() string + type TransportType int32 + const HEADER + func (TransportType) EnumDescriptor() ([]byte, []int) + func (x TransportType) String() string + type WeightedCluster struct + Clusters []*WeightedCluster_ClusterWeight + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WeightedCluster) Descriptor() ([]byte, []int) + func (*WeightedCluster) ProtoMessage() + func (dst *WeightedCluster) XXX_Merge(src proto.Message) + func (m *WeightedCluster) GetClusters() []*WeightedCluster_ClusterWeight + func (m *WeightedCluster) Marshal() (dAtA []byte, err error) + func (m *WeightedCluster) MarshalTo(dAtA []byte) (int, error) + func (m *WeightedCluster) Reset() + func (m *WeightedCluster) Size() (n int) + func (m *WeightedCluster) String() string + func (m *WeightedCluster) Unmarshal(dAtA []byte) error + func (m *WeightedCluster) Validate() error + func (m *WeightedCluster) XXX_DiscardUnknown() + func (m *WeightedCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WeightedCluster) XXX_Size() int + func (m *WeightedCluster) XXX_Unmarshal(b []byte) error + type WeightedClusterValidationError struct + Cause error + Field string + Key bool + Reason string + func (e WeightedClusterValidationError) Error() string + type WeightedCluster_ClusterWeight struct + MetadataMatch *core.Metadata + Name string + Weight *types.UInt32Value + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WeightedCluster_ClusterWeight) Descriptor() ([]byte, []int) + func (*WeightedCluster_ClusterWeight) ProtoMessage() + func (dst *WeightedCluster_ClusterWeight) XXX_Merge(src proto.Message) + func (m *WeightedCluster_ClusterWeight) GetMetadataMatch() *core.Metadata + func (m *WeightedCluster_ClusterWeight) GetName() string + func (m *WeightedCluster_ClusterWeight) GetWeight() *types.UInt32Value + func (m *WeightedCluster_ClusterWeight) Marshal() (dAtA []byte, err error) + func (m *WeightedCluster_ClusterWeight) MarshalTo(dAtA []byte) (int, error) + func (m *WeightedCluster_ClusterWeight) Reset() + func (m *WeightedCluster_ClusterWeight) Size() (n int) + func (m *WeightedCluster_ClusterWeight) String() string + func (m *WeightedCluster_ClusterWeight) Unmarshal(dAtA []byte) error + func (m *WeightedCluster_ClusterWeight) Validate() error + func (m *WeightedCluster_ClusterWeight) XXX_DiscardUnknown() + func (m *WeightedCluster_ClusterWeight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WeightedCluster_ClusterWeight) XXX_Size() int + func (m *WeightedCluster_ClusterWeight) XXX_Unmarshal(b []byte) error + type WeightedCluster_ClusterWeightValidationError struct + Cause error + Field string + Key bool + Reason string + func (e WeightedCluster_ClusterWeightValidationError) Error() string v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowRoute = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowThriftProxy = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRoute = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthThriftProxy = fmt.Errorf("proto: negative length found during unmarshaling") + var ThriftProxy_ProtocolType_name = map[int32]string + var ThriftProxy_ProtocolType_value = map[string]int32 + var ThriftProxy_TransportType_name = map[int32]string + var ThriftProxy_TransportType_value = map[string]int32 + type Route struct + Match RouteMatch + Route RouteAction + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Route) Descriptor() ([]byte, []int) + func (*Route) ProtoMessage() + func (dst *Route) XXX_Merge(src proto.Message) + func (m *Route) GetMatch() RouteMatch + func (m *Route) GetRoute() RouteAction + func (m *Route) Marshal() (dAtA []byte, err error) + func (m *Route) MarshalTo(dAtA []byte) (int, error) + func (m *Route) Reset() + func (m *Route) Size() (n int) + func (m *Route) String() string + func (m *Route) Unmarshal(dAtA []byte) error + func (m *Route) Validate() error + func (m *Route) XXX_DiscardUnknown() + func (m *Route) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Route) XXX_Size() int + func (m *Route) XXX_Unmarshal(b []byte) error + type RouteAction struct + Cluster string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RouteAction) Descriptor() ([]byte, []int) + func (*RouteAction) ProtoMessage() + func (dst *RouteAction) XXX_Merge(src proto.Message) + func (m *RouteAction) GetCluster() string + func (m *RouteAction) Marshal() (dAtA []byte, err error) + func (m *RouteAction) MarshalTo(dAtA []byte) (int, error) + func (m *RouteAction) Reset() + func (m *RouteAction) Size() (n int) + func (m *RouteAction) String() string + func (m *RouteAction) Unmarshal(dAtA []byte) error + func (m *RouteAction) Validate() error + func (m *RouteAction) XXX_DiscardUnknown() + func (m *RouteAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RouteAction) XXX_Size() int + func (m *RouteAction) XXX_Unmarshal(b []byte) error + type RouteActionValidationError struct + Cause error + Field string + Key bool + Reason string + func (e RouteActionValidationError) Error() string + type RouteConfiguration struct + Name string + Routes []Route + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RouteConfiguration) Descriptor() ([]byte, []int) + func (*RouteConfiguration) ProtoMessage() + func (dst *RouteConfiguration) XXX_Merge(src proto.Message) + func (m *RouteConfiguration) GetName() string + func (m *RouteConfiguration) GetRoutes() []Route + func (m *RouteConfiguration) Marshal() (dAtA []byte, err error) + func (m *RouteConfiguration) MarshalTo(dAtA []byte) (int, error) + func (m *RouteConfiguration) Reset() + func (m *RouteConfiguration) Size() (n int) + func (m *RouteConfiguration) String() string + func (m *RouteConfiguration) Unmarshal(dAtA []byte) error + func (m *RouteConfiguration) Validate() error + func (m *RouteConfiguration) XXX_DiscardUnknown() + func (m *RouteConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RouteConfiguration) XXX_Size() int + func (m *RouteConfiguration) XXX_Unmarshal(b []byte) error + type RouteConfigurationValidationError struct + Cause error + Field string + Key bool + Reason string + func (e RouteConfigurationValidationError) Error() string + type RouteMatch struct + Method string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RouteMatch) Descriptor() ([]byte, []int) + func (*RouteMatch) ProtoMessage() + func (dst *RouteMatch) XXX_Merge(src proto.Message) + func (m *RouteMatch) GetMethod() string + func (m *RouteMatch) Marshal() (dAtA []byte, err error) + func (m *RouteMatch) MarshalTo(dAtA []byte) (int, error) + func (m *RouteMatch) Reset() + func (m *RouteMatch) Size() (n int) + func (m *RouteMatch) String() string + func (m *RouteMatch) Unmarshal(dAtA []byte) error + func (m *RouteMatch) Validate() error + func (m *RouteMatch) XXX_DiscardUnknown() + func (m *RouteMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RouteMatch) XXX_Size() int + func (m *RouteMatch) XXX_Unmarshal(b []byte) error + type RouteMatchValidationError struct + Cause error + Field string + Key bool + Reason string + func (e RouteMatchValidationError) Error() string + type RouteValidationError struct + Cause error + Field string + Key bool + Reason string + func (e RouteValidationError) Error() string + type ThriftProxy struct + Protocol ThriftProxy_ProtocolType + RouteConfig *RouteConfiguration + StatPrefix string + Transport ThriftProxy_TransportType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ThriftProxy) Descriptor() ([]byte, []int) + func (*ThriftProxy) ProtoMessage() + func (dst *ThriftProxy) XXX_Merge(src proto.Message) + func (m *ThriftProxy) GetProtocol() ThriftProxy_ProtocolType + func (m *ThriftProxy) GetRouteConfig() *RouteConfiguration + func (m *ThriftProxy) GetStatPrefix() string + func (m *ThriftProxy) GetTransport() ThriftProxy_TransportType + func (m *ThriftProxy) Marshal() (dAtA []byte, err error) + func (m *ThriftProxy) MarshalTo(dAtA []byte) (int, error) + func (m *ThriftProxy) Reset() + func (m *ThriftProxy) Size() (n int) + func (m *ThriftProxy) String() string + func (m *ThriftProxy) Unmarshal(dAtA []byte) error + func (m *ThriftProxy) Validate() error + func (m *ThriftProxy) XXX_DiscardUnknown() + func (m *ThriftProxy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ThriftProxy) XXX_Size() int + func (m *ThriftProxy) XXX_Unmarshal(b []byte) error + type ThriftProxyValidationError struct + Cause error + Field string + Key bool + Reason string + func (e ThriftProxyValidationError) Error() string + type ThriftProxy_ProtocolType int32 + const AUTO_PROTOCOL + const BINARY + const COMPACT + const LAX_BINARY + func (ThriftProxy_ProtocolType) EnumDescriptor() ([]byte, []int) + func (x ThriftProxy_ProtocolType) String() string + type ThriftProxy_TransportType int32 + const AUTO_TRANSPORT + const FRAMED + const UNFRAMED + func (ThriftProxy_TransportType) EnumDescriptor() ([]byte, []int) + func (x ThriftProxy_TransportType) String() string