api: istio.io/api/mixer/adapter/model/v1beta1 Index | Files

package v1beta1

import "istio.io/api/mixer/adapter/model/v1beta1"

Index

Package Files

check.pb.go extensions.pb.go info.pb.go infrastructure_backend.pb.go quota.pb.go report.pb.go template.pb.go

Variables

var (
    ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowCheck   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthInfo = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowInfo   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthInfrastructureBackend = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowInfrastructureBackend   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthQuota = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowQuota   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthReport = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowReport   = fmt.Errorf("proto: integer overflow")
)
var (
    ErrInvalidLengthTemplate = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowTemplate   = fmt.Errorf("proto: integer overflow")
)
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",
}
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",
}
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",
}
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,
}

func RegisterInfrastructureBackendServer Uses

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

type CheckResult Uses

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 Uses

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

func (*CheckResult) Marshal Uses

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

func (*CheckResult) MarshalTo Uses

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

func (*CheckResult) MarshalToSizedBuffer Uses

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

func (*CheckResult) ProtoMessage Uses

func (*CheckResult) ProtoMessage()

func (*CheckResult) Reset Uses

func (m *CheckResult) Reset()

func (*CheckResult) Size Uses

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

func (*CheckResult) String Uses

func (this *CheckResult) String() string

func (*CheckResult) Unmarshal Uses

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

func (*CheckResult) XXX_DiscardUnknown Uses

func (m *CheckResult) XXX_DiscardUnknown()

func (*CheckResult) XXX_Marshal Uses

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

func (*CheckResult) XXX_Merge Uses

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

func (*CheckResult) XXX_Size Uses

func (m *CheckResult) XXX_Size() int

func (*CheckResult) XXX_Unmarshal Uses

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

type CloseSessionRequest Uses

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 Uses

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

func (*CloseSessionRequest) Equal Uses

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

func (*CloseSessionRequest) GetSessionId Uses

func (m *CloseSessionRequest) GetSessionId() string

func (*CloseSessionRequest) GoString Uses

func (this *CloseSessionRequest) GoString() string

func (*CloseSessionRequest) Marshal Uses

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

func (*CloseSessionRequest) MarshalTo Uses

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

func (*CloseSessionRequest) MarshalToSizedBuffer Uses

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

func (*CloseSessionRequest) ProtoMessage Uses

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset Uses

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size Uses

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

func (*CloseSessionRequest) String Uses

func (this *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal Uses

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

func (*CloseSessionRequest) XXX_DiscardUnknown Uses

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal Uses

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

func (*CloseSessionRequest) XXX_Merge Uses

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

func (*CloseSessionRequest) XXX_Size Uses

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal Uses

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

type CloseSessionResponse Uses

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 Uses

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

func (*CloseSessionResponse) Equal Uses

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

func (*CloseSessionResponse) GetStatus Uses

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

func (*CloseSessionResponse) GoString Uses

func (this *CloseSessionResponse) GoString() string

func (*CloseSessionResponse) Marshal Uses

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

func (*CloseSessionResponse) MarshalTo Uses

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

func (*CloseSessionResponse) MarshalToSizedBuffer Uses

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

func (*CloseSessionResponse) ProtoMessage Uses

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset Uses

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size Uses

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

func (*CloseSessionResponse) String Uses

func (this *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal Uses

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

func (*CloseSessionResponse) XXX_DiscardUnknown Uses

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal Uses

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

func (*CloseSessionResponse) XXX_Merge Uses

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

func (*CloseSessionResponse) XXX_Size Uses

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal Uses

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

type CreateSessionRequest Uses

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 `protobuf:"bytes,2,rep,name=inferred_types,json=inferredTypes,proto3" json:"inferred_types,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

Request message for `CreateSession` method.

func (*CreateSessionRequest) Descriptor Uses

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

func (*CreateSessionRequest) Equal Uses

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

func (*CreateSessionRequest) GetAdapterConfig Uses

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

func (*CreateSessionRequest) GetInferredTypes Uses

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

func (*CreateSessionRequest) GoString Uses

func (this *CreateSessionRequest) GoString() string

func (*CreateSessionRequest) Marshal Uses

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

func (*CreateSessionRequest) MarshalTo Uses

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

func (*CreateSessionRequest) MarshalToSizedBuffer Uses

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

func (*CreateSessionRequest) ProtoMessage Uses

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) Reset Uses

func (m *CreateSessionRequest) Reset()

func (*CreateSessionRequest) Size Uses

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

func (*CreateSessionRequest) String Uses

func (this *CreateSessionRequest) String() string

func (*CreateSessionRequest) Unmarshal Uses

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

func (*CreateSessionRequest) XXX_DiscardUnknown Uses

func (m *CreateSessionRequest) XXX_DiscardUnknown()

func (*CreateSessionRequest) XXX_Marshal Uses

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

func (*CreateSessionRequest) XXX_Merge Uses

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

func (*CreateSessionRequest) XXX_Size Uses

func (m *CreateSessionRequest) XXX_Size() int

func (*CreateSessionRequest) XXX_Unmarshal Uses

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

type CreateSessionResponse Uses

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 Uses

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

func (*CreateSessionResponse) Equal Uses

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

func (*CreateSessionResponse) GetSessionId Uses

func (m *CreateSessionResponse) GetSessionId() string

func (*CreateSessionResponse) GetStatus Uses

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

func (*CreateSessionResponse) GoString Uses

func (this *CreateSessionResponse) GoString() string

func (*CreateSessionResponse) Marshal Uses

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

func (*CreateSessionResponse) MarshalTo Uses

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

func (*CreateSessionResponse) MarshalToSizedBuffer Uses

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

func (*CreateSessionResponse) ProtoMessage Uses

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) Reset Uses

func (m *CreateSessionResponse) Reset()

func (*CreateSessionResponse) Size Uses

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

func (*CreateSessionResponse) String Uses

func (this *CreateSessionResponse) String() string

func (*CreateSessionResponse) Unmarshal Uses

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

func (*CreateSessionResponse) XXX_DiscardUnknown Uses

func (m *CreateSessionResponse) XXX_DiscardUnknown()

func (*CreateSessionResponse) XXX_Marshal Uses

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

func (*CreateSessionResponse) XXX_Merge Uses

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

func (*CreateSessionResponse) XXX_Size Uses

func (m *CreateSessionResponse) XXX_Size() int

func (*CreateSessionResponse) XXX_Unmarshal Uses

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

type Info Uses

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/master/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/master/mixer/template/metric/template_handler_service.proto),
    // [HandlerListEntryService](https://github.com/istio/istio/blob/master/mixer/template/logentry/template_handler_service.proto),
    // [HandleQuotaService](https://github.com/istio/istio/blob/master/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 Uses

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

func (*Info) Equal Uses

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

func (*Info) GetConfig Uses

func (m *Info) GetConfig() string

func (*Info) GetDescription Uses

func (m *Info) GetDescription() string

func (*Info) GetName Uses

func (m *Info) GetName() string

func (*Info) GetSessionBased Uses

func (m *Info) GetSessionBased() bool

func (*Info) GetTemplates Uses

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

func (*Info) GoString Uses

func (this *Info) GoString() string

func (*Info) Marshal Uses

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

func (*Info) MarshalTo Uses

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

func (*Info) MarshalToSizedBuffer Uses

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

func (*Info) ProtoMessage Uses

func (*Info) ProtoMessage()

func (*Info) Reset Uses

func (m *Info) Reset()

func (*Info) Size Uses

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

func (*Info) String Uses

func (this *Info) String() string

func (*Info) Unmarshal Uses

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

func (*Info) XXX_DiscardUnknown Uses

func (m *Info) XXX_DiscardUnknown()

func (*Info) XXX_Marshal Uses

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

func (*Info) XXX_Merge Uses

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

func (*Info) XXX_Size Uses

func (m *Info) XXX_Size() int

func (*Info) XXX_Unmarshal Uses

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

type InfrastructureBackendClient Uses

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 Uses

func NewInfrastructureBackendClient(cc *grpc.ClientConn) InfrastructureBackendClient

type InfrastructureBackendServer Uses

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 Uses

type QuotaRequest struct {
    // The individual quotas to allocate
    Quotas map[string]QuotaRequest_QuotaParams `protobuf:"bytes,1,rep,name=quotas,proto3" json:"quotas" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

Expresses the quota allocation request.

func (*QuotaRequest) Descriptor Uses

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

func (*QuotaRequest) Marshal Uses

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

func (*QuotaRequest) MarshalTo Uses

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

func (*QuotaRequest) MarshalToSizedBuffer Uses

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

func (*QuotaRequest) ProtoMessage Uses

func (*QuotaRequest) ProtoMessage()

func (*QuotaRequest) Reset Uses

func (m *QuotaRequest) Reset()

func (*QuotaRequest) Size Uses

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

func (*QuotaRequest) String Uses

func (this *QuotaRequest) String() string

func (*QuotaRequest) Unmarshal Uses

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

func (*QuotaRequest) XXX_DiscardUnknown Uses

func (m *QuotaRequest) XXX_DiscardUnknown()

func (*QuotaRequest) XXX_Marshal Uses

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

func (*QuotaRequest) XXX_Merge Uses

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

func (*QuotaRequest) XXX_Size Uses

func (m *QuotaRequest) XXX_Size() int

func (*QuotaRequest) XXX_Unmarshal Uses

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

type QuotaRequest_QuotaParams Uses

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 Uses

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

func (*QuotaRequest_QuotaParams) Marshal Uses

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

func (*QuotaRequest_QuotaParams) MarshalTo Uses

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

func (*QuotaRequest_QuotaParams) MarshalToSizedBuffer Uses

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

func (*QuotaRequest_QuotaParams) ProtoMessage Uses

func (*QuotaRequest_QuotaParams) ProtoMessage()

func (*QuotaRequest_QuotaParams) Reset Uses

func (m *QuotaRequest_QuotaParams) Reset()

func (*QuotaRequest_QuotaParams) Size Uses

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

func (*QuotaRequest_QuotaParams) String Uses

func (this *QuotaRequest_QuotaParams) String() string

func (*QuotaRequest_QuotaParams) Unmarshal Uses

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

func (*QuotaRequest_QuotaParams) XXX_DiscardUnknown Uses

func (m *QuotaRequest_QuotaParams) XXX_DiscardUnknown()

func (*QuotaRequest_QuotaParams) XXX_Marshal Uses

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

func (*QuotaRequest_QuotaParams) XXX_Merge Uses

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

func (*QuotaRequest_QuotaParams) XXX_Size Uses

func (m *QuotaRequest_QuotaParams) XXX_Size() int

func (*QuotaRequest_QuotaParams) XXX_Unmarshal Uses

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

type QuotaResult Uses

type QuotaResult struct {
    // The resulting quota, one entry per requested quota.
    Quotas map[string]QuotaResult_Result `protobuf:"bytes,1,rep,name=quotas,proto3" json:"quotas" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

Expresses the result of multiple quota allocations.

func (*QuotaResult) Descriptor Uses

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

func (*QuotaResult) Marshal Uses

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

func (*QuotaResult) MarshalTo Uses

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

func (*QuotaResult) MarshalToSizedBuffer Uses

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

func (*QuotaResult) ProtoMessage Uses

func (*QuotaResult) ProtoMessage()

func (*QuotaResult) Reset Uses

func (m *QuotaResult) Reset()

func (*QuotaResult) Size Uses

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

func (*QuotaResult) String Uses

func (this *QuotaResult) String() string

func (*QuotaResult) Unmarshal Uses

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

func (*QuotaResult) XXX_DiscardUnknown Uses

func (m *QuotaResult) XXX_DiscardUnknown()

func (*QuotaResult) XXX_Marshal Uses

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

func (*QuotaResult) XXX_Merge Uses

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

func (*QuotaResult) XXX_Size Uses

func (m *QuotaResult) XXX_Size() int

func (*QuotaResult) XXX_Unmarshal Uses

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

type QuotaResult_Result Uses

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 Uses

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

func (*QuotaResult_Result) Marshal Uses

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

func (*QuotaResult_Result) MarshalTo Uses

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

func (*QuotaResult_Result) MarshalToSizedBuffer Uses

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

func (*QuotaResult_Result) ProtoMessage Uses

func (*QuotaResult_Result) ProtoMessage()

func (*QuotaResult_Result) Reset Uses

func (m *QuotaResult_Result) Reset()

func (*QuotaResult_Result) Size Uses

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

func (*QuotaResult_Result) String Uses

func (this *QuotaResult_Result) String() string

func (*QuotaResult_Result) Unmarshal Uses

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

func (*QuotaResult_Result) XXX_DiscardUnknown Uses

func (m *QuotaResult_Result) XXX_DiscardUnknown()

func (*QuotaResult_Result) XXX_Marshal Uses

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

func (*QuotaResult_Result) XXX_Merge Uses

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

func (*QuotaResult_Result) XXX_Size Uses

func (m *QuotaResult_Result) XXX_Size() int

func (*QuotaResult_Result) XXX_Unmarshal Uses

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

type ReportResult Uses

type ReportResult struct {
}

Expresses the result of a report call.

func (*ReportResult) Descriptor Uses

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

func (*ReportResult) Marshal Uses

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

func (*ReportResult) MarshalTo Uses

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

func (*ReportResult) MarshalToSizedBuffer Uses

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

func (*ReportResult) ProtoMessage Uses

func (*ReportResult) ProtoMessage()

func (*ReportResult) Reset Uses

func (m *ReportResult) Reset()

func (*ReportResult) Size Uses

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

func (*ReportResult) String Uses

func (this *ReportResult) String() string

func (*ReportResult) Unmarshal Uses

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

func (*ReportResult) XXX_DiscardUnknown Uses

func (m *ReportResult) XXX_DiscardUnknown()

func (*ReportResult) XXX_Marshal Uses

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

func (*ReportResult) XXX_Merge Uses

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

func (*ReportResult) XXX_Size Uses

func (m *ReportResult) XXX_Size() int

func (*ReportResult) XXX_Unmarshal Uses

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

type Template Uses

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 Uses

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

func (*Template) Equal Uses

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

func (*Template) GetDescriptor_ Uses

func (m *Template) GetDescriptor_() string

func (*Template) GoString Uses

func (this *Template) GoString() string

func (*Template) Marshal Uses

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

func (*Template) MarshalTo Uses

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

func (*Template) MarshalToSizedBuffer Uses

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

func (*Template) ProtoMessage Uses

func (*Template) ProtoMessage()

func (*Template) Reset Uses

func (m *Template) Reset()

func (*Template) Size Uses

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

func (*Template) String Uses

func (this *Template) String() string

func (*Template) Unmarshal Uses

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

func (*Template) XXX_DiscardUnknown Uses

func (m *Template) XXX_DiscardUnknown()

func (*Template) XXX_Marshal Uses

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

func (*Template) XXX_Merge Uses

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

func (*Template) XXX_Size Uses

func (m *Template) XXX_Size() int

func (*Template) XXX_Unmarshal Uses

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

type TemplateVariety Uses

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 Uses

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

func (TemplateVariety) String Uses

func (x TemplateVariety) String() string

type UnimplementedInfrastructureBackendServer Uses

type UnimplementedInfrastructureBackendServer struct {
}

UnimplementedInfrastructureBackendServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfrastructureBackendServer) CloseSession Uses

func (*UnimplementedInfrastructureBackendServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedInfrastructureBackendServer) CreateSession Uses

func (*UnimplementedInfrastructureBackendServer) CreateSession(ctx context.Context, req *CreateSessionRequest) (*CreateSessionResponse, error)

func (*UnimplementedInfrastructureBackendServer) Validate Uses

func (*UnimplementedInfrastructureBackendServer) Validate(ctx context.Context, req *ValidateRequest) (*ValidateResponse, error)

type ValidateRequest Uses

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 `protobuf:"bytes,2,rep,name=inferred_types,json=inferredTypes,proto3" json:"inferred_types,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

Request message for `Validate` method.

func (*ValidateRequest) Descriptor Uses

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

func (*ValidateRequest) Equal Uses

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

func (*ValidateRequest) GetAdapterConfig Uses

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

func (*ValidateRequest) GetInferredTypes Uses

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

func (*ValidateRequest) GoString Uses

func (this *ValidateRequest) GoString() string

func (*ValidateRequest) Marshal Uses

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

func (*ValidateRequest) MarshalTo Uses

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

func (*ValidateRequest) MarshalToSizedBuffer Uses

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

func (*ValidateRequest) ProtoMessage Uses

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) Reset Uses

func (m *ValidateRequest) Reset()

func (*ValidateRequest) Size Uses

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

func (*ValidateRequest) String Uses

func (this *ValidateRequest) String() string

func (*ValidateRequest) Unmarshal Uses

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

func (*ValidateRequest) XXX_DiscardUnknown Uses

func (m *ValidateRequest) XXX_DiscardUnknown()

func (*ValidateRequest) XXX_Marshal Uses

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

func (*ValidateRequest) XXX_Merge Uses

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

func (*ValidateRequest) XXX_Size Uses

func (m *ValidateRequest) XXX_Size() int

func (*ValidateRequest) XXX_Unmarshal Uses

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

type ValidateResponse Uses

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 Uses

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

func (*ValidateResponse) Equal Uses

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

func (*ValidateResponse) GetStatus Uses

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

func (*ValidateResponse) GoString Uses

func (this *ValidateResponse) GoString() string

func (*ValidateResponse) Marshal Uses

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

func (*ValidateResponse) MarshalTo Uses

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

func (*ValidateResponse) MarshalToSizedBuffer Uses

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

func (*ValidateResponse) ProtoMessage Uses

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) Reset Uses

func (m *ValidateResponse) Reset()

func (*ValidateResponse) Size Uses

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

func (*ValidateResponse) String Uses

func (this *ValidateResponse) String() string

func (*ValidateResponse) Unmarshal Uses

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

func (*ValidateResponse) XXX_DiscardUnknown Uses

func (m *ValidateResponse) XXX_DiscardUnknown()

func (*ValidateResponse) XXX_Marshal Uses

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

func (*ValidateResponse) XXX_Merge Uses

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

func (*ValidateResponse) XXX_Size Uses

func (m *ValidateResponse) XXX_Size() int

func (*ValidateResponse) XXX_Unmarshal Uses

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

Package v1beta1 imports 18 packages (graph) and is imported by 60 packages. Updated 2019-11-02. Refresh now. Tools for package owners.