v1

package
v0.0.0-...-820986f Latest Latest
Warning

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

Go to latest
Published: May 17, 2019 License: Apache-2.0 Imports: 15 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 (
	ErrInvalidLengthMixer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMixer   = fmt.Errorf("proto: integer overflow")
)
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) Descriptor

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

func (*Attributes) Marshal

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

func (*Attributes) MarshalTo

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

func (*Attributes) ProtoMessage

func (*Attributes) ProtoMessage()

func (*Attributes) Reset

func (m *Attributes) Reset()

func (*Attributes) Size

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

func (*Attributes) String

func (this *Attributes) String() string

func (*Attributes) Unmarshal

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

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) 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) MarshalTo

func (m *Attributes_AttributeValue) MarshalTo(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) 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_OneofFuncs

func (*Attributes_AttributeValue) 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.

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) Size

func (*Attributes_AttributeValue_BoolValue) 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) Size

func (*Attributes_AttributeValue_BytesValue) 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) Size

func (*Attributes_AttributeValue_DoubleValue) 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) Size

func (*Attributes_AttributeValue_DurationValue) 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) Size

func (*Attributes_AttributeValue_Int64Value) 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) Size

func (*Attributes_AttributeValue_StringMapValue) 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) Size

func (*Attributes_AttributeValue_StringValue) 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) Size

func (*Attributes_AttributeValue_TimestampValue) 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) Descriptor

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

func (*Attributes_StringMap) Marshal

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

func (*Attributes_StringMap) MarshalTo

func (m *Attributes_StringMap) MarshalTo(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) 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) Descriptor

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

func (*CheckRequest) Marshal

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

func (*CheckRequest) MarshalTo

func (m *CheckRequest) MarshalTo(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) 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) Descriptor

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

func (*CheckRequest_QuotaParams) Marshal

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

func (*CheckRequest_QuotaParams) MarshalTo

func (m *CheckRequest_QuotaParams) MarshalTo(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) 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) Descriptor

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

func (*CheckResponse) Marshal

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

func (*CheckResponse) MarshalTo

func (m *CheckResponse) MarshalTo(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) 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) Descriptor

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

func (*CheckResponse_PreconditionResult) Marshal

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

func (*CheckResponse_PreconditionResult) MarshalTo

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

func (*CheckResponse_PreconditionResult) ProtoMessage

func (*CheckResponse_PreconditionResult) ProtoMessage()

func (*CheckResponse_PreconditionResult) Reset

func (*CheckResponse_PreconditionResult) Size

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

func (*CheckResponse_PreconditionResult) String

func (*CheckResponse_PreconditionResult) Unmarshal

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

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 (*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"`
	// 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) Descriptor

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

func (*CheckResponse_QuotaResult) Marshal

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

func (*CheckResponse_QuotaResult) MarshalTo

func (m *CheckResponse_QuotaResult) MarshalTo(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) 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) Descriptor

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

func (*CompressedAttributes) Marshal

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

func (*CompressedAttributes) MarshalTo

func (m *CompressedAttributes) MarshalTo(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) 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) Descriptor

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

func (*HeaderOperation) Marshal

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

func (*HeaderOperation) MarshalTo

func (m *HeaderOperation) MarshalTo(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) 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.

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) Descriptor

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

func (*ReferencedAttributes) Marshal

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

func (*ReferencedAttributes) MarshalTo

func (m *ReferencedAttributes) MarshalTo(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) 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.
	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) Descriptor

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

func (*ReferencedAttributes_AttributeMatch) Marshal

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

func (*ReferencedAttributes_AttributeMatch) MarshalTo

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

func (*ReferencedAttributes_AttributeMatch) ProtoMessage

func (*ReferencedAttributes_AttributeMatch) ProtoMessage()

func (*ReferencedAttributes_AttributeMatch) Reset

func (*ReferencedAttributes_AttributeMatch) Size

func (*ReferencedAttributes_AttributeMatch) String

func (*ReferencedAttributes_AttributeMatch) Unmarshal

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

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 (*ReferencedAttributes_AttributeMatch) XXX_Size

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

func (ReferencedAttributes_Condition) EnumDescriptor

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

func (ReferencedAttributes_Condition) 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) Descriptor

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

func (*ReportRequest) Marshal

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

func (*ReportRequest) MarshalTo

func (m *ReportRequest) MarshalTo(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) 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 reconstitued 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

type ReportResponse

type ReportResponse struct {
}

Used to carry responses to telemetry reports

func (*ReportResponse) Descriptor

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

func (*ReportResponse) Marshal

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

func (*ReportResponse) MarshalTo

func (m *ReportResponse) MarshalTo(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) 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) Descriptor

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

func (*RouteDirective) Marshal

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

func (*RouteDirective) MarshalTo

func (m *RouteDirective) MarshalTo(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) 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) Descriptor

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

func (*StringMap) Marshal

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

func (*StringMap) MarshalTo

func (m *StringMap) MarshalTo(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) 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

Directories

Path Synopsis
config

Jump to

Keyboard shortcuts

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