v1beta1

package
Version: v0.0.0-...-0dc35ad Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCheck   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthInfo = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInfo   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthInfrastructureBackend = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowInfrastructureBackend   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthQuota = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuota   = 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 (
	ErrInvalidLengthTemplate = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTemplate   = fmt.Errorf("proto: integer overflow")
)
View Source
var E_TemplateName = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.FileOptions)(nil),
	ExtensionType: (*string)(nil),
	Field:         72295888,
	Name:          "istio.mixer.adapter.model.v1beta1.template_name",
	Tag:           "bytes,72295888,opt,name=template_name",
	Filename:      "mixer/adapter/model/v1beta1/extensions.proto",
}
View Source
var E_TemplateVariety = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.FileOptions)(nil),
	ExtensionType: (*TemplateVariety)(nil),
	Field:         72295727,
	Name:          "istio.mixer.adapter.model.v1beta1.template_variety",
	Tag:           "varint,72295727,opt,name=template_variety,enum=istio.mixer.adapter.model.v1beta1.TemplateVariety",
	Filename:      "mixer/adapter/model/v1beta1/extensions.proto",
}
View Source
var TemplateVariety_name = map[int32]string{
	0: "TEMPLATE_VARIETY_CHECK",
	1: "TEMPLATE_VARIETY_REPORT",
	2: "TEMPLATE_VARIETY_QUOTA",
	3: "TEMPLATE_VARIETY_ATTRIBUTE_GENERATOR",
	4: "TEMPLATE_VARIETY_CHECK_WITH_OUTPUT",
}
View Source
var TemplateVariety_value = map[string]int32{
	"TEMPLATE_VARIETY_CHECK":               0,
	"TEMPLATE_VARIETY_REPORT":              1,
	"TEMPLATE_VARIETY_QUOTA":               2,
	"TEMPLATE_VARIETY_ATTRIBUTE_GENERATOR": 3,
	"TEMPLATE_VARIETY_CHECK_WITH_OUTPUT":   4,
}

Functions

func RegisterInfrastructureBackendServer

func RegisterInfrastructureBackendServer(s *grpc.Server, srv InfrastructureBackendServer)

Types

type CheckResult

type CheckResult struct {
	// A status code of OK indicates preconditions were satisfied. Any other code indicates preconditions were not
	// 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"`
}

Expresses the result of a precondition check.

func (*CheckResult) Descriptor

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

func (*CheckResult) Marshal

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

func (*CheckResult) MarshalTo

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

func (*CheckResult) MarshalToSizedBuffer

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

func (*CheckResult) ProtoMessage

func (*CheckResult) ProtoMessage()

func (*CheckResult) Reset

func (m *CheckResult) Reset()

func (*CheckResult) Size

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

func (*CheckResult) String

func (this *CheckResult) String() string

func (*CheckResult) Unmarshal

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

func (*CheckResult) XXX_DiscardUnknown

func (m *CheckResult) XXX_DiscardUnknown()

func (*CheckResult) XXX_Marshal

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

func (*CheckResult) XXX_Merge

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

func (*CheckResult) XXX_Size

func (m *CheckResult) XXX_Size() int

func (*CheckResult) XXX_Unmarshal

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

type CloseSessionRequest

type CloseSessionRequest struct {
	// Id of the session to be closed.
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}

Request message for `CloseSession` method.

func (*CloseSessionRequest) Descriptor

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

func (*CloseSessionRequest) Equal

func (this *CloseSessionRequest) Equal(that interface{}) bool

func (*CloseSessionRequest) GetSessionId

func (m *CloseSessionRequest) GetSessionId() string

func (*CloseSessionRequest) GoString

func (this *CloseSessionRequest) GoString() string

func (*CloseSessionRequest) Marshal

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

func (*CloseSessionRequest) MarshalTo

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

func (*CloseSessionRequest) MarshalToSizedBuffer

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

func (*CloseSessionRequest) ProtoMessage

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size

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

func (*CloseSessionRequest) String

func (this *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal

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

func (*CloseSessionRequest) XXX_DiscardUnknown

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal

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

func (*CloseSessionRequest) XXX_Merge

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

func (*CloseSessionRequest) XXX_Size

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal

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

type CloseSessionResponse

type CloseSessionResponse struct {
	// The success/failure status of close session call.
	Status *rpc.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

Response message for `CloseSession` method.

func (*CloseSessionResponse) Descriptor

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

func (*CloseSessionResponse) Equal

func (this *CloseSessionResponse) Equal(that interface{}) bool

func (*CloseSessionResponse) GetStatus

func (m *CloseSessionResponse) GetStatus() *rpc.Status

func (*CloseSessionResponse) GoString

func (this *CloseSessionResponse) GoString() string

func (*CloseSessionResponse) Marshal

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

func (*CloseSessionResponse) MarshalTo

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

func (*CloseSessionResponse) MarshalToSizedBuffer

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

func (*CloseSessionResponse) ProtoMessage

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size

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

func (*CloseSessionResponse) String

func (this *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal

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

func (*CloseSessionResponse) XXX_DiscardUnknown

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal

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

func (*CloseSessionResponse) XXX_Merge

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

func (*CloseSessionResponse) XXX_Size

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal

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

type CreateSessionRequest

type CreateSessionRequest struct {
	// Adapter specific configuration.
	AdapterConfig *types.Any `protobuf:"bytes,1,opt,name=adapter_config,json=adapterConfig,proto3" json:"adapter_config,omitempty"`
	// Map of instance names to their template-specific inferred type.
	InferredTypes map[string]*types.Any `` /* 188-byte string literal not displayed */
}

Request message for `CreateSession` method.

func (*CreateSessionRequest) Descriptor

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

func (*CreateSessionRequest) Equal

func (this *CreateSessionRequest) Equal(that interface{}) bool

func (*CreateSessionRequest) GetAdapterConfig

func (m *CreateSessionRequest) GetAdapterConfig() *types.Any

func (*CreateSessionRequest) GetInferredTypes

func (m *CreateSessionRequest) GetInferredTypes() map[string]*types.Any

func (*CreateSessionRequest) GoString

func (this *CreateSessionRequest) GoString() string

func (*CreateSessionRequest) Marshal

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

func (*CreateSessionRequest) MarshalTo

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

func (*CreateSessionRequest) MarshalToSizedBuffer

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

func (*CreateSessionRequest) ProtoMessage

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) Reset

func (m *CreateSessionRequest) Reset()

func (*CreateSessionRequest) Size

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

func (*CreateSessionRequest) String

func (this *CreateSessionRequest) String() string

func (*CreateSessionRequest) Unmarshal

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

func (*CreateSessionRequest) XXX_DiscardUnknown

func (m *CreateSessionRequest) XXX_DiscardUnknown()

func (*CreateSessionRequest) XXX_Marshal

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

func (*CreateSessionRequest) XXX_Merge

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

func (*CreateSessionRequest) XXX_Size

func (m *CreateSessionRequest) XXX_Size() int

func (*CreateSessionRequest) XXX_Unmarshal

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

type CreateSessionResponse

type CreateSessionResponse struct {
	// Id of the created session.
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// The success/failure status of create session call.
	Status *rpc.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
}

Response message for `CreateSession` method.

func (*CreateSessionResponse) Descriptor

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

func (*CreateSessionResponse) Equal

func (this *CreateSessionResponse) Equal(that interface{}) bool

func (*CreateSessionResponse) GetSessionId

func (m *CreateSessionResponse) GetSessionId() string

func (*CreateSessionResponse) GetStatus

func (m *CreateSessionResponse) GetStatus() *rpc.Status

func (*CreateSessionResponse) GoString

func (this *CreateSessionResponse) GoString() string

func (*CreateSessionResponse) Marshal

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

func (*CreateSessionResponse) MarshalTo

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

func (*CreateSessionResponse) MarshalToSizedBuffer

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

func (*CreateSessionResponse) ProtoMessage

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) Reset

func (m *CreateSessionResponse) Reset()

func (*CreateSessionResponse) Size

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

func (*CreateSessionResponse) String

func (this *CreateSessionResponse) String() string

func (*CreateSessionResponse) Unmarshal

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

func (*CreateSessionResponse) XXX_DiscardUnknown

func (m *CreateSessionResponse) XXX_DiscardUnknown()

func (*CreateSessionResponse) XXX_Marshal

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

func (*CreateSessionResponse) XXX_Merge

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

func (*CreateSessionResponse) XXX_Size

func (m *CreateSessionResponse) XXX_Size() int

func (*CreateSessionResponse) XXX_Unmarshal

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

type Info

type Info struct {
	// Name of the adapter. It must be an RFC 1035 compatible DNS label
	// matching the `^[a-z]([-a-z0-9]*[a-z0-9])?$` regular expression.
	// Name is used in Istio configuration, therefore it should be descriptive but short.
	// example: denier
	// Vendor adapters should use a vendor prefix.
	// example: mycompany-denier
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// User-friendly description of the adapter.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Names of the templates the adapter supports.
	Templates []string `protobuf:"bytes,3,rep,name=templates,proto3" json:"templates,omitempty"`
	// Base64 encoded proto descriptor of the adapter configuration.
	Config string `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// True if backend has implemented the
	// [InfrastructureBackend](https://github.com/istio/api/blob/release-1.7/mixer/adapter/model/v1beta1/infrastructure_backend.proto)
	// service; false otherwise.
	//
	// If true, during configuration time, Mixer calls the `InfrastructureBackend`' rpcs
	// to validate and pass the handler configuration. And during request-time, Mixer does not pass the handler
	// configuration, and only passes the template-specific Instance payload using the template-specific handle service (Example
	// [HandlerMetricService](https://github.com/istio/istio/blob/release-1.7/mixer/template/metric/template_handler_service.proto),
	// [HandlerListEntryService](https://github.com/istio/istio/blob/release-1.7/mixer/template/logentry/template_handler_service.proto),
	// [HandleQuotaService](https://github.com/istio/istio/blob/release-1.7/mixer/template/quota/template_handler_service.proto) and more).
	// If `session_based` is false, Mixer does not expect backend to implement `InfrastructureBackend` service, and
	// only communicates with the backends during request-time through the template-specific handle service. Without
	// `InfrastructureBackend` service, Mixer passes the handler configuration on each call during request-time.
	SessionBased bool `protobuf:"varint,5,opt,name=session_based,json=sessionBased,proto3" json:"session_based,omitempty"`
}

Info describes an adapter or a backend that wants to provide telemetry and policy functionality to Mixer as an out of process adapter.

func (*Info) Descriptor

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

func (*Info) Equal

func (this *Info) Equal(that interface{}) bool

func (*Info) GetConfig

func (m *Info) GetConfig() string

func (*Info) GetDescription

func (m *Info) GetDescription() string

func (*Info) GetName

func (m *Info) GetName() string

func (*Info) GetSessionBased

func (m *Info) GetSessionBased() bool

func (*Info) GetTemplates

func (m *Info) GetTemplates() []string

func (*Info) GoString

func (this *Info) GoString() string

func (*Info) Marshal

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

func (*Info) MarshalTo

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

func (*Info) MarshalToSizedBuffer

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

func (*Info) ProtoMessage

func (*Info) ProtoMessage()

func (*Info) Reset

func (m *Info) Reset()

func (*Info) Size

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

func (*Info) String

func (this *Info) String() string

func (*Info) Unmarshal

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

func (*Info) XXX_DiscardUnknown

func (m *Info) XXX_DiscardUnknown()

func (*Info) XXX_Marshal

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

func (*Info) XXX_Merge

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

func (*Info) XXX_Size

func (m *Info) XXX_Size() int

func (*Info) XXX_Unmarshal

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

type InfrastructureBackendClient

type InfrastructureBackendClient interface {
	// Validates the handler configuration along with the template-specific instances that would be routed to that
	// handler. The `CreateSession` for a specific handler configuration is invoked only if its associated `Validate`
	// call has returned success.
	Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error)
	// Creates a session for a given handler configuration and the template-specific instances that would be routed to
	// that handler. For every handler configuration, Mixer creates a separate session by invoking `CreateSession`
	// on the backend.
	//
	// `CreateSessionRequest` contains the adapter specific handler configuration and the inferred type information about
	// the instances the handler would receive during request processing.
	//
	// `CreateSession` must return a `session_id` which Mixer uses to invoke template-specific Handle functions during
	// request processing. The `session_id` provides the Handle functions a way to retrieve the necessary configuration
	// associated with the session. Upon Mixer configuration change, Mixer will re-invoke `CreateSession` for all
	// handler configurations whose existing sessions are invalidated or didn't existed.
	//
	// Backend is allowed to return the same session id if given the same configuration block.
	// This would happen when multiple instances of Mixer in a deployment all create sessions with the same configuration.
	// Note that given individual instances of Mixer can call `CloseSession`, reusing `session_id` by the backend
	// assumes that the backend is doing reference counting.
	//
	// If the backend couldn't create a session for a specific handler configuration and
	// returns non S_OK status, Mixer will not make request-time Handle calls associated with that handler configuration.
	CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)
	// Closes the session associated with the `session_id`. Mixer closes a session when its associated handler
	// configuration or the instance configuration changes. Backend is supposed to cleanup all the resources associated
	// with the session_id referenced by CloseSessionRequest.
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

InfrastructureBackendClient is the client API for InfrastructureBackend service.

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

func NewInfrastructureBackendClient

func NewInfrastructureBackendClient(cc *grpc.ClientConn) InfrastructureBackendClient

type InfrastructureBackendServer

type InfrastructureBackendServer interface {
	// Validates the handler configuration along with the template-specific instances that would be routed to that
	// handler. The `CreateSession` for a specific handler configuration is invoked only if its associated `Validate`
	// call has returned success.
	Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
	// Creates a session for a given handler configuration and the template-specific instances that would be routed to
	// that handler. For every handler configuration, Mixer creates a separate session by invoking `CreateSession`
	// on the backend.
	//
	// `CreateSessionRequest` contains the adapter specific handler configuration and the inferred type information about
	// the instances the handler would receive during request processing.
	//
	// `CreateSession` must return a `session_id` which Mixer uses to invoke template-specific Handle functions during
	// request processing. The `session_id` provides the Handle functions a way to retrieve the necessary configuration
	// associated with the session. Upon Mixer configuration change, Mixer will re-invoke `CreateSession` for all
	// handler configurations whose existing sessions are invalidated or didn't existed.
	//
	// Backend is allowed to return the same session id if given the same configuration block.
	// This would happen when multiple instances of Mixer in a deployment all create sessions with the same configuration.
	// Note that given individual instances of Mixer can call `CloseSession`, reusing `session_id` by the backend
	// assumes that the backend is doing reference counting.
	//
	// If the backend couldn't create a session for a specific handler configuration and
	// returns non S_OK status, Mixer will not make request-time Handle calls associated with that handler configuration.
	CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
	// Closes the session associated with the `session_id`. Mixer closes a session when its associated handler
	// configuration or the instance configuration changes. Backend is supposed to cleanup all the resources associated
	// with the session_id referenced by CloseSessionRequest.
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
}

InfrastructureBackendServer is the server API for InfrastructureBackend service.

type QuotaRequest

type QuotaRequest struct {
	// The individual quotas to allocate
	Quotas map[string]QuotaRequest_QuotaParams `` /* 143-byte string literal not displayed */
}

Expresses the quota allocation request.

func (*QuotaRequest) Descriptor

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

func (*QuotaRequest) Marshal

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

func (*QuotaRequest) MarshalTo

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

func (*QuotaRequest) MarshalToSizedBuffer

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

func (*QuotaRequest) ProtoMessage

func (*QuotaRequest) ProtoMessage()

func (*QuotaRequest) Reset

func (m *QuotaRequest) Reset()

func (*QuotaRequest) Size

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

func (*QuotaRequest) String

func (this *QuotaRequest) String() string

func (*QuotaRequest) Unmarshal

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

func (*QuotaRequest) XXX_DiscardUnknown

func (m *QuotaRequest) XXX_DiscardUnknown()

func (*QuotaRequest) XXX_Marshal

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

func (*QuotaRequest) XXX_Merge

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

func (*QuotaRequest) XXX_Size

func (m *QuotaRequest) XXX_Size() int

func (*QuotaRequest) XXX_Unmarshal

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

type QuotaRequest_QuotaParams

type QuotaRequest_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 (*QuotaRequest_QuotaParams) Descriptor

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

func (*QuotaRequest_QuotaParams) Marshal

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

func (*QuotaRequest_QuotaParams) MarshalTo

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

func (*QuotaRequest_QuotaParams) MarshalToSizedBuffer

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

func (*QuotaRequest_QuotaParams) ProtoMessage

func (*QuotaRequest_QuotaParams) ProtoMessage()

func (*QuotaRequest_QuotaParams) Reset

func (m *QuotaRequest_QuotaParams) Reset()

func (*QuotaRequest_QuotaParams) Size

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

func (*QuotaRequest_QuotaParams) String

func (this *QuotaRequest_QuotaParams) String() string

func (*QuotaRequest_QuotaParams) Unmarshal

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

func (*QuotaRequest_QuotaParams) XXX_DiscardUnknown

func (m *QuotaRequest_QuotaParams) XXX_DiscardUnknown()

func (*QuotaRequest_QuotaParams) XXX_Marshal

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

func (*QuotaRequest_QuotaParams) XXX_Merge

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

func (*QuotaRequest_QuotaParams) XXX_Size

func (m *QuotaRequest_QuotaParams) XXX_Size() int

func (*QuotaRequest_QuotaParams) XXX_Unmarshal

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

type QuotaResult

type QuotaResult struct {
	// The resulting quota, one entry per requested quota.
	Quotas map[string]QuotaResult_Result `` /* 143-byte string literal not displayed */
}

Expresses the result of multiple quota allocations.

func (*QuotaResult) Descriptor

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

func (*QuotaResult) Marshal

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

func (*QuotaResult) MarshalTo

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

func (*QuotaResult) MarshalToSizedBuffer

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

func (*QuotaResult) ProtoMessage

func (*QuotaResult) ProtoMessage()

func (*QuotaResult) Reset

func (m *QuotaResult) Reset()

func (*QuotaResult) Size

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

func (*QuotaResult) String

func (this *QuotaResult) String() string

func (*QuotaResult) Unmarshal

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

func (*QuotaResult) XXX_DiscardUnknown

func (m *QuotaResult) XXX_DiscardUnknown()

func (*QuotaResult) XXX_Marshal

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

func (*QuotaResult) XXX_Merge

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

func (*QuotaResult) XXX_Size

func (m *QuotaResult) XXX_Size() int

func (*QuotaResult) XXX_Unmarshal

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

type QuotaResult_Result

type QuotaResult_Result struct {
	// 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 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,3,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,4,opt,name=status,proto3" json:"status"`
}

Expresses the result of a quota allocation.

func (*QuotaResult_Result) Descriptor

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

func (*QuotaResult_Result) Marshal

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

func (*QuotaResult_Result) MarshalTo

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

func (*QuotaResult_Result) MarshalToSizedBuffer

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

func (*QuotaResult_Result) ProtoMessage

func (*QuotaResult_Result) ProtoMessage()

func (*QuotaResult_Result) Reset

func (m *QuotaResult_Result) Reset()

func (*QuotaResult_Result) Size

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

func (*QuotaResult_Result) String

func (this *QuotaResult_Result) String() string

func (*QuotaResult_Result) Unmarshal

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

func (*QuotaResult_Result) XXX_DiscardUnknown

func (m *QuotaResult_Result) XXX_DiscardUnknown()

func (*QuotaResult_Result) XXX_Marshal

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

func (*QuotaResult_Result) XXX_Merge

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

func (*QuotaResult_Result) XXX_Size

func (m *QuotaResult_Result) XXX_Size() int

func (*QuotaResult_Result) XXX_Unmarshal

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

type ReportResult

type ReportResult struct {
}

Expresses the result of a report call.

func (*ReportResult) Descriptor

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

func (*ReportResult) Marshal

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

func (*ReportResult) MarshalTo

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

func (*ReportResult) MarshalToSizedBuffer

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

func (*ReportResult) ProtoMessage

func (*ReportResult) ProtoMessage()

func (*ReportResult) Reset

func (m *ReportResult) Reset()

func (*ReportResult) Size

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

func (*ReportResult) String

func (this *ReportResult) String() string

func (*ReportResult) Unmarshal

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

func (*ReportResult) XXX_DiscardUnknown

func (m *ReportResult) XXX_DiscardUnknown()

func (*ReportResult) XXX_Marshal

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

func (*ReportResult) XXX_Merge

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

func (*ReportResult) XXX_Size

func (m *ReportResult) XXX_Size() int

func (*ReportResult) XXX_Unmarshal

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

type Template

type Template struct {
	// Base64 encoded proto descriptor of the template.
	Descriptor_ string `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
}

Template provides the details of a Mixer template.

func (*Template) Descriptor

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

func (*Template) Equal

func (this *Template) Equal(that interface{}) bool

func (*Template) GetDescriptor_

func (m *Template) GetDescriptor_() string

func (*Template) GoString

func (this *Template) GoString() string

func (*Template) Marshal

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

func (*Template) MarshalTo

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

func (*Template) MarshalToSizedBuffer

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

func (*Template) ProtoMessage

func (*Template) ProtoMessage()

func (*Template) Reset

func (m *Template) Reset()

func (*Template) Size

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

func (*Template) String

func (this *Template) String() string

func (*Template) Unmarshal

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

func (*Template) XXX_DiscardUnknown

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal

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

func (*Template) XXX_Merge

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

func (*Template) XXX_Size

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal

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

type TemplateVariety

type TemplateVariety int32

The available varieties of templates, controlling the semantics of what an adapter does with each instance.

const (
	// Makes the template applicable for Mixer's check calls. Instances of such template are created during
	// check calls in Mixer and passed to the handlers based on the rule configurations.
	TEMPLATE_VARIETY_CHECK TemplateVariety = 0
	// Makes the template applicable for Mixer's report calls. Instances of such template are created during
	// report calls in Mixer and passed to the handlers based on the rule configurations.
	TEMPLATE_VARIETY_REPORT TemplateVariety = 1
	// Makes the template applicable for Mixer's quota calls. Instances of such template are created during
	// quota check calls in Mixer and passed to the handlers based on the rule configurations.
	TEMPLATE_VARIETY_QUOTA TemplateVariety = 2
	// Makes the template applicable for Mixer's attribute generation phase. Instances of such template are created during
	// pre-processing attribute generation phase and passed to the handlers based on the rule configurations.
	TEMPLATE_VARIETY_ATTRIBUTE_GENERATOR TemplateVariety = 3
	// Makes the template applicable for Mixer's check calls. Instances of such template are created during
	// check calls in Mixer and passed to the handlers that produce values.
	TEMPLATE_VARIETY_CHECK_WITH_OUTPUT TemplateVariety = 4
)

func (TemplateVariety) EnumDescriptor

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

func (TemplateVariety) String

func (x TemplateVariety) String() string

type UnimplementedInfrastructureBackendServer

type UnimplementedInfrastructureBackendServer struct {
}

UnimplementedInfrastructureBackendServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfrastructureBackendServer) CloseSession

func (*UnimplementedInfrastructureBackendServer) CreateSession

func (*UnimplementedInfrastructureBackendServer) Validate

type ValidateRequest

type ValidateRequest struct {
	// Adapter specific configuration.
	AdapterConfig *types.Any `protobuf:"bytes,1,opt,name=adapter_config,json=adapterConfig,proto3" json:"adapter_config,omitempty"`
	// Map of instance names to their template-specific inferred type.
	InferredTypes map[string]*types.Any `` /* 188-byte string literal not displayed */
}

Request message for `Validate` method.

func (*ValidateRequest) Descriptor

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

func (*ValidateRequest) Equal

func (this *ValidateRequest) Equal(that interface{}) bool

func (*ValidateRequest) GetAdapterConfig

func (m *ValidateRequest) GetAdapterConfig() *types.Any

func (*ValidateRequest) GetInferredTypes

func (m *ValidateRequest) GetInferredTypes() map[string]*types.Any

func (*ValidateRequest) GoString

func (this *ValidateRequest) GoString() string

func (*ValidateRequest) Marshal

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

func (*ValidateRequest) MarshalTo

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

func (*ValidateRequest) MarshalToSizedBuffer

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

func (*ValidateRequest) ProtoMessage

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) Reset

func (m *ValidateRequest) Reset()

func (*ValidateRequest) Size

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

func (*ValidateRequest) String

func (this *ValidateRequest) String() string

func (*ValidateRequest) Unmarshal

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

func (*ValidateRequest) XXX_DiscardUnknown

func (m *ValidateRequest) XXX_DiscardUnknown()

func (*ValidateRequest) XXX_Marshal

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

func (*ValidateRequest) XXX_Merge

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

func (*ValidateRequest) XXX_Size

func (m *ValidateRequest) XXX_Size() int

func (*ValidateRequest) XXX_Unmarshal

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

type ValidateResponse

type ValidateResponse struct {
	// The success/failure status of validation call.
	Status *rpc.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

Response message for `Validate` method.

func (*ValidateResponse) Descriptor

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

func (*ValidateResponse) Equal

func (this *ValidateResponse) Equal(that interface{}) bool

func (*ValidateResponse) GetStatus

func (m *ValidateResponse) GetStatus() *rpc.Status

func (*ValidateResponse) GoString

func (this *ValidateResponse) GoString() string

func (*ValidateResponse) Marshal

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

func (*ValidateResponse) MarshalTo

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

func (*ValidateResponse) MarshalToSizedBuffer

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

func (*ValidateResponse) ProtoMessage

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) Reset

func (m *ValidateResponse) Reset()

func (*ValidateResponse) Size

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

func (*ValidateResponse) String

func (this *ValidateResponse) String() string

func (*ValidateResponse) Unmarshal

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

func (*ValidateResponse) XXX_DiscardUnknown

func (m *ValidateResponse) XXX_DiscardUnknown()

func (*ValidateResponse) XXX_Marshal

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

func (*ValidateResponse) XXX_Merge

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

func (*ValidateResponse) XXX_Size

func (m *ValidateResponse) XXX_Size() int

func (*ValidateResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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