v1

package
v0.0.0-...-9d98e3d Latest Latest
Warning

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

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

Documentation

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 (
	AttributesMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	AttributesUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{}
)
View Source 
var (
	ErrInvalidLengthMixer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMixer   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	MixerMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	MixerUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{}
)
View Source 
var HeaderOperation_Operation_name = map[int32]string{
	0: "REPLACE",
	1: "REMOVE",
	2: "APPEND",
}
View Source 
var HeaderOperation_Operation_value = map[string]int32{
	"REPLACE": 0,
	"REMOVE":  1,
	"APPEND":  2,
}
View Source 
var ReferencedAttributes_Condition_name = map[int32]string{
	0: "CONDITION_UNSPECIFIED",
	1: "ABSENCE",
	2: "EXACT",
	3: "REGEX",
}
View Source 
var ReferencedAttributes_Condition_value = map[string]int32{
	"CONDITION_UNSPECIFIED": 0,
	"ABSENCE":               1,
	"EXACT":                 2,
	"REGEX":                 3,
}
View Source 
var ReportRequest_RepeatedAttributesSemantics_name = map[int32]string{
	0: "DELTA_ENCODING",
	1: "INDEPENDENT_ENCODING",
}
View Source 
var ReportRequest_RepeatedAttributesSemantics_value = map[string]int32{
	"DELTA_ENCODING":       0,
	"INDEPENDENT_ENCODING": 1,
}

Functions

func RegisterMixerServer 

func RegisterMixerServer(s *grpc.Server, srv MixerServer)

Types

type Attributes 

type Attributes struct {
	// A map of attribute name to its value.
	Attributes map[string]*Attributes_AttributeValue `` /* 161-byte string literal not displayed */
}

Attributes represents a set of typed name/value pairs. Many of Mixer's API either consume and/or return attributes.

Istio uses attributes to control the runtime behavior of services running in the service mesh. Attributes are named and typed pieces of metadata describing ingress and egress traffic and the environment this traffic occurs in. An Istio attribute carries a specific piece of information such as the error code of an API request, the latency of an API request, or the original IP address of a TCP connection. For example:

```yaml request.path: xyz/abc request.size: 234 request.time: 12:34:56.789 04/17/2017 source.ip: 192.168.0.1 target.service: example ```

A given Istio deployment has a fixed vocabulary of attributes that it understands. The specific vocabulary is determined by the set of attribute producers being used in the deployment. The primary attribute producer in Istio is Envoy, although specialized Mixer adapters and services can also generate attributes.

The common baseline set of attributes available in most Istio deployments is defined [here](https://istio.io/docs/reference/config/policy-and-telemetry/attribute-vocabulary/).

Attributes are strongly typed. The supported attribute types are defined by [ValueType](https://github.com/istio/api/blob/master/policy/v1beta1/value_type.proto). Each type of value is encoded into one of the so-called transport types present in this message.

Defines a map of attributes in uncompressed format. Following places may use this message: 1) Configure Istio/Proxy with static per-proxy attributes, such as source.uid. 2) Service IDL definition to extract api attributes for active requests. 3) Forward attributes from client proxy to server proxy for HTTP requests.

func (*Attributes) DeepCopy 

func (in *Attributes) DeepCopy() *Attributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Attributes. Required by controller-gen.

func (*Attributes) DeepCopyInto 

func (in *Attributes) DeepCopyInto(out *Attributes)

DeepCopyInto supports using Attributes within kubernetes types, where deepcopy-gen is used.

func (*Attributes) Descriptor 

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

func (*Attributes) Marshal 

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

func (*Attributes) MarshalJSON 

func (this *Attributes) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Attributes

func (*Attributes) MarshalTo 

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

func (*Attributes) MarshalToSizedBuffer 

func (m *Attributes) MarshalToSizedBuffer(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 (this *Attributes) String() string

func (*Attributes) Unmarshal 

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

func (*Attributes) UnmarshalJSON 

func (this *Attributes) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Attributes

func (*Attributes) XXX_DiscardUnknown 

func (m *Attributes) XXX_DiscardUnknown()

func (*Attributes) XXX_Marshal 

func (m *Attributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attributes) XXX_Merge 

func (m *Attributes) XXX_Merge(src proto.Message)

func (*Attributes) XXX_Size 

func (m *Attributes) XXX_Size() int

func (*Attributes) XXX_Unmarshal 

func (m *Attributes) XXX_Unmarshal(b []byte) error

type Attributes_AttributeValue 

type Attributes_AttributeValue struct {
	// The attribute value.
	//
	// Types that are valid to be assigned to Value:
	//	*Attributes_AttributeValue_StringValue
	//	*Attributes_AttributeValue_Int64Value
	//	*Attributes_AttributeValue_DoubleValue
	//	*Attributes_AttributeValue_BoolValue
	//	*Attributes_AttributeValue_BytesValue
	//	*Attributes_AttributeValue_TimestampValue
	//	*Attributes_AttributeValue_DurationValue
	//	*Attributes_AttributeValue_StringMapValue
	Value isAttributes_AttributeValue_Value `protobuf_oneof:"value"`
}

Specifies one attribute value with different type.

func (*Attributes_AttributeValue) DeepCopy 

func (in *Attributes_AttributeValue) DeepCopy() *Attributes_AttributeValue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Attributes_AttributeValue. Required by controller-gen.

func (*Attributes_AttributeValue) DeepCopyInto 

func (in *Attributes_AttributeValue) DeepCopyInto(out *Attributes_AttributeValue)

DeepCopyInto supports using Attributes_AttributeValue within kubernetes types, where deepcopy-gen is used.

func (*Attributes_AttributeValue) Descriptor 

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

func (*Attributes_AttributeValue) GetBoolValue 

func (m *Attributes_AttributeValue) GetBoolValue() bool

func (*Attributes_AttributeValue) GetBytesValue 

func (m *Attributes_AttributeValue) GetBytesValue() []byte

func (*Attributes_AttributeValue) GetDoubleValue 

func (m *Attributes_AttributeValue) GetDoubleValue() float64

func (*Attributes_AttributeValue) GetDurationValue 

func (m *Attributes_AttributeValue) GetDurationValue() *types.Duration

func (*Attributes_AttributeValue) GetInt64Value 

func (m *Attributes_AttributeValue) GetInt64Value() int64

func (*Attributes_AttributeValue) GetStringMapValue 

func (m *Attributes_AttributeValue) GetStringMapValue() *Attributes_StringMap

func (*Attributes_AttributeValue) GetStringValue 

func (m *Attributes_AttributeValue) GetStringValue() string

func (*Attributes_AttributeValue) GetTimestampValue 

func (m *Attributes_AttributeValue) GetTimestampValue() *types.Timestamp

func (*Attributes_AttributeValue) GetValue 

func (m *Attributes_AttributeValue) GetValue() isAttributes_AttributeValue_Value

func (*Attributes_AttributeValue) Marshal 

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

func (*Attributes_AttributeValue) MarshalJSON 

func (this *Attributes_AttributeValue) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Attributes_AttributeValue

func (*Attributes_AttributeValue) MarshalTo 

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

func (*Attributes_AttributeValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue) ProtoMessage 

func (*Attributes_AttributeValue) ProtoMessage()

func (*Attributes_AttributeValue) Reset 

func (m *Attributes_AttributeValue) Reset()

func (*Attributes_AttributeValue) Size 

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

func (*Attributes_AttributeValue) String 

func (this *Attributes_AttributeValue) String() string

func (*Attributes_AttributeValue) Unmarshal 

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

func (*Attributes_AttributeValue) UnmarshalJSON 

func (this *Attributes_AttributeValue) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Attributes_AttributeValue

func (*Attributes_AttributeValue) XXX_DiscardUnknown 

func (m *Attributes_AttributeValue) XXX_DiscardUnknown()

func (*Attributes_AttributeValue) XXX_Marshal 

func (m *Attributes_AttributeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attributes_AttributeValue) XXX_Merge 

func (m *Attributes_AttributeValue) XXX_Merge(src proto.Message)

func (*Attributes_AttributeValue) XXX_OneofWrappers 

func (*Attributes_AttributeValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Attributes_AttributeValue) XXX_Size 

func (m *Attributes_AttributeValue) XXX_Size() int

func (*Attributes_AttributeValue) XXX_Unmarshal 

func (m *Attributes_AttributeValue) XXX_Unmarshal(b []byte) error

type Attributes_AttributeValue_BoolValue 

type Attributes_AttributeValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,5,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_BoolValue) MarshalTo 

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

func (*Attributes_AttributeValue_BoolValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_BoolValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_BoolValue) Size 

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

func (*Attributes_AttributeValue_BoolValue) String 

func (this *Attributes_AttributeValue_BoolValue) String() string

type Attributes_AttributeValue_BytesValue 

type Attributes_AttributeValue_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,6,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_BytesValue) MarshalTo 

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

func (*Attributes_AttributeValue_BytesValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_BytesValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_BytesValue) Size 

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

func (*Attributes_AttributeValue_BytesValue) String 

func (this *Attributes_AttributeValue_BytesValue) String() string

type Attributes_AttributeValue_DoubleValue 

type Attributes_AttributeValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_DoubleValue) MarshalTo 

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

func (*Attributes_AttributeValue_DoubleValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_DoubleValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_DoubleValue) Size 

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

func (*Attributes_AttributeValue_DoubleValue) String 

func (this *Attributes_AttributeValue_DoubleValue) String() string

type Attributes_AttributeValue_DurationValue 

type Attributes_AttributeValue_DurationValue struct {
	DurationValue *types.Duration `protobuf:"bytes,8,opt,name=duration_value,json=durationValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_DurationValue) MarshalTo 

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

func (*Attributes_AttributeValue_DurationValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_DurationValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_DurationValue) Size 

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

func (*Attributes_AttributeValue_DurationValue) String 

func (this *Attributes_AttributeValue_DurationValue) String() string

type Attributes_AttributeValue_Int64Value 

type Attributes_AttributeValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

func (*Attributes_AttributeValue_Int64Value) MarshalTo 

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

func (*Attributes_AttributeValue_Int64Value) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_Int64Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_Int64Value) Size 

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

func (*Attributes_AttributeValue_Int64Value) String 

func (this *Attributes_AttributeValue_Int64Value) String() string

type Attributes_AttributeValue_StringMapValue 

type Attributes_AttributeValue_StringMapValue struct {
	StringMapValue *Attributes_StringMap `protobuf:"bytes,9,opt,name=string_map_value,json=stringMapValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_StringMapValue) MarshalTo 

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

func (*Attributes_AttributeValue_StringMapValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_StringMapValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_StringMapValue) Size 

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

func (*Attributes_AttributeValue_StringMapValue) String 

func (this *Attributes_AttributeValue_StringMapValue) String() string

type Attributes_AttributeValue_StringValue 

type Attributes_AttributeValue_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_StringValue) MarshalTo 

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

func (*Attributes_AttributeValue_StringValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_StringValue) Size 

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

func (*Attributes_AttributeValue_StringValue) String 

func (this *Attributes_AttributeValue_StringValue) String() string

type Attributes_AttributeValue_TimestampValue 

type Attributes_AttributeValue_TimestampValue struct {
	TimestampValue *types.Timestamp `protobuf:"bytes,7,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

func (*Attributes_AttributeValue_TimestampValue) MarshalTo 

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

func (*Attributes_AttributeValue_TimestampValue) MarshalToSizedBuffer 

func (m *Attributes_AttributeValue_TimestampValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_AttributeValue_TimestampValue) Size 

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

func (*Attributes_AttributeValue_TimestampValue) String 

func (this *Attributes_AttributeValue_TimestampValue) String() string

type Attributes_StringMap 

type Attributes_StringMap struct {
	// Holds a set of name/value pairs.
	Entries map[string]string `` /* 155-byte string literal not displayed */
}

Defines a string map.

func (*Attributes_StringMap) DeepCopy 

func (in *Attributes_StringMap) DeepCopy() *Attributes_StringMap

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Attributes_StringMap. Required by controller-gen.

func (*Attributes_StringMap) DeepCopyInto 

func (in *Attributes_StringMap) DeepCopyInto(out *Attributes_StringMap)

DeepCopyInto supports using Attributes_StringMap within kubernetes types, where deepcopy-gen is used.

func (*Attributes_StringMap) Descriptor 

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

func (*Attributes_StringMap) Marshal 

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

func (*Attributes_StringMap) MarshalJSON 

func (this *Attributes_StringMap) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Attributes_StringMap

func (*Attributes_StringMap) MarshalTo 

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

func (*Attributes_StringMap) MarshalToSizedBuffer 

func (m *Attributes_StringMap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Attributes_StringMap) ProtoMessage 

func (*Attributes_StringMap) ProtoMessage()

func (*Attributes_StringMap) Reset 

func (m *Attributes_StringMap) Reset()

func (*Attributes_StringMap) Size 

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

func (*Attributes_StringMap) String 

func (this *Attributes_StringMap) String() string

func (*Attributes_StringMap) Unmarshal 

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

func (*Attributes_StringMap) UnmarshalJSON 

func (this *Attributes_StringMap) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Attributes_StringMap

func (*Attributes_StringMap) XXX_DiscardUnknown 

func (m *Attributes_StringMap) XXX_DiscardUnknown()

func (*Attributes_StringMap) XXX_Marshal 

func (m *Attributes_StringMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attributes_StringMap) XXX_Merge 

func (m *Attributes_StringMap) XXX_Merge(src proto.Message)

func (*Attributes_StringMap) XXX_Size 

func (m *Attributes_StringMap) XXX_Size() int

func (*Attributes_StringMap) XXX_Unmarshal 

func (m *Attributes_StringMap) XXX_Unmarshal(b []byte) error

type CheckRequest 

type CheckRequest struct {
	// The attributes to use for this request.
	//
	// Mixer's configuration determines how these attributes are used to
	// establish the result returned in the response.
	Attributes CompressedAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes"`
	// The number of words in the global dictionary, used with to populate the attributes.
	// This value is used as a quick way to determine whether the client is using a dictionary that
	// the server understands.
	GlobalWordCount uint32 `protobuf:"varint,2,opt,name=global_word_count,json=globalWordCount,proto3" json:"global_word_count,omitempty"`
	// Used for deduplicating `Check` calls in the case of failed RPCs and retries. This should be a UUID
	// per call, where the same UUID is used for retries of the same call.
	DeduplicationId string `protobuf:"bytes,3,opt,name=deduplication_id,json=deduplicationId,proto3" json:"deduplication_id,omitempty"`
	// The individual quotas to allocate
	Quotas map[string]CheckRequest_QuotaParams `` /* 143-byte string literal not displayed */
}

Used to get a thumbs-up/thumbs-down before performing an action.

func (*CheckRequest) DeepCopy 

func (in *CheckRequest) DeepCopy() *CheckRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckRequest. Required by controller-gen.

func (*CheckRequest) DeepCopyInto 

func (in *CheckRequest) DeepCopyInto(out *CheckRequest)

DeepCopyInto supports using CheckRequest within kubernetes types, where deepcopy-gen is used.

func (*CheckRequest) Descriptor 

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

func (*CheckRequest) Marshal 

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

func (*CheckRequest) MarshalJSON 

func (this *CheckRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CheckRequest

func (*CheckRequest) MarshalTo 

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

func (*CheckRequest) MarshalToSizedBuffer 

func (m *CheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) Reset 

func (m *CheckRequest) Reset()

func (*CheckRequest) Size 

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

func (*CheckRequest) String 

func (this *CheckRequest) String() string

func (*CheckRequest) Unmarshal 

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

func (*CheckRequest) UnmarshalJSON 

func (this *CheckRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CheckRequest

func (*CheckRequest) XXX_DiscardUnknown 

func (m *CheckRequest) XXX_DiscardUnknown()

func (*CheckRequest) XXX_Marshal 

func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckRequest) XXX_Merge 

func (m *CheckRequest) XXX_Merge(src proto.Message)

func (*CheckRequest) XXX_Size 

func (m *CheckRequest) XXX_Size() int

func (*CheckRequest) XXX_Unmarshal 

func (m *CheckRequest) XXX_Unmarshal(b []byte) error

type CheckRequest_QuotaParams 

type CheckRequest_QuotaParams struct {
	// Amount of quota to allocate
	Amount int64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// When true, supports returning less quota than what was requested.
	BestEffort bool `protobuf:"varint,2,opt,name=best_effort,json=bestEffort,proto3" json:"best_effort,omitempty"`
}

parameters for a quota allocation

func (*CheckRequest_QuotaParams) DeepCopy 

func (in *CheckRequest_QuotaParams) DeepCopy() *CheckRequest_QuotaParams

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckRequest_QuotaParams. Required by controller-gen.

func (*CheckRequest_QuotaParams) DeepCopyInto 

func (in *CheckRequest_QuotaParams) DeepCopyInto(out *CheckRequest_QuotaParams)

DeepCopyInto supports using CheckRequest_QuotaParams within kubernetes types, where deepcopy-gen is used.

func (*CheckRequest_QuotaParams) Descriptor 

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

func (*CheckRequest_QuotaParams) Marshal 

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

func (*CheckRequest_QuotaParams) MarshalJSON 

func (this *CheckRequest_QuotaParams) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CheckRequest_QuotaParams

func (*CheckRequest_QuotaParams) MarshalTo 

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

func (*CheckRequest_QuotaParams) MarshalToSizedBuffer 

func (m *CheckRequest_QuotaParams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckRequest_QuotaParams) ProtoMessage 

func (*CheckRequest_QuotaParams) ProtoMessage()

func (*CheckRequest_QuotaParams) Reset 

func (m *CheckRequest_QuotaParams) Reset()

func (*CheckRequest_QuotaParams) Size 

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

func (*CheckRequest_QuotaParams) String 

func (this *CheckRequest_QuotaParams) String() string

func (*CheckRequest_QuotaParams) Unmarshal 

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

func (*CheckRequest_QuotaParams) UnmarshalJSON 

func (this *CheckRequest_QuotaParams) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CheckRequest_QuotaParams

func (*CheckRequest_QuotaParams) XXX_DiscardUnknown 

func (m *CheckRequest_QuotaParams) XXX_DiscardUnknown()

func (*CheckRequest_QuotaParams) XXX_Marshal 

func (m *CheckRequest_QuotaParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckRequest_QuotaParams) XXX_Merge 

func (m *CheckRequest_QuotaParams) XXX_Merge(src proto.Message)

func (*CheckRequest_QuotaParams) XXX_Size 

func (m *CheckRequest_QuotaParams) XXX_Size() int

func (*CheckRequest_QuotaParams) XXX_Unmarshal 

func (m *CheckRequest_QuotaParams) XXX_Unmarshal(b []byte) error

type CheckResponse 

type CheckResponse struct {
	// The precondition check results.
	Precondition CheckResponse_PreconditionResult `protobuf:"bytes,2,opt,name=precondition,proto3" json:"precondition"`
	// The resulting quota, one entry per requested quota.
	Quotas map[string]CheckResponse_QuotaResult `` /* 143-byte string literal not displayed */
}

The response generated by the Check method.

func (*CheckResponse) DeepCopy 

func (in *CheckResponse) DeepCopy() *CheckResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckResponse. Required by controller-gen.

func (*CheckResponse) DeepCopyInto 

func (in *CheckResponse) DeepCopyInto(out *CheckResponse)

DeepCopyInto supports using CheckResponse within kubernetes types, where deepcopy-gen is used.

func (*CheckResponse) Descriptor 

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

func (*CheckResponse) Marshal 

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

func (*CheckResponse) MarshalJSON 

func (this *CheckResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CheckResponse

func (*CheckResponse) MarshalTo 

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

func (*CheckResponse) MarshalToSizedBuffer 

func (m *CheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) Reset 

func (m *CheckResponse) Reset()

func (*CheckResponse) Size 

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

func (*CheckResponse) String 

func (this *CheckResponse) String() string

func (*CheckResponse) Unmarshal 

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

func (*CheckResponse) UnmarshalJSON 

func (this *CheckResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CheckResponse

func (*CheckResponse) XXX_DiscardUnknown 

func (m *CheckResponse) XXX_DiscardUnknown()

func (*CheckResponse) XXX_Marshal 

func (m *CheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckResponse) XXX_Merge 

func (m *CheckResponse) XXX_Merge(src proto.Message)

func (*CheckResponse) XXX_Size 

func (m *CheckResponse) XXX_Size() int

func (*CheckResponse) XXX_Unmarshal 

func (m *CheckResponse) XXX_Unmarshal(b []byte) error

type CheckResponse_PreconditionResult 

type CheckResponse_PreconditionResult struct {
	// A status code of OK indicates all preconditions were satisfied. Any other code indicates not
	// all preconditions were satisfied and details describe why.
	Status rpc.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status"`
	// The amount of time for which this result can be considered valid.
	ValidDuration time.Duration `protobuf:"bytes,2,opt,name=valid_duration,json=validDuration,proto3,stdduration" json:"valid_duration"`
	// The number of uses for which this result can be considered valid.
	ValidUseCount int32 `protobuf:"varint,3,opt,name=valid_use_count,json=validUseCount,proto3" json:"valid_use_count,omitempty"`
	// The total set of attributes that were used in producing the result
	// along with matching conditions.
	ReferencedAttributes *ReferencedAttributes `protobuf:"bytes,5,opt,name=referenced_attributes,json=referencedAttributes,proto3" json:"referenced_attributes,omitempty"`
	// An optional routing directive, used to manipulate the traffic metadata
	// whenever all preconditions are satisfied.
	RouteDirective *RouteDirective `protobuf:"bytes,6,opt,name=route_directive,json=routeDirective,proto3" json:"route_directive,omitempty"`
}

Expresses the result of a precondition check.

func (*CheckResponse_PreconditionResult) DeepCopy 

func (in *CheckResponse_PreconditionResult) DeepCopy() *CheckResponse_PreconditionResult

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckResponse_PreconditionResult. Required by controller-gen.

func (*CheckResponse_PreconditionResult) DeepCopyInto 

func (in *CheckResponse_PreconditionResult) DeepCopyInto(out *CheckResponse_PreconditionResult)

DeepCopyInto supports using CheckResponse_PreconditionResult within kubernetes types, where deepcopy-gen is used.

func (*CheckResponse_PreconditionResult) Descriptor 

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

func (*CheckResponse_PreconditionResult) Marshal 

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

func (*CheckResponse_PreconditionResult) MarshalJSON 

func (this *CheckResponse_PreconditionResult) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CheckResponse_PreconditionResult

func (*CheckResponse_PreconditionResult) MarshalTo 

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

func (*CheckResponse_PreconditionResult) MarshalToSizedBuffer 

func (m *CheckResponse_PreconditionResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckResponse_PreconditionResult) ProtoMessage 

func (*CheckResponse_PreconditionResult) ProtoMessage()

func (*CheckResponse_PreconditionResult) Reset 

func (m *CheckResponse_PreconditionResult) Reset()

func (*CheckResponse_PreconditionResult) Size 

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

func (*CheckResponse_PreconditionResult) String 

func (this *CheckResponse_PreconditionResult) String() string

func (*CheckResponse_PreconditionResult) Unmarshal 

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

func (*CheckResponse_PreconditionResult) UnmarshalJSON 

func (this *CheckResponse_PreconditionResult) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CheckResponse_PreconditionResult

func (*CheckResponse_PreconditionResult) XXX_DiscardUnknown 

func (m *CheckResponse_PreconditionResult) XXX_DiscardUnknown()

func (*CheckResponse_PreconditionResult) XXX_Marshal 

func (m *CheckResponse_PreconditionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckResponse_PreconditionResult) XXX_Merge 

func (m *CheckResponse_PreconditionResult) XXX_Merge(src proto.Message)

func (*CheckResponse_PreconditionResult) XXX_Size 

func (m *CheckResponse_PreconditionResult) XXX_Size() int

func (*CheckResponse_PreconditionResult) XXX_Unmarshal 

func (m *CheckResponse_PreconditionResult) XXX_Unmarshal(b []byte) error

type CheckResponse_QuotaResult 

type CheckResponse_QuotaResult struct {
	// The amount of time for which this result can be considered valid.
	ValidDuration time.Duration `protobuf:"bytes,1,opt,name=valid_duration,json=validDuration,proto3,stdduration" json:"valid_duration"`
	// The amount of granted quota. When `QuotaParams.best_effort` is true, this will be >= 0.
	// If `QuotaParams.best_effort` is false, this will be either 0 or >= `QuotaParams.amount`.
	GrantedAmount int64 `protobuf:"varint,2,opt,name=granted_amount,json=grantedAmount,proto3" json:"granted_amount,omitempty"`
	// A status code of OK indicates quota was fetched successfully.
	// Any other code indicates error in fetching quota.
	Status rpc.Status `protobuf:"bytes,6,opt,name=status,proto3" json:"status"`
	// The total set of attributes that were used in producing the result
	// along with matching conditions.
	ReferencedAttributes ReferencedAttributes `protobuf:"bytes,5,opt,name=referenced_attributes,json=referencedAttributes,proto3" json:"referenced_attributes"`
}

Expresses the result of a quota allocation.

func (*CheckResponse_QuotaResult) DeepCopy 

func (in *CheckResponse_QuotaResult) DeepCopy() *CheckResponse_QuotaResult

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckResponse_QuotaResult. Required by controller-gen.

func (*CheckResponse_QuotaResult) DeepCopyInto 

func (in *CheckResponse_QuotaResult) DeepCopyInto(out *CheckResponse_QuotaResult)

DeepCopyInto supports using CheckResponse_QuotaResult within kubernetes types, where deepcopy-gen is used.

func (*CheckResponse_QuotaResult) Descriptor 

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

func (*CheckResponse_QuotaResult) Marshal 

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

func (*CheckResponse_QuotaResult) MarshalJSON 

func (this *CheckResponse_QuotaResult) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CheckResponse_QuotaResult

func (*CheckResponse_QuotaResult) MarshalTo 

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

func (*CheckResponse_QuotaResult) MarshalToSizedBuffer 

func (m *CheckResponse_QuotaResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckResponse_QuotaResult) ProtoMessage 

func (*CheckResponse_QuotaResult) ProtoMessage()

func (*CheckResponse_QuotaResult) Reset 

func (m *CheckResponse_QuotaResult) Reset()

func (*CheckResponse_QuotaResult) Size 

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

func (*CheckResponse_QuotaResult) String 

func (this *CheckResponse_QuotaResult) String() string

func (*CheckResponse_QuotaResult) Unmarshal 

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

func (*CheckResponse_QuotaResult) UnmarshalJSON 

func (this *CheckResponse_QuotaResult) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CheckResponse_QuotaResult

func (*CheckResponse_QuotaResult) XXX_DiscardUnknown 

func (m *CheckResponse_QuotaResult) XXX_DiscardUnknown()

func (*CheckResponse_QuotaResult) XXX_Marshal 

func (m *CheckResponse_QuotaResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckResponse_QuotaResult) XXX_Merge 

func (m *CheckResponse_QuotaResult) XXX_Merge(src proto.Message)

func (*CheckResponse_QuotaResult) XXX_Size 

func (m *CheckResponse_QuotaResult) XXX_Size() int

func (*CheckResponse_QuotaResult) XXX_Unmarshal 

func (m *CheckResponse_QuotaResult) XXX_Unmarshal(b []byte) error

type CompressedAttributes 

type CompressedAttributes struct {
	// The message-level dictionary.
	Words []string `protobuf:"bytes,1,rep,name=words,proto3" json:"words,omitempty"`
	// Holds attributes of type STRING, DNS_NAME, EMAIL_ADDRESS, URI
	Strings map[int32]int32 `` /* 161-byte string literal not displayed */
	// Holds attributes of type INT64
	Int64S map[int32]int64 `` /* 157-byte string literal not displayed */
	// Holds attributes of type DOUBLE
	Doubles map[int32]float64 `` /* 160-byte string literal not displayed */
	// Holds attributes of type BOOL
	Bools map[int32]bool `` /* 155-byte string literal not displayed */
	// Holds attributes of type TIMESTAMP
	Timestamps map[int32]time.Time `` /* 162-byte string literal not displayed */
	// Holds attributes of type DURATION
	Durations map[int32]time.Duration `` /* 164-byte string literal not displayed */
	// Holds attributes of type BYTES
	Bytes map[int32][]byte `` /* 154-byte string literal not displayed */
	// Holds attributes of type STRING_MAP
	StringMaps map[int32]StringMap `` /* 172-byte string literal not displayed */
}

Defines a list of attributes in compressed format optimized for transport. Within this message, strings are referenced using integer indices into one of two string dictionaries. Positive integers index into the global deployment-wide dictionary, whereas negative integers index into the message-level dictionary instead. The message-level dictionary is carried by the `words` field of this message, the deployment-wide dictionary is determined via configuration.

func (*CompressedAttributes) DeepCopy 

func (in *CompressedAttributes) DeepCopy() *CompressedAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CompressedAttributes. Required by controller-gen.

func (*CompressedAttributes) DeepCopyInto 

func (in *CompressedAttributes) DeepCopyInto(out *CompressedAttributes)

DeepCopyInto supports using CompressedAttributes within kubernetes types, where deepcopy-gen is used.

func (*CompressedAttributes) Descriptor 

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

func (*CompressedAttributes) Marshal 

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

func (*CompressedAttributes) MarshalJSON 

func (this *CompressedAttributes) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for CompressedAttributes

func (*CompressedAttributes) MarshalTo 

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

func (*CompressedAttributes) MarshalToSizedBuffer 

func (m *CompressedAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompressedAttributes) ProtoMessage 

func (*CompressedAttributes) ProtoMessage()

func (*CompressedAttributes) Reset 

func (m *CompressedAttributes) Reset()

func (*CompressedAttributes) Size 

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

func (*CompressedAttributes) String 

func (this *CompressedAttributes) String() string

func (*CompressedAttributes) Unmarshal 

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

func (*CompressedAttributes) UnmarshalJSON 

func (this *CompressedAttributes) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for CompressedAttributes

func (*CompressedAttributes) XXX_DiscardUnknown 

func (m *CompressedAttributes) XXX_DiscardUnknown()

func (*CompressedAttributes) XXX_Marshal 

func (m *CompressedAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompressedAttributes) XXX_Merge 

func (m *CompressedAttributes) XXX_Merge(src proto.Message)

func (*CompressedAttributes) XXX_Size 

func (m *CompressedAttributes) XXX_Size() int

func (*CompressedAttributes) XXX_Unmarshal 

func (m *CompressedAttributes) XXX_Unmarshal(b []byte) error

type HeaderOperation 

type HeaderOperation struct {
	// Header name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Header value.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// Header operation.
	Operation HeaderOperation_Operation `protobuf:"varint,3,opt,name=operation,proto3,enum=istio.mixer.v1.HeaderOperation_Operation" json:"operation,omitempty"`
}

Operation on HTTP headers to replace, append, or remove a header. Header names are normalized to lower-case with dashes, e.g. "x-request-id". Pseudo-headers ":path", ":authority", and ":method" are supported to modify the request headers.

func (*HeaderOperation) DeepCopy 

func (in *HeaderOperation) DeepCopy() *HeaderOperation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HeaderOperation. Required by controller-gen.

func (*HeaderOperation) DeepCopyInto 

func (in *HeaderOperation) DeepCopyInto(out *HeaderOperation)

DeepCopyInto supports using HeaderOperation within kubernetes types, where deepcopy-gen is used.

func (*HeaderOperation) Descriptor 

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

func (*HeaderOperation) Marshal 

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

func (*HeaderOperation) MarshalJSON 

func (this *HeaderOperation) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for HeaderOperation

func (*HeaderOperation) MarshalTo 

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

func (*HeaderOperation) MarshalToSizedBuffer 

func (m *HeaderOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeaderOperation) ProtoMessage 

func (*HeaderOperation) ProtoMessage()

func (*HeaderOperation) Reset 

func (m *HeaderOperation) Reset()

func (*HeaderOperation) Size 

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

func (*HeaderOperation) String 

func (this *HeaderOperation) String() string

func (*HeaderOperation) Unmarshal 

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

func (*HeaderOperation) UnmarshalJSON 

func (this *HeaderOperation) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for HeaderOperation

func (*HeaderOperation) XXX_DiscardUnknown 

func (m *HeaderOperation) XXX_DiscardUnknown()

func (*HeaderOperation) XXX_Marshal 

func (m *HeaderOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeaderOperation) XXX_Merge 

func (m *HeaderOperation) XXX_Merge(src proto.Message)

func (*HeaderOperation) XXX_Size 

func (m *HeaderOperation) XXX_Size() int

func (*HeaderOperation) XXX_Unmarshal 

func (m *HeaderOperation) XXX_Unmarshal(b []byte) error

type HeaderOperation_Operation 

type HeaderOperation_Operation int32

Operation type. 

const (
	REPLACE HeaderOperation_Operation = 0
	REMOVE  HeaderOperation_Operation = 1
	APPEND  HeaderOperation_Operation = 2
)

func (HeaderOperation_Operation) EnumDescriptor 

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

func (HeaderOperation_Operation) String 

func (x HeaderOperation_Operation) String() string

type MixerClient 

type MixerClient interface {
	// Checks preconditions and allocate quota before performing an operation.
	// The preconditions enforced depend on the set of supplied attributes and
	// the active configuration.
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
	// Reports telemetry, such as logs and metrics.
	// The reported information depends on the set of supplied attributes and the
	// active configuration.
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error)
}

MixerClient is the client API for Mixer service.

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

func NewMixerClient 

func NewMixerClient(cc *grpc.ClientConn) MixerClient

type MixerServer 

type MixerServer interface {
	// Checks preconditions and allocate quota before performing an operation.
	// The preconditions enforced depend on the set of supplied attributes and
	// the active configuration.
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	// Reports telemetry, such as logs and metrics.
	// The reported information depends on the set of supplied attributes and the
	// active configuration.
	Report(context.Context, *ReportRequest) (*ReportResponse, error)
}

MixerServer is the server API for Mixer service.

type ReferencedAttributes 

type ReferencedAttributes struct {
	// The message-level dictionary. Refer to [CompressedAttributes][istio.mixer.v1.CompressedAttributes] for information
	// on using dictionaries.
	Words []string `protobuf:"bytes,1,rep,name=words,proto3" json:"words,omitempty"`
	// Describes a set of attributes.
	AttributeMatches []ReferencedAttributes_AttributeMatch `protobuf:"bytes,2,rep,name=attribute_matches,json=attributeMatches,proto3" json:"attribute_matches"`
}

Describes the attributes that were used to determine the response. This can be used to construct a response cache.

func (*ReferencedAttributes) DeepCopy 

func (in *ReferencedAttributes) DeepCopy() *ReferencedAttributes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferencedAttributes. Required by controller-gen.

func (*ReferencedAttributes) DeepCopyInto 

func (in *ReferencedAttributes) DeepCopyInto(out *ReferencedAttributes)

DeepCopyInto supports using ReferencedAttributes within kubernetes types, where deepcopy-gen is used.

func (*ReferencedAttributes) Descriptor 

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

func (*ReferencedAttributes) Marshal 

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

func (*ReferencedAttributes) MarshalJSON 

func (this *ReferencedAttributes) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReferencedAttributes

func (*ReferencedAttributes) MarshalTo 

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

func (*ReferencedAttributes) MarshalToSizedBuffer 

func (m *ReferencedAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReferencedAttributes) ProtoMessage 

func (*ReferencedAttributes) ProtoMessage()

func (*ReferencedAttributes) Reset 

func (m *ReferencedAttributes) Reset()

func (*ReferencedAttributes) Size 

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

func (*ReferencedAttributes) String 

func (this *ReferencedAttributes) String() string

func (*ReferencedAttributes) Unmarshal 

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

func (*ReferencedAttributes) UnmarshalJSON 

func (this *ReferencedAttributes) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReferencedAttributes

func (*ReferencedAttributes) XXX_DiscardUnknown 

func (m *ReferencedAttributes) XXX_DiscardUnknown()

func (*ReferencedAttributes) XXX_Marshal 

func (m *ReferencedAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReferencedAttributes) XXX_Merge 

func (m *ReferencedAttributes) XXX_Merge(src proto.Message)

func (*ReferencedAttributes) XXX_Size 

func (m *ReferencedAttributes) XXX_Size() int

func (*ReferencedAttributes) XXX_Unmarshal 

func (m *ReferencedAttributes) XXX_Unmarshal(b []byte) error

type ReferencedAttributes_AttributeMatch 

type ReferencedAttributes_AttributeMatch struct {
	// The name of the attribute. This is a dictionary index encoded in a manner identical
	// to all strings in the [CompressedAttributes][istio.mixer.v1.CompressedAttributes] message.
	Name int32 `protobuf:"zigzag32,1,opt,name=name,proto3" json:"name,omitempty"`
	// The kind of match against the attribute value.
	Condition ReferencedAttributes_Condition `protobuf:"varint,2,opt,name=condition,proto3,enum=istio.mixer.v1.ReferencedAttributes_Condition" json:"condition,omitempty"`
	// If a REGEX condition is provided for a STRING_MAP attribute,
	// clients should use the regex value to match against map keys.
	// RE2 style regex-based match (https://github.com/google/re2/wiki/Syntax).
	Regex string `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	// A key in a STRING_MAP. When multiple keys from a STRING_MAP
	// attribute were referenced, there will be multiple AttributeMatch
	// messages with different map_key values. Values for map_key SHOULD
	// be ignored for attributes that are not STRING_MAP.
	//
	// Indices for the keys are used (taken either from the
	// message dictionary from the `words` field or the global dictionary).
	//
	// If no map_key value is provided for a STRING_MAP attribute, the
	// entire STRING_MAP will be used.
	MapKey int32 `protobuf:"zigzag32,4,opt,name=map_key,json=mapKey,proto3" json:"map_key,omitempty"`
}

Describes a single attribute match.

func (*ReferencedAttributes_AttributeMatch) DeepCopy 

func (in *ReferencedAttributes_AttributeMatch) DeepCopy() *ReferencedAttributes_AttributeMatch

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReferencedAttributes_AttributeMatch. Required by controller-gen.

func (*ReferencedAttributes_AttributeMatch) DeepCopyInto 

func (in *ReferencedAttributes_AttributeMatch) DeepCopyInto(out *ReferencedAttributes_AttributeMatch)

DeepCopyInto supports using ReferencedAttributes_AttributeMatch within kubernetes types, where deepcopy-gen is used.

func (*ReferencedAttributes_AttributeMatch) Descriptor 

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

func (*ReferencedAttributes_AttributeMatch) Marshal 

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

func (*ReferencedAttributes_AttributeMatch) MarshalJSON 

func (this *ReferencedAttributes_AttributeMatch) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReferencedAttributes_AttributeMatch

func (*ReferencedAttributes_AttributeMatch) MarshalTo 

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

func (*ReferencedAttributes_AttributeMatch) MarshalToSizedBuffer 

func (m *ReferencedAttributes_AttributeMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReferencedAttributes_AttributeMatch) ProtoMessage 

func (*ReferencedAttributes_AttributeMatch) ProtoMessage()

func (*ReferencedAttributes_AttributeMatch) Reset 

func (m *ReferencedAttributes_AttributeMatch) Reset()

func (*ReferencedAttributes_AttributeMatch) Size 

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

func (*ReferencedAttributes_AttributeMatch) String 

func (this *ReferencedAttributes_AttributeMatch) String() string

func (*ReferencedAttributes_AttributeMatch) Unmarshal 

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

func (*ReferencedAttributes_AttributeMatch) UnmarshalJSON 

func (this *ReferencedAttributes_AttributeMatch) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReferencedAttributes_AttributeMatch

func (*ReferencedAttributes_AttributeMatch) XXX_DiscardUnknown 

func (m *ReferencedAttributes_AttributeMatch) XXX_DiscardUnknown()

func (*ReferencedAttributes_AttributeMatch) XXX_Marshal 

func (m *ReferencedAttributes_AttributeMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReferencedAttributes_AttributeMatch) XXX_Merge 

func (m *ReferencedAttributes_AttributeMatch) XXX_Merge(src proto.Message)

func (*ReferencedAttributes_AttributeMatch) XXX_Size 

func (m *ReferencedAttributes_AttributeMatch) XXX_Size() int

func (*ReferencedAttributes_AttributeMatch) XXX_Unmarshal 

func (m *ReferencedAttributes_AttributeMatch) XXX_Unmarshal(b []byte) error

type ReferencedAttributes_Condition 

type ReferencedAttributes_Condition int32

How an attribute's value was matched 

const (
	CONDITION_UNSPECIFIED ReferencedAttributes_Condition = 0
	ABSENCE               ReferencedAttributes_Condition = 1
	EXACT                 ReferencedAttributes_Condition = 2
	REGEX                 ReferencedAttributes_Condition = 3
)

func (ReferencedAttributes_Condition) EnumDescriptor 

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

func (ReferencedAttributes_Condition) String 

func (x ReferencedAttributes_Condition) String() string

type ReportRequest 

type ReportRequest struct {
	// The attributes to use for this request.
	//
	// Each `Attributes` element represents the state of a single action. Multiple actions
	// can be provided in a single message in order to improve communication efficiency. The
	// client can accumulate a set of actions and send them all in one single message.
	Attributes []CompressedAttributes `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes"`
	// Indicates how to decode the attributes sets in this request.
	RepeatedAttributesSemantics ReportRequest_RepeatedAttributesSemantics `` /* 207-byte string literal not displayed */
	// The default message-level dictionary for all the attributes.
	// Individual attribute messages can have their own dictionaries, but if they don't
	// then this set of words, if it is provided, is used instead.
	//
	// This makes it possible to share the same dictionary for all attributes in this
	// request, which can substantially reduce the overall request size.
	DefaultWords []string `protobuf:"bytes,2,rep,name=default_words,json=defaultWords,proto3" json:"default_words,omitempty"`
	// The number of words in the global dictionary.
	// To detect global dictionary out of sync between client and server.
	GlobalWordCount uint32 `protobuf:"varint,3,opt,name=global_word_count,json=globalWordCount,proto3" json:"global_word_count,omitempty"`
}

Used to report telemetry after performing one or more actions.

func (*ReportRequest) DeepCopy 

func (in *ReportRequest) DeepCopy() *ReportRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReportRequest. Required by controller-gen.

func (*ReportRequest) DeepCopyInto 

func (in *ReportRequest) DeepCopyInto(out *ReportRequest)

DeepCopyInto supports using ReportRequest within kubernetes types, where deepcopy-gen is used.

func (*ReportRequest) Descriptor 

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

func (*ReportRequest) Marshal 

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

func (*ReportRequest) MarshalJSON 

func (this *ReportRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReportRequest

func (*ReportRequest) MarshalTo 

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

func (*ReportRequest) MarshalToSizedBuffer 

func (m *ReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) Reset 

func (m *ReportRequest) Reset()

func (*ReportRequest) Size 

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

func (*ReportRequest) String 

func (this *ReportRequest) String() string

func (*ReportRequest) Unmarshal 

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

func (*ReportRequest) UnmarshalJSON 

func (this *ReportRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReportRequest

func (*ReportRequest) XXX_DiscardUnknown 

func (m *ReportRequest) XXX_DiscardUnknown()

func (*ReportRequest) XXX_Marshal 

func (m *ReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportRequest) XXX_Merge 

func (m *ReportRequest) XXX_Merge(src proto.Message)

func (*ReportRequest) XXX_Size 

func (m *ReportRequest) XXX_Size() int

func (*ReportRequest) XXX_Unmarshal 

func (m *ReportRequest) XXX_Unmarshal(b []byte) error

type ReportRequest_RepeatedAttributesSemantics 

type ReportRequest_RepeatedAttributesSemantics int32

Used to signal how the sets of compressed attributes should be reconstituted server-side. 

const (
	// Use delta encoding between sets of compressed attributes to reduce the overall on-wire
	// request size. Each individual set of attributes is used to modify the previous set.
	// NOTE: There is no way with this encoding to specify attribute value deletion. This
	// option should be used with extreme caution.
	DELTA_ENCODING ReportRequest_RepeatedAttributesSemantics = 0
	// Treat each set of compressed attributes as complete - independent from other sets
	// in this request. This will result in on-wire duplication of attributes and values, but
	// will allow for proper accounting of absent values in overall encoding.
	INDEPENDENT_ENCODING ReportRequest_RepeatedAttributesSemantics = 1
)

func (ReportRequest_RepeatedAttributesSemantics) EnumDescriptor 

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

func (ReportRequest_RepeatedAttributesSemantics) String 

func (x ReportRequest_RepeatedAttributesSemantics) String() string

type ReportResponse 

type ReportResponse struct {
}

Used to carry responses to telemetry reports

func (*ReportResponse) DeepCopy 

func (in *ReportResponse) DeepCopy() *ReportResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReportResponse. Required by controller-gen.

func (*ReportResponse) DeepCopyInto 

func (in *ReportResponse) DeepCopyInto(out *ReportResponse)

DeepCopyInto supports using ReportResponse within kubernetes types, where deepcopy-gen is used.

func (*ReportResponse) Descriptor 

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

func (*ReportResponse) Marshal 

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

func (*ReportResponse) MarshalJSON 

func (this *ReportResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ReportResponse

func (*ReportResponse) MarshalTo 

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

func (*ReportResponse) MarshalToSizedBuffer 

func (m *ReportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReportResponse) ProtoMessage 

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) Reset 

func (m *ReportResponse) Reset()

func (*ReportResponse) Size 

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

func (*ReportResponse) String 

func (this *ReportResponse) String() string

func (*ReportResponse) Unmarshal 

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

func (*ReportResponse) UnmarshalJSON 

func (this *ReportResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ReportResponse

func (*ReportResponse) XXX_DiscardUnknown 

func (m *ReportResponse) XXX_DiscardUnknown()

func (*ReportResponse) XXX_Marshal 

func (m *ReportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportResponse) XXX_Merge 

func (m *ReportResponse) XXX_Merge(src proto.Message)

func (*ReportResponse) XXX_Size 

func (m *ReportResponse) XXX_Size() int

func (*ReportResponse) XXX_Unmarshal 

func (m *ReportResponse) XXX_Unmarshal(b []byte) error

type RouteDirective 

type RouteDirective struct {
	// Operations on the request headers.
	RequestHeaderOperations []HeaderOperation `protobuf:"bytes,1,rep,name=request_header_operations,json=requestHeaderOperations,proto3" json:"request_header_operations"`
	// Operations on the response headers.
	ResponseHeaderOperations []HeaderOperation `protobuf:"bytes,2,rep,name=response_header_operations,json=responseHeaderOperations,proto3" json:"response_header_operations"`
	// If set, enables a direct response without proxying the request to the routing
	// destination. Required to be a value in the 2xx or 3xx range.
	DirectResponseCode uint32 `protobuf:"varint,3,opt,name=direct_response_code,json=directResponseCode,proto3" json:"direct_response_code,omitempty"`
	// Supplies the response body for the direct response.
	// If this setting is omitted, no body is included in the generated response.
	DirectResponseBody string `protobuf:"bytes,4,opt,name=direct_response_body,json=directResponseBody,proto3" json:"direct_response_body,omitempty"`
}

Expresses the routing manipulation actions to be performed on behalf of Mixer in response to a precondition check.

func (*RouteDirective) DeepCopy 

func (in *RouteDirective) DeepCopy() *RouteDirective

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RouteDirective. Required by controller-gen.

func (*RouteDirective) DeepCopyInto 

func (in *RouteDirective) DeepCopyInto(out *RouteDirective)

DeepCopyInto supports using RouteDirective within kubernetes types, where deepcopy-gen is used.

func (*RouteDirective) Descriptor 

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

func (*RouteDirective) Marshal 

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

func (*RouteDirective) MarshalJSON 

func (this *RouteDirective) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for RouteDirective

func (*RouteDirective) MarshalTo 

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

func (*RouteDirective) MarshalToSizedBuffer 

func (m *RouteDirective) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RouteDirective) ProtoMessage 

func (*RouteDirective) ProtoMessage()

func (*RouteDirective) Reset 

func (m *RouteDirective) Reset()

func (*RouteDirective) Size 

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

func (*RouteDirective) String 

func (this *RouteDirective) String() string

func (*RouteDirective) Unmarshal 

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

func (*RouteDirective) UnmarshalJSON 

func (this *RouteDirective) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for RouteDirective

func (*RouteDirective) XXX_DiscardUnknown 

func (m *RouteDirective) XXX_DiscardUnknown()

func (*RouteDirective) XXX_Marshal 

func (m *RouteDirective) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RouteDirective) XXX_Merge 

func (m *RouteDirective) XXX_Merge(src proto.Message)

func (*RouteDirective) XXX_Size 

func (m *RouteDirective) XXX_Size() int

func (*RouteDirective) XXX_Unmarshal 

func (m *RouteDirective) XXX_Unmarshal(b []byte) error

type StringMap 

type StringMap struct {
	// Holds a set of name/value pairs.
	Entries map[int32]int32 `` /* 161-byte string literal not displayed */
}

A map of string to string. The keys and values in this map are dictionary indices (see the Attributes[istio.mixer.v1.CompressedAttributes] message for an explanation)

func (*StringMap) DeepCopy 

func (in *StringMap) DeepCopy() *StringMap

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StringMap. Required by controller-gen.

func (*StringMap) DeepCopyInto 

func (in *StringMap) DeepCopyInto(out *StringMap)

DeepCopyInto supports using StringMap within kubernetes types, where deepcopy-gen is used.

func (*StringMap) Descriptor 

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

func (*StringMap) Marshal 

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

func (*StringMap) MarshalJSON 

func (this *StringMap) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for StringMap

func (*StringMap) MarshalTo 

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

func (*StringMap) MarshalToSizedBuffer 

func (m *StringMap) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringMap) ProtoMessage 

func (*StringMap) ProtoMessage()

func (*StringMap) Reset 

func (m *StringMap) Reset()

func (*StringMap) Size 

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

func (*StringMap) String 

func (this *StringMap) String() string

func (*StringMap) Unmarshal 

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

func (*StringMap) UnmarshalJSON 

func (this *StringMap) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for StringMap

func (*StringMap) XXX_DiscardUnknown 

func (m *StringMap) XXX_DiscardUnknown()

func (*StringMap) XXX_Marshal 

func (m *StringMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringMap) XXX_Merge 

func (m *StringMap) XXX_Merge(src proto.Message)

func (*StringMap) XXX_Size 

func (m *StringMap) XXX_Size() int

func (*StringMap) XXX_Unmarshal 

func (m *StringMap) XXX_Unmarshal(b []byte) error

type UnimplementedMixerServer 

type UnimplementedMixerServer struct {
}

UnimplementedMixerServer can be embedded to have forward compatible implementations.

func (*UnimplementedMixerServer) Check 

func (*UnimplementedMixerServer) Check(ctx context.Context, req *CheckRequest) (*CheckResponse, error)

func (*UnimplementedMixerServer) Report 

func (*UnimplementedMixerServer) Report(ctx context.Context, req *ReportRequest) (*ReportResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
config
client

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.