v1

package
v0.0.0-...-2d182f5 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package v1 is a generated protocol buffer package.

It is generated from these files: 

mixer/v1/attributes.proto
mixer/v1/check.proto
mixer/v1/report.proto
mixer/v1/service.proto

It has these top-level messages: 

Attributes
CompressedAttributes
StringMap
CheckRequest
CheckResponse
ReferencedAttributes
HeaderOperation
RouteDirective
ReportRequest
ReportResponse

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 (
	ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCheck   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthReport = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReport   = 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,
}

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 `` /* 147-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:

``` 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/mixer/attribute-vocabulary.html).

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

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() *google_protobuf1.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() *google_protobuf2.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_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.

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 (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) 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) 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 *google_protobuf1.Duration `protobuf:"bytes,8,opt,name=duration_value,json=durationValue,oneof"`
}

func (*Attributes_AttributeValue_DurationValue) MarshalTo 

func (m *Attributes_AttributeValue_DurationValue) MarshalTo(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) 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,oneof"`
}

func (*Attributes_AttributeValue_StringMapValue) MarshalTo 

func (m *Attributes_AttributeValue_StringMapValue) MarshalTo(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) 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 *google_protobuf2.Timestamp `protobuf:"bytes,7,opt,name=timestamp_value,json=timestampValue,oneof"`
}

func (*Attributes_AttributeValue_TimestampValue) MarshalTo 

func (m *Attributes_AttributeValue_TimestampValue) MarshalTo(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 `` /* 148-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

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" 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 `` /* 129-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

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

type CheckResponse 

type CheckResponse struct {
	// The precondition check results.
	Precondition CheckResponse_PreconditionResult `protobuf:"bytes,2,opt,name=precondition" json:"precondition"`
	// The resulting quota, one entry per requested quota.
	Quotas map[string]CheckResponse_QuotaResult `` /* 129-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

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 google_rpc.Status `protobuf:"bytes,1,opt,name=status" 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,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" 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" 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 (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

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,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" 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

type CompressedAttributes 

type CompressedAttributes struct {
	// The message-level dictionary.
	Words []string `protobuf:"bytes,1,rep,name=words" json:"words,omitempty"`
	// Holds attributes of type STRING, DNS_NAME, EMAIL_ADDRESS, URI
	Strings map[int32]int32 `` /* 154-byte string literal not displayed */
	// Holds attributes of type INT64
	Int64S map[int32]int64 `` /* 150-byte string literal not displayed */
	// Holds attributes of type DOUBLE
	Doubles map[int32]float64 `` /* 153-byte string literal not displayed */
	// Holds attributes of type BOOL
	Bools map[int32]bool `` /* 148-byte string literal not displayed */
	// Holds attributes of type TIMESTAMP
	Timestamps map[int32]time.Time `` /* 148-byte string literal not displayed */
	// Holds attributes of type DURATION
	Durations map[int32]time.Duration `` /* 150-byte string literal not displayed */
	// Holds attributes of type BYTES
	Bytes map[int32][]byte `` /* 147-byte string literal not displayed */
	// Holds attributes of type STRING_MAP
	StringMaps map[int32]StringMap `` /* 158-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

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

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

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

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" json:"words,omitempty"`
	// Describes a set of attributes.
	AttributeMatches []ReferencedAttributes_AttributeMatch `protobuf:"bytes,2,rep,name=attribute_matches,json=attributeMatches" 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

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

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.
	//
	// Although each `Attributes` message is semantically treated as an independent
	// stand-alone entity unrelated to the other attributes within the message, this
	// message format leverages delta-encoding between attribute messages in order to
	// substantially reduce the request size and improve end-to-end efficiency. Each
	// individual set of attributes is used to modify the previous set. This eliminates
	// the need to redundantly send the same attributes multiple times over within
	// a single request.
	//
	// If a client is not sophisticated and doesn't want to use delta-encoding,
	// a degenerate case is to include all attributes in every individual message.
	Attributes []CompressedAttributes `protobuf:"bytes,1,rep,name=attributes" json:"attributes"`
	// 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" 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

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

type RouteDirective 

type RouteDirective struct {
	// Operations on the request headers.
	RequestHeaderOperations []HeaderOperation `protobuf:"bytes,1,rep,name=request_header_operations,json=requestHeaderOperations" json:"request_header_operations"`
	// Operations on the response headers.
	ResponseHeaderOperations []HeaderOperation `protobuf:"bytes,2,rep,name=response_header_operations,json=responseHeaderOperations" 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 successful 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

type StringMap 

type StringMap struct {
	// Holds a set of name/value pairs.
	Entries map[int32]int32 `` /* 154-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

Source Files

View all Source files

Directories

Path Synopsis
config
client
Package client is a generated protocol buffer package.
 Package client is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.