federation

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2024 License: MIT Imports: 35 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	PrivatePackageName          = "grpc.federation.private"
	MessageArgumentVariableName = "__ARG__"
)

Variables

View Source 
var (
	Getenv                = os.Getenv
	GRPCError             = status.Errorf
	NewGRPCStatus         = status.New
	ErrorGroupWithContext = errgroup.WithContext
	NewCELEnv             = cel.NewCustomEnv
	CELLib                = cel.Lib
	CELDoubleType         = types.DoubleType
	CELIntType            = types.IntType
	CELUintType           = types.UintType
	CELBoolType           = types.BoolType
	CELStringType         = types.StringType
	CELBytesType          = types.BytesType
	CELObjectType         = cel.ObjectType
	CELListType           = cel.ListType
	NewCELListType        = types.NewListType
	NewCELObjectType      = types.NewObjectType
)
View Source 
var (
	ErrClientConfig    = errors.New("grpc-federation: Client field is not set. this field must be set")
	ErrResolverConfig  = errors.New("grpc-federation: Resolver field is not set. this field must be set")
	ErrCELPluginConfig = errors.New("grpc-federation: CELPlugin field is not set. this field must be set")
)
View Source 
var (
	// optional grpc.federation.EnumRule enum = 1187;
	E_Enum = &file_grpc_federation_federation_proto_extTypes[4]
)

Extension fields to descriptorpb.EnumOptions.

View Source 
var (
	// optional grpc.federation.EnumValueRule enum_value = 1187;
	E_EnumValue = &file_grpc_federation_federation_proto_extTypes[5]
)

Extension fields to descriptorpb.EnumValueOptions.

View Source 
var (
	// optional grpc.federation.FieldRule field = 1187;
	E_Field = &file_grpc_federation_federation_proto_extTypes[3]
)

Extension fields to descriptorpb.FieldOptions.

View Source 
var (
	// optional grpc.federation.MessageRule message = 1187;
	E_Message = &file_grpc_federation_federation_proto_extTypes[2]
)

Extension fields to descriptorpb.MessageOptions.

View Source 
var (
	// optional grpc.federation.MethodRule method = 1187;
	E_Method = &file_grpc_federation_federation_proto_extTypes[1]
)

Extension fields to descriptorpb.MethodOptions.

View Source 
var (
	// optional grpc.federation.OneofRule oneof = 1187;
	E_Oneof = &file_grpc_federation_federation_proto_extTypes[6]
)

Extension fields to descriptorpb.OneofOptions.

View Source 
var (
	// optional grpc.federation.PluginRule plugin = 1187;
	E_Plugin = &file_grpc_federation_plugin_proto_extTypes[0]
)

Extension fields to descriptorpb.FileOptions.

View Source 
var (
	// optional grpc.federation.ServiceRule service = 1187;
	E_Service = &file_grpc_federation_federation_proto_extTypes[0]
)

Extension fields to descriptorpb.ServiceOptions.

View Source 
var File_grpc_federation_federation_proto protoreflect.FileDescriptor
View Source 
var File_grpc_federation_plugin_proto protoreflect.FileDescriptor

Functions

func BadRequest added in v0.10.0 

func BadRequest(ctx context.Context, value localValue, violations []*BadRequestFieldViolation) *errdetails.BadRequest

func BytesToPtr added in v0.10.0 

func BytesToPtr(b []byte) (uint32, uint32)

func BytesToPtrWithAllocation added in v0.10.0 

func BytesToPtrWithAllocation(b []byte) (uint32, uint32)

func CELPlugins added in v0.11.0 

func CELPlugins(ctx context.Context) []*cel.CELPlugin

func CustomMessage added in v0.10.0 

func CustomMessage(ctx context.Context, value localValue, expr string, idx int) protoadapt.MessageV1

func DebugLog added in v0.10.0 

func DebugLog(msg string)

func EvalCEL added in v0.4.0 

func EvalCEL(ctx context.Context, value localValue, expr string, outType reflect.Type) (any, error)

func EvalDef added in v0.10.0 

func EvalDef[T any, U localValue](ctx context.Context, value U, def Def[T, U]) error

func EvalDefMap added in v0.10.0 

func EvalDefMap[T any, U any, V localValue](ctx context.Context, value V, def DefMap[T, U, V]) error

func FreePtr added in v0.10.0 

func FreePtr(ptr uint32)

func GoWithRecover added in v0.4.0 

func GoWithRecover(eg *errgroup.Group, fn func() (any, error))

func If added in v0.10.0 

func If[T localValue](ctx context.Context, value T, expr string, cb func(T) error) error

func LocalizedMessage added in v0.10.0 

func LocalizedMessage(ctx context.Context, value localValue, locale, msg string) *errdetails.LocalizedMessage

func Logger added in v0.4.0 

func Logger(ctx context.Context) *slog.Logger

func NewCELFieldType added in v0.4.0 

func NewCELFieldType(typ *celtypes.Type, fieldName string) *celtypes.FieldType

func NewDefaultEnvOptions added in v0.10.0 

func NewDefaultEnvOptions(celHelper *CELTypeHelper) []cel.EnvOption

func NewOneofSelectorFieldType added in v0.4.0 

func NewOneofSelectorFieldType(typ *celtypes.Type, fieldName string, oneofTypes []reflect.Type, getterNames []string, zeroValue reflect.Value) *celtypes.FieldType

func OutputErrorLog added in v0.4.0 

func OutputErrorLog(ctx context.Context, logger *slog.Logger, err error)

func PreconditionFailure added in v0.10.0 

func PreconditionFailure(ctx context.Context, value localValue, violations []*PreconditionFailureViolation) *errdetails.PreconditionFailure

func RecordErrorToSpan added in v0.5.0 

func RecordErrorToSpan(ctx context.Context, err error)

func SetCELValue added in v0.10.0 

func SetCELValue[T any](ctx context.Context, value localValue, expr string, setter func(T)) error

func StringToPtr added in v0.10.0 

func StringToPtr(s string) (uint32, uint32)

func StringToPtrWithAllocation added in v0.10.0 

func StringToPtrWithAllocation(s string) (uint32, uint32)

func ToBytes added in v0.10.0 

func ToBytes(ptr, size uint32) []byte

func ToFloat32 added in v0.10.0 

func ToFloat32(v uint32) float32

func ToFloat64 added in v0.10.0 

func ToFloat64(v uint64) float64

func ToLogAttrKey added in v0.10.0 

func ToLogAttrKey(v any) string

func ToMessage added in v0.10.0 

func ToMessage[T any](ptr uint32) *T

func ToString added in v0.10.0 

func ToString(ptr, size uint32) string

func WithCELPlugins added in v0.11.0 

func WithCELPlugins(ctx context.Context, plugins []*cel.CELPlugin) context.Context

func WithLogger added in v0.4.0 

func WithLogger(ctx context.Context, logger *slog.Logger) context.Context

func WithRetry added in v0.4.0 

func WithRetry[T any](b *BackOff, fn func() (*T, error)) (*T, error)

func WithTimeout added in v0.4.0 

func WithTimeout[T any](ctx context.Context, method string, timeout time.Duration, fn func(context.Context) (*T, error)) (*T, error)

Types

type Argument 

type Argument struct {

	// name of the message argument.
	// Use this name to refer to the message argument.
	// For example, if `foo` is specified as the name, it is referenced by `$.foo`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// by used to refer to a name or message argument defined in a MessageRule, use `$.` to refer to the message argument.
	// Use CEL (https://github.com/google/cel-spec) to evaluate the expression.
	// Variables are already defined in MessageRule can be used.
	By *string `protobuf:"bytes,2,opt,name=by,proto3,oneof" json:"by,omitempty"`
	// inline like by, it refers to the specified value and expands all fields beyond it.
	// For this reason, the referenced value must always be of message type.
	Inline *string `protobuf:"bytes,3,opt,name=inline,proto3,oneof" json:"inline,omitempty"`
	// double literal value.
	Double *float64 `protobuf:"fixed64,4,opt,name=double,proto3,oneof" json:"double,omitempty"`
	// repeated double literal values.
	Doubles []float64 `protobuf:"fixed64,5,rep,packed,name=doubles,proto3" json:"doubles,omitempty"`
	// float literal value.
	Float *float32 `protobuf:"fixed32,6,opt,name=float,proto3,oneof" json:"float,omitempty"`
	// repeated float literal values.
	Floats []float32 `protobuf:"fixed32,7,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	// int32 literal value.
	Int32 *int32 `protobuf:"varint,8,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
	// repeated int32 literal values.
	Int32S []int32 `protobuf:"varint,9,rep,packed,name=int32s,proto3" json:"int32s,omitempty"`
	// int64 literal value.
	Int64 *int64 `protobuf:"varint,10,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
	// repeated int64 literal values.
	Int64S []int64 `protobuf:"varint,11,rep,packed,name=int64s,proto3" json:"int64s,omitempty"`
	// uint32 literal value.
	Uint32 *uint32 `protobuf:"varint,12,opt,name=uint32,proto3,oneof" json:"uint32,omitempty"`
	// repeated uint32 literal values.
	Uint32S []uint32 `protobuf:"varint,13,rep,packed,name=uint32s,proto3" json:"uint32s,omitempty"`
	// uint64 literal value.
	Uint64 *uint64 `protobuf:"varint,14,opt,name=uint64,proto3,oneof" json:"uint64,omitempty"`
	// repeated uint64 literal values.
	Uint64S []uint64 `protobuf:"varint,15,rep,packed,name=uint64s,proto3" json:"uint64s,omitempty"`
	// sint32 literal value.
	Sint32 *int32 `protobuf:"zigzag32,16,opt,name=sint32,proto3,oneof" json:"sint32,omitempty"`
	// repeated sint32 literal values.
	Sint32S []int32 `protobuf:"zigzag32,17,rep,packed,name=sint32s,proto3" json:"sint32s,omitempty"`
	// sint64 literal value.
	Sint64 *int64 `protobuf:"zigzag64,18,opt,name=sint64,proto3,oneof" json:"sint64,omitempty"`
	// repeated sint64 literal values.
	Sint64S []int64 `protobuf:"zigzag64,19,rep,packed,name=sint64s,proto3" json:"sint64s,omitempty"`
	// fixed32 literal value.
	Fixed32 *uint32 `protobuf:"fixed32,20,opt,name=fixed32,proto3,oneof" json:"fixed32,omitempty"`
	// repeated fixed32 literal values.
	Fixed32S []uint32 `protobuf:"fixed32,21,rep,packed,name=fixed32s,proto3" json:"fixed32s,omitempty"`
	// fixed64 literal value.
	Fixed64 *uint64 `protobuf:"fixed64,22,opt,name=fixed64,proto3,oneof" json:"fixed64,omitempty"`
	// repeated fixed64 literal values.
	Fixed64S []uint64 `protobuf:"fixed64,23,rep,packed,name=fixed64s,proto3" json:"fixed64s,omitempty"`
	// sfixed32 literal value.
	Sfixed32 *int32 `protobuf:"fixed32,24,opt,name=sfixed32,proto3,oneof" json:"sfixed32,omitempty"`
	// repeated sfixed32 literal values.
	Sfixed32S []int32 `protobuf:"fixed32,25,rep,packed,name=sfixed32s,proto3" json:"sfixed32s,omitempty"`
	// sfixed64 literal value.
	Sfixed64 *int64 `protobuf:"fixed64,26,opt,name=sfixed64,proto3,oneof" json:"sfixed64,omitempty"`
	// repeated sfixed64 literal values.
	Sfixed64S []int64 `protobuf:"fixed64,27,rep,packed,name=sfixed64s,proto3" json:"sfixed64s,omitempty"`
	// bool literal value.
	Bool *bool `protobuf:"varint,28,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
	// repeated bool literal values.
	Bools []bool `protobuf:"varint,29,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	// string literal value.
	String_ *string `protobuf:"bytes,30,opt,name=string,proto3,oneof" json:"string,omitempty"`
	// repeated string literal values.
	Strings []string `protobuf:"bytes,31,rep,name=strings,proto3" json:"strings,omitempty"`
	// bytes literal value.
	ByteString []byte `protobuf:"bytes,32,opt,name=byte_string,json=byteString,proto3,oneof" json:"byte_string,omitempty"`
	// repeated bytes literal values.
	ByteStrings [][]byte `protobuf:"bytes,33,rep,name=byte_strings,json=byteStrings,proto3" json:"byte_strings,omitempty"`
	// message literal value.
	Message *MessageValue `protobuf:"bytes,34,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// repeated message literal values.
	Messages []*MessageValue `protobuf:"bytes,35,rep,name=messages,proto3" json:"messages,omitempty"`
	// enum literal value.
	Enum *string `protobuf:"bytes,36,opt,name=enum,proto3,oneof" json:"enum,omitempty"`
	// repeated enum literal values.
	Enums []string `protobuf:"bytes,37,rep,name=enums,proto3" json:"enums,omitempty"`
	// env literal value.
	Env *string `protobuf:"bytes,38,opt,name=env,proto3,oneof" json:"env,omitempty"`
	// repeated env literal values.
	Envs []string `protobuf:"bytes,39,rep,name=envs,proto3" json:"envs,omitempty"`
	// contains filtered or unexported fields
}

Argument define message argument.

func (*Argument) CloneMessageVT added in v0.12.0 

func (m *Argument) CloneMessageVT() proto.Message

func (*Argument) CloneVT added in v0.12.0 

func (m *Argument) CloneVT() *Argument

func (*Argument) Descriptor deprecated 

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

Deprecated: Use Argument.ProtoReflect.Descriptor instead.

func (*Argument) EqualMessageVT added in v0.12.0 

func (this *Argument) EqualMessageVT(thatMsg proto.Message) bool

func (*Argument) EqualVT added in v0.12.0 

func (this *Argument) EqualVT(that *Argument) bool

func (*Argument) GetBool 

func (x *Argument) GetBool() bool

func (*Argument) GetBools 

func (x *Argument) GetBools() []bool

func (*Argument) GetBy 

func (x *Argument) GetBy() string

func (*Argument) GetByteString 

func (x *Argument) GetByteString() []byte

func (*Argument) GetByteStrings 

func (x *Argument) GetByteStrings() [][]byte

func (*Argument) GetDouble 

func (x *Argument) GetDouble() float64

func (*Argument) GetDoubles 

func (x *Argument) GetDoubles() []float64

func (*Argument) GetEnum 

func (x *Argument) GetEnum() string

func (*Argument) GetEnums 

func (x *Argument) GetEnums() []string

func (*Argument) GetEnv 

func (x *Argument) GetEnv() string

func (*Argument) GetEnvs 

func (x *Argument) GetEnvs() []string

func (*Argument) GetFixed32 

func (x *Argument) GetFixed32() uint32

func (*Argument) GetFixed32S 

func (x *Argument) GetFixed32S() []uint32

func (*Argument) GetFixed64 

func (x *Argument) GetFixed64() uint64

func (*Argument) GetFixed64S 

func (x *Argument) GetFixed64S() []uint64

func (*Argument) GetFloat 

func (x *Argument) GetFloat() float32

func (*Argument) GetFloats 

func (x *Argument) GetFloats() []float32

func (*Argument) GetInline 

func (x *Argument) GetInline() string

func (*Argument) GetInt32 

func (x *Argument) GetInt32() int32

func (*Argument) GetInt32S 

func (x *Argument) GetInt32S() []int32

func (*Argument) GetInt64 

func (x *Argument) GetInt64() int64

func (*Argument) GetInt64S 

func (x *Argument) GetInt64S() []int64

func (*Argument) GetMessage 

func (x *Argument) GetMessage() *MessageValue

func (*Argument) GetMessages 

func (x *Argument) GetMessages() []*MessageValue

func (*Argument) GetName 

func (x *Argument) GetName() string

func (*Argument) GetSfixed32 

func (x *Argument) GetSfixed32() int32

func (*Argument) GetSfixed32S 

func (x *Argument) GetSfixed32S() []int32

func (*Argument) GetSfixed64 

func (x *Argument) GetSfixed64() int64

func (*Argument) GetSfixed64S 

func (x *Argument) GetSfixed64S() []int64

func (*Argument) GetSint32 

func (x *Argument) GetSint32() int32

func (*Argument) GetSint32S 

func (x *Argument) GetSint32S() []int32

func (*Argument) GetSint64 

func (x *Argument) GetSint64() int64

func (*Argument) GetSint64S 

func (x *Argument) GetSint64S() []int64

func (*Argument) GetString_ 

func (x *Argument) GetString_() string

func (*Argument) GetStrings 

func (x *Argument) GetStrings() []string

func (*Argument) GetUint32 

func (x *Argument) GetUint32() uint32

func (*Argument) GetUint32S 

func (x *Argument) GetUint32S() []uint32

func (*Argument) GetUint64 

func (x *Argument) GetUint64() uint64

func (*Argument) GetUint64S 

func (x *Argument) GetUint64S() []uint64

func (*Argument) MarshalToSizedBufferVT added in v0.12.0 

func (m *Argument) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Argument) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *Argument) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Argument) MarshalToVT added in v0.12.0 

func (m *Argument) MarshalToVT(dAtA []byte) (int, error)

func (*Argument) MarshalToVTStrict added in v0.12.0 

func (m *Argument) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Argument) MarshalVT added in v0.12.0 

func (m *Argument) MarshalVT() (dAtA []byte, err error)

func (*Argument) MarshalVTStrict added in v0.12.0 

func (m *Argument) MarshalVTStrict() (dAtA []byte, err error)

func (*Argument) ProtoMessage 

func (*Argument) ProtoMessage()

func (*Argument) ProtoReflect 

func (x *Argument) ProtoReflect() protoreflect.Message

func (*Argument) Reset 

func (x *Argument) Reset()

func (*Argument) SizeVT added in v0.12.0 

func (m *Argument) SizeVT() (n int)

func (*Argument) String 

func (x *Argument) String() string

func (*Argument) UnmarshalVT added in v0.12.0 

func (m *Argument) UnmarshalVT(dAtA []byte) error

func (*Argument) UnmarshalVTUnsafe added in v0.12.0 

func (m *Argument) UnmarshalVTUnsafe(dAtA []byte) error

type BackOff added in v0.10.0 

type BackOff struct {
	backoff.BackOff
}

func BackOffWithContext added in v0.10.0 

func BackOffWithContext(b *BackOff, ctx context.Context) *BackOff

func BackOffWithMaxRetries added in v0.10.0 

func BackOffWithMaxRetries(b *BackOff, max uint64) *BackOff

func NewConstantBackOff added in v0.10.0 

func NewConstantBackOff(d time.Duration) *BackOff

func NewExponentialBackOff added in v0.10.0 

func NewExponentialBackOff(cfg *ExponentialBackOffConfig) *BackOff

type BadRequestFieldViolation added in v0.10.0 

type BadRequestFieldViolation struct {
	Field string
	Desc  string
}

type CELEnv added in v0.10.0 

type CELEnv = cel.Env

type CELFieldType added in v0.10.0 

type CELFieldType = types.FieldType

type CELFunction added in v0.10.0 

type CELFunction struct {

	// name is the function name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// desc is the description of function.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// args describe the definition of the function argument.
	Args []*CELFunctionArgument `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// return describe the definition of return type of function.
	Return *CELType `protobuf:"bytes,4,opt,name=return,proto3" json:"return,omitempty"`
	// contains filtered or unexported fields
}

CELFunction represents the CEL function definition.

func (*CELFunction) CloneMessageVT added in v0.12.0 

func (m *CELFunction) CloneMessageVT() proto.Message

func (*CELFunction) CloneVT added in v0.12.0 

func (m *CELFunction) CloneVT() *CELFunction

func (*CELFunction) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use CELFunction.ProtoReflect.Descriptor instead.

func (*CELFunction) EqualMessageVT added in v0.12.0 

func (this *CELFunction) EqualMessageVT(thatMsg proto.Message) bool

func (*CELFunction) EqualVT added in v0.12.0 

func (this *CELFunction) EqualVT(that *CELFunction) bool

func (*CELFunction) GetArgs added in v0.10.0 

func (x *CELFunction) GetArgs() []*CELFunctionArgument

func (*CELFunction) GetDesc added in v0.10.0 

func (x *CELFunction) GetDesc() string

func (*CELFunction) GetName added in v0.10.0 

func (x *CELFunction) GetName() string

func (*CELFunction) GetReturn added in v0.10.0 

func (x *CELFunction) GetReturn() *CELType

func (*CELFunction) MarshalToSizedBufferVT added in v0.12.0 

func (m *CELFunction) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CELFunction) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *CELFunction) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CELFunction) MarshalToVT added in v0.12.0 

func (m *CELFunction) MarshalToVT(dAtA []byte) (int, error)

func (*CELFunction) MarshalToVTStrict added in v0.12.0 

func (m *CELFunction) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CELFunction) MarshalVT added in v0.12.0 

func (m *CELFunction) MarshalVT() (dAtA []byte, err error)

func (*CELFunction) MarshalVTStrict added in v0.12.0 

func (m *CELFunction) MarshalVTStrict() (dAtA []byte, err error)

func (*CELFunction) ProtoMessage added in v0.10.0 

func (*CELFunction) ProtoMessage()

func (*CELFunction) ProtoReflect added in v0.10.0 

func (x *CELFunction) ProtoReflect() protoreflect.Message

func (*CELFunction) Reset added in v0.10.0 

func (x *CELFunction) Reset()

func (*CELFunction) SizeVT added in v0.12.0 

func (m *CELFunction) SizeVT() (n int)

func (*CELFunction) String added in v0.10.0 

func (x *CELFunction) String() string

func (*CELFunction) UnmarshalVT added in v0.12.0 

func (m *CELFunction) UnmarshalVT(dAtA []byte) error

func (*CELFunction) UnmarshalVTUnsafe added in v0.12.0 

func (m *CELFunction) UnmarshalVTUnsafe(dAtA []byte) error

type CELFunctionArgument added in v0.10.0 

type CELFunctionArgument struct {

	// name is the argument value name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// desc is the description of plugin.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// type is the argument type.
	// The value must be one that can be referenced on the Protocol Buffers.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// repeated is whether repeated type or not.
	Repeated bool `protobuf:"varint,4,opt,name=repeated,proto3" json:"repeated,omitempty"`
	// contains filtered or unexported fields
}

CELFunctionArgument represents the function argument.

func (*CELFunctionArgument) CloneMessageVT added in v0.12.0 

func (m *CELFunctionArgument) CloneMessageVT() proto.Message

func (*CELFunctionArgument) CloneVT added in v0.12.0 

func (m *CELFunctionArgument) CloneVT() *CELFunctionArgument

func (*CELFunctionArgument) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use CELFunctionArgument.ProtoReflect.Descriptor instead.

func (*CELFunctionArgument) EqualMessageVT added in v0.12.0 

func (this *CELFunctionArgument) EqualMessageVT(thatMsg proto.Message) bool

func (*CELFunctionArgument) EqualVT added in v0.12.0 

func (this *CELFunctionArgument) EqualVT(that *CELFunctionArgument) bool

func (*CELFunctionArgument) GetDesc added in v0.10.0 

func (x *CELFunctionArgument) GetDesc() string

func (*CELFunctionArgument) GetName added in v0.10.0 

func (x *CELFunctionArgument) GetName() string

func (*CELFunctionArgument) GetRepeated added in v0.10.0 

func (x *CELFunctionArgument) GetRepeated() bool

func (*CELFunctionArgument) GetType added in v0.10.0 

func (x *CELFunctionArgument) GetType() string

func (*CELFunctionArgument) MarshalToSizedBufferVT added in v0.12.0 

func (m *CELFunctionArgument) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CELFunctionArgument) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *CELFunctionArgument) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CELFunctionArgument) MarshalToVT added in v0.12.0 

func (m *CELFunctionArgument) MarshalToVT(dAtA []byte) (int, error)

func (*CELFunctionArgument) MarshalToVTStrict added in v0.12.0 

func (m *CELFunctionArgument) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CELFunctionArgument) MarshalVT added in v0.12.0 

func (m *CELFunctionArgument) MarshalVT() (dAtA []byte, err error)

func (*CELFunctionArgument) MarshalVTStrict added in v0.12.0 

func (m *CELFunctionArgument) MarshalVTStrict() (dAtA []byte, err error)

func (*CELFunctionArgument) ProtoMessage added in v0.10.0 

func (*CELFunctionArgument) ProtoMessage()

func (*CELFunctionArgument) ProtoReflect added in v0.10.0 

func (x *CELFunctionArgument) ProtoReflect() protoreflect.Message

func (*CELFunctionArgument) Reset added in v0.10.0 

func (x *CELFunctionArgument) Reset()

func (*CELFunctionArgument) SizeVT added in v0.12.0 

func (m *CELFunctionArgument) SizeVT() (n int)

func (*CELFunctionArgument) String added in v0.10.0 

func (x *CELFunctionArgument) String() string

func (*CELFunctionArgument) UnmarshalVT added in v0.12.0 

func (m *CELFunctionArgument) UnmarshalVT(dAtA []byte) error

func (*CELFunctionArgument) UnmarshalVTUnsafe added in v0.12.0 

func (m *CELFunctionArgument) UnmarshalVTUnsafe(dAtA []byte) error

type CELType added in v0.10.0 

type CELType struct {

	// type is the type name.
	// The value must be one that can be referenced on the Protocol Buffers.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// desc is the description of plugin.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// repeated is whether repeated type or not.
	Repeated bool `protobuf:"varint,3,opt,name=repeated,proto3" json:"repeated,omitempty"`
	// contains filtered or unexported fields
}

CELType represents type information.

func (*CELType) CloneMessageVT added in v0.12.0 

func (m *CELType) CloneMessageVT() proto.Message

func (*CELType) CloneVT added in v0.12.0 

func (m *CELType) CloneVT() *CELType

func (*CELType) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use CELType.ProtoReflect.Descriptor instead.

func (*CELType) EqualMessageVT added in v0.12.0 

func (this *CELType) EqualMessageVT(thatMsg proto.Message) bool

func (*CELType) EqualVT added in v0.12.0 

func (this *CELType) EqualVT(that *CELType) bool

func (*CELType) GetDesc added in v0.10.0 

func (x *CELType) GetDesc() string

func (*CELType) GetRepeated added in v0.10.0 

func (x *CELType) GetRepeated() bool

func (*CELType) GetType added in v0.10.0 

func (x *CELType) GetType() string

func (*CELType) MarshalToSizedBufferVT added in v0.12.0 

func (m *CELType) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CELType) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *CELType) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CELType) MarshalToVT added in v0.12.0 

func (m *CELType) MarshalToVT(dAtA []byte) (int, error)

func (*CELType) MarshalToVTStrict added in v0.12.0 

func (m *CELType) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CELType) MarshalVT added in v0.12.0 

func (m *CELType) MarshalVT() (dAtA []byte, err error)

func (*CELType) MarshalVTStrict added in v0.12.0 

func (m *CELType) MarshalVTStrict() (dAtA []byte, err error)

func (*CELType) ProtoMessage added in v0.10.0 

func (*CELType) ProtoMessage()

func (*CELType) ProtoReflect added in v0.10.0 

func (x *CELType) ProtoReflect() protoreflect.Message

func (*CELType) Reset added in v0.10.0 

func (x *CELType) Reset()

func (*CELType) SizeVT added in v0.12.0 

func (m *CELType) SizeVT() (n int)

func (*CELType) String added in v0.10.0 

func (x *CELType) String() string

func (*CELType) UnmarshalVT added in v0.12.0 

func (m *CELType) UnmarshalVT(dAtA []byte) error

func (*CELType) UnmarshalVTUnsafe added in v0.12.0 

func (m *CELType) UnmarshalVTUnsafe(dAtA []byte) error

type CELTypeDeclare added in v0.10.0 

type CELTypeDeclare = cel.Type

type CELTypeHelper added in v0.4.0 

type CELTypeHelper struct {
	// contains filtered or unexported fields
}

CELTypeHelper provides the cel.Registry needed to build a cel environment.

func NewCELTypeHelper added in v0.4.0 

func NewCELTypeHelper(structFieldMap map[string]map[string]*celtypes.FieldType) *CELTypeHelper

func (*CELTypeHelper) EnumValue added in v0.4.0 

func (h *CELTypeHelper) EnumValue(enumName string) ref.Val

func (*CELTypeHelper) FindIdent added in v0.4.0 

func (h *CELTypeHelper) FindIdent(identName string) (ref.Val, bool)

func (*CELTypeHelper) FindStructFieldNames added in v0.4.0 

func (h *CELTypeHelper) FindStructFieldNames(structType string) ([]string, bool)

func (*CELTypeHelper) FindStructFieldType added in v0.4.0 

func (h *CELTypeHelper) FindStructFieldType(structType, fieldName string) (*celtypes.FieldType, bool)

func (*CELTypeHelper) FindStructType added in v0.4.0 

func (h *CELTypeHelper) FindStructType(structType string) (*celtypes.Type, bool)

func (*CELTypeHelper) NewValue added in v0.4.0 

func (h *CELTypeHelper) NewValue(structType string, fields map[string]ref.Val) ref.Val

func (*CELTypeHelper) TypeAdapter added in v0.4.0 

func (h *CELTypeHelper) TypeAdapter() celtypes.Adapter

func (*CELTypeHelper) TypeProvider added in v0.4.0 

func (h *CELTypeHelper) TypeProvider() celtypes.Provider

type CELVariable added in v0.10.0 

type CELVariable struct {

	// name is the variable name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// desc is the description of plugin.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// type is the argument type.
	// The value must be one that can be referenced on the Protocol Buffers.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// repeated is whether repeated type or not.
	Repeated bool `protobuf:"varint,4,opt,name=repeated,proto3" json:"repeated,omitempty"`
	// contains filtered or unexported fields
}

CELVariable represents CEL variable.

func (*CELVariable) CloneMessageVT added in v0.12.0 

func (m *CELVariable) CloneMessageVT() proto.Message

func (*CELVariable) CloneVT added in v0.12.0 

func (m *CELVariable) CloneVT() *CELVariable

func (*CELVariable) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use CELVariable.ProtoReflect.Descriptor instead.

func (*CELVariable) EqualMessageVT added in v0.12.0 

func (this *CELVariable) EqualMessageVT(thatMsg proto.Message) bool

func (*CELVariable) EqualVT added in v0.12.0 

func (this *CELVariable) EqualVT(that *CELVariable) bool

func (*CELVariable) GetDesc added in v0.10.0 

func (x *CELVariable) GetDesc() string

func (*CELVariable) GetName added in v0.10.0 

func (x *CELVariable) GetName() string

func (*CELVariable) GetRepeated added in v0.12.0 

func (x *CELVariable) GetRepeated() bool

func (*CELVariable) GetType added in v0.10.0 

func (x *CELVariable) GetType() string

func (*CELVariable) MarshalToSizedBufferVT added in v0.12.0 

func (m *CELVariable) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CELVariable) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *CELVariable) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CELVariable) MarshalToVT added in v0.12.0 

func (m *CELVariable) MarshalToVT(dAtA []byte) (int, error)

func (*CELVariable) MarshalToVTStrict added in v0.12.0 

func (m *CELVariable) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CELVariable) MarshalVT added in v0.12.0 

func (m *CELVariable) MarshalVT() (dAtA []byte, err error)

func (*CELVariable) MarshalVTStrict added in v0.12.0 

func (m *CELVariable) MarshalVTStrict() (dAtA []byte, err error)

func (*CELVariable) ProtoMessage added in v0.10.0 

func (*CELVariable) ProtoMessage()

func (*CELVariable) ProtoReflect added in v0.10.0 

func (x *CELVariable) ProtoReflect() protoreflect.Message

func (*CELVariable) Reset added in v0.10.0 

func (x *CELVariable) Reset()

func (*CELVariable) SizeVT added in v0.12.0 

func (m *CELVariable) SizeVT() (n int)

func (*CELVariable) String added in v0.10.0 

func (x *CELVariable) String() string

func (*CELVariable) UnmarshalVT added in v0.12.0 

func (m *CELVariable) UnmarshalVT(dAtA []byte) error

func (*CELVariable) UnmarshalVTUnsafe added in v0.12.0 

func (m *CELVariable) UnmarshalVTUnsafe(dAtA []byte) error

type CallExpr added in v0.6.0 

type CallExpr struct {

	// method specify the FQDN for the gRPC method. format is `<package-name>.<service-name>/<method-name>`.
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// request specify request parameters for the gRPC method.
	Request []*MethodRequest `protobuf:"bytes,2,rep,name=request,proto3" json:"request,omitempty"`
	// the time to timeout. If the specified time period elapses, DEADLINE_EXCEEDED status is returned.
	// If you want to handle this error, you need to implement a custom error handler in Go.
	// The format is the same as Go's time.Duration format. See https://pkg.go.dev/time#ParseDuration.
	Timeout *string `protobuf:"bytes,3,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// retry specifies the retry policy if the method call fails.
	Retry *RetryPolicy `protobuf:"bytes,4,opt,name=retry,proto3,oneof" json:"retry,omitempty"`
	// contains filtered or unexported fields
}

CallExpr represents how to call gRPC method.

func (*CallExpr) CloneMessageVT added in v0.12.0 

func (m *CallExpr) CloneMessageVT() proto.Message

func (*CallExpr) CloneVT added in v0.12.0 

func (m *CallExpr) CloneVT() *CallExpr

func (*CallExpr) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use CallExpr.ProtoReflect.Descriptor instead.

func (*CallExpr) EqualMessageVT added in v0.12.0 

func (this *CallExpr) EqualMessageVT(thatMsg proto.Message) bool

func (*CallExpr) EqualVT added in v0.12.0 

func (this *CallExpr) EqualVT(that *CallExpr) bool

func (*CallExpr) GetMethod added in v0.6.0 

func (x *CallExpr) GetMethod() string

func (*CallExpr) GetRequest added in v0.6.0 

func (x *CallExpr) GetRequest() []*MethodRequest

func (*CallExpr) GetRetry added in v0.6.0 

func (x *CallExpr) GetRetry() *RetryPolicy

func (*CallExpr) GetTimeout added in v0.6.0 

func (x *CallExpr) GetTimeout() string

func (*CallExpr) MarshalToSizedBufferVT added in v0.12.0 

func (m *CallExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CallExpr) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *CallExpr) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CallExpr) MarshalToVT added in v0.12.0 

func (m *CallExpr) MarshalToVT(dAtA []byte) (int, error)

func (*CallExpr) MarshalToVTStrict added in v0.12.0 

func (m *CallExpr) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CallExpr) MarshalVT added in v0.12.0 

func (m *CallExpr) MarshalVT() (dAtA []byte, err error)

func (*CallExpr) MarshalVTStrict added in v0.12.0 

func (m *CallExpr) MarshalVTStrict() (dAtA []byte, err error)

func (*CallExpr) ProtoMessage added in v0.6.0 

func (*CallExpr) ProtoMessage()

func (*CallExpr) ProtoReflect added in v0.6.0 

func (x *CallExpr) ProtoReflect() protoreflect.Message

func (*CallExpr) Reset added in v0.6.0 

func (x *CallExpr) Reset()

func (*CallExpr) SizeVT added in v0.12.0 

func (m *CallExpr) SizeVT() (n int)

func (*CallExpr) String added in v0.6.0 

func (x *CallExpr) String() string

func (*CallExpr) UnmarshalVT added in v0.12.0 

func (m *CallExpr) UnmarshalVT(dAtA []byte) error

func (*CallExpr) UnmarshalVTUnsafe added in v0.12.0 

func (m *CallExpr) UnmarshalVTUnsafe(dAtA []byte) error

type Code added in v0.10.0 

type Code = codes.Code
const (
	OKCode                 Code = codes.Unimplemented
	CanceledCode           Code = codes.Canceled
	UnknownCode            Code = codes.Unknown
	InvalidArgumentCode    Code = codes.InvalidArgument
	DeadlineExceededCode   Code = codes.DeadlineExceeded
	NotFoundCode           Code = codes.NotFound
	AlreadyExistsCode      Code = codes.AlreadyExists
	PermissionDeniedCode   Code = codes.PermissionDenied
	ResourceExhaustedCode  Code = codes.ResourceExhausted
	FailedPreconditionCode Code = codes.FailedPrecondition
	AbortedCode            Code = codes.Aborted
	OutOfRangeCode         Code = codes.OutOfRange
	UnimplementedCode      Code = codes.Unimplemented
	InternalCode           Code = codes.Internal
	UnavailableCode        Code = codes.Unavailable
	DataLossCode           Code = codes.DataLoss
	UnauthenticatedCode    Code = codes.Unauthenticated
)

type Def added in v0.10.0 

type Def[T any, U localValue] struct {
	If         string
	Name       string
	Type       *cel.Type
	Setter     func(U, T)
	By         string
	Message    func(context.Context, U) (any, error)
	Validation func(context.Context, U) error
}

type DefMap added in v0.10.0 

type DefMap[T any, U any, V localValue] struct {
	If             string
	Name           string
	Type           *cel.Type
	Setter         func(V, T)
	IteratorName   string
	IteratorType   *cel.Type
	IteratorSource func(V) []U
	Iterator       func(context.Context, *MapIteratorValue) (any, error)
	// contains filtered or unexported fields
}

type EnumRule 

type EnumRule struct {

	// alias mapping between enums defined in other packages and enums defined on the federation service side.
	// The alias is the FQDN ( <package-name>.<enum-name> ) to the enum.
	// If this definition exists, type conversion is automatically performed before the enum value assignment operation.
	// If a enum with this option has a value that is not present in the enum specified by alias, and the alias option is not specified for that value, an error is occurred.
	Alias *string `protobuf:"bytes,1,opt,name=alias,proto3,oneof" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumRule) CloneMessageVT added in v0.12.0 

func (m *EnumRule) CloneMessageVT() proto.Message

func (*EnumRule) CloneVT added in v0.12.0 

func (m *EnumRule) CloneVT() *EnumRule

func (*EnumRule) Descriptor deprecated 

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

Deprecated: Use EnumRule.ProtoReflect.Descriptor instead.

func (*EnumRule) EqualMessageVT added in v0.12.0 

func (this *EnumRule) EqualMessageVT(thatMsg proto.Message) bool

func (*EnumRule) EqualVT added in v0.12.0 

func (this *EnumRule) EqualVT(that *EnumRule) bool

func (*EnumRule) GetAlias 

func (x *EnumRule) GetAlias() string

func (*EnumRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *EnumRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnumRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *EnumRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*EnumRule) MarshalToVT added in v0.12.0 

func (m *EnumRule) MarshalToVT(dAtA []byte) (int, error)

func (*EnumRule) MarshalToVTStrict added in v0.12.0 

func (m *EnumRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*EnumRule) MarshalVT added in v0.12.0 

func (m *EnumRule) MarshalVT() (dAtA []byte, err error)

func (*EnumRule) MarshalVTStrict added in v0.12.0 

func (m *EnumRule) MarshalVTStrict() (dAtA []byte, err error)

func (*EnumRule) ProtoMessage 

func (*EnumRule) ProtoMessage()

func (*EnumRule) ProtoReflect 

func (x *EnumRule) ProtoReflect() protoreflect.Message

func (*EnumRule) Reset 

func (x *EnumRule) Reset()

func (*EnumRule) SizeVT added in v0.12.0 

func (m *EnumRule) SizeVT() (n int)

func (*EnumRule) String 

func (x *EnumRule) String() string

func (*EnumRule) UnmarshalVT added in v0.12.0 

func (m *EnumRule) UnmarshalVT(dAtA []byte) error

func (*EnumRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *EnumRule) UnmarshalVTUnsafe(dAtA []byte) error

type EnumValueRule 

type EnumValueRule struct {

	// specifies the default value of the enum.
	// All values other than those specified in alias will be default values.
	Default *bool `protobuf:"varint,1,opt,name=default,proto3,oneof" json:"default,omitempty"`
	// alias can be used when alias is specified in grpc.federation.enum option,
	// and specifies the value name to be referenced among the enums specified in alias of enum option.
	// multiple value names can be specified for alias.
	Alias []string `protobuf:"bytes,2,rep,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumValueRule) CloneMessageVT added in v0.12.0 

func (m *EnumValueRule) CloneMessageVT() proto.Message

func (*EnumValueRule) CloneVT added in v0.12.0 

func (m *EnumValueRule) CloneVT() *EnumValueRule

func (*EnumValueRule) Descriptor deprecated 

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

Deprecated: Use EnumValueRule.ProtoReflect.Descriptor instead.

func (*EnumValueRule) EqualMessageVT added in v0.12.0 

func (this *EnumValueRule) EqualMessageVT(thatMsg proto.Message) bool

func (*EnumValueRule) EqualVT added in v0.12.0 

func (this *EnumValueRule) EqualVT(that *EnumValueRule) bool

func (*EnumValueRule) GetAlias 

func (x *EnumValueRule) GetAlias() []string

func (*EnumValueRule) GetDefault 

func (x *EnumValueRule) GetDefault() bool

func (*EnumValueRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *EnumValueRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnumValueRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *EnumValueRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*EnumValueRule) MarshalToVT added in v0.12.0 

func (m *EnumValueRule) MarshalToVT(dAtA []byte) (int, error)

func (*EnumValueRule) MarshalToVTStrict added in v0.12.0 

func (m *EnumValueRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*EnumValueRule) MarshalVT added in v0.12.0 

func (m *EnumValueRule) MarshalVT() (dAtA []byte, err error)

func (*EnumValueRule) MarshalVTStrict added in v0.12.0 

func (m *EnumValueRule) MarshalVTStrict() (dAtA []byte, err error)

func (*EnumValueRule) ProtoMessage 

func (*EnumValueRule) ProtoMessage()

func (*EnumValueRule) ProtoReflect 

func (x *EnumValueRule) ProtoReflect() protoreflect.Message

func (*EnumValueRule) Reset 

func (x *EnumValueRule) Reset()

func (*EnumValueRule) SizeVT added in v0.12.0 

func (m *EnumValueRule) SizeVT() (n int)

func (*EnumValueRule) String 

func (x *EnumValueRule) String() string

func (*EnumValueRule) UnmarshalVT added in v0.12.0 

func (m *EnumValueRule) UnmarshalVT(dAtA []byte) error

func (*EnumValueRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *EnumValueRule) UnmarshalVTUnsafe(dAtA []byte) error

type ErrorGroup added in v0.10.0 

type ErrorGroup = errgroup.Group

type ErrorHandler added in v0.4.0 

type ErrorHandler func(ctx context.Context, methodName string, err error) error

ErrorHandler Federation Service often needs to convert errors received from downstream services. If an error occurs during method execution in the Federation Service, this error handler is called and the returned error is treated as a final error.

type ExponentialBackOffConfig added in v0.10.0 

type ExponentialBackOffConfig struct {
	InitialInterval     time.Duration
	RandomizationFactor float64
	Multiplier          float64
	MaxInterval         time.Duration
	MaxElapsedTime      time.Duration
}

type Export added in v0.10.0 

type Export struct {

	// name is the plugin name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// desc is the description of plugin.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// types describe the message type you want to expose.
	Types []*ReceiverType `protobuf:"bytes,3,rep,name=types,proto3" json:"types,omitempty"`
	// functions describe the definition of the function you want to expose.
	Functions []*CELFunction `protobuf:"bytes,4,rep,name=functions,proto3" json:"functions,omitempty"`
	// variables describe the definition of the variable you want to expose.
	Variables []*CELVariable `protobuf:"bytes,5,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

Export describe the schema to be exposed as a CEL plugin.

func (*Export) CloneMessageVT added in v0.12.0 

func (m *Export) CloneMessageVT() proto.Message

func (*Export) CloneVT added in v0.12.0 

func (m *Export) CloneVT() *Export

func (*Export) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use Export.ProtoReflect.Descriptor instead.

func (*Export) EqualMessageVT added in v0.12.0 

func (this *Export) EqualMessageVT(thatMsg proto.Message) bool

func (*Export) EqualVT added in v0.12.0 

func (this *Export) EqualVT(that *Export) bool

func (*Export) GetDesc added in v0.10.0 

func (x *Export) GetDesc() string

func (*Export) GetFunctions added in v0.10.0 

func (x *Export) GetFunctions() []*CELFunction

func (*Export) GetName added in v0.10.0 

func (x *Export) GetName() string

func (*Export) GetTypes added in v0.10.0 

func (x *Export) GetTypes() []*ReceiverType

func (*Export) GetVariables added in v0.10.0 

func (x *Export) GetVariables() []*CELVariable

func (*Export) MarshalToSizedBufferVT added in v0.12.0 

func (m *Export) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Export) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *Export) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Export) MarshalToVT added in v0.12.0 

func (m *Export) MarshalToVT(dAtA []byte) (int, error)

func (*Export) MarshalToVTStrict added in v0.12.0 

func (m *Export) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Export) MarshalVT added in v0.12.0 

func (m *Export) MarshalVT() (dAtA []byte, err error)

func (*Export) MarshalVTStrict added in v0.12.0 

func (m *Export) MarshalVTStrict() (dAtA []byte, err error)

func (*Export) ProtoMessage added in v0.10.0 

func (*Export) ProtoMessage()

func (*Export) ProtoReflect added in v0.10.0 

func (x *Export) ProtoReflect() protoreflect.Message

func (*Export) Reset added in v0.10.0 

func (x *Export) Reset()

func (*Export) SizeVT added in v0.12.0 

func (m *Export) SizeVT() (n int)

func (*Export) String added in v0.10.0 

func (x *Export) String() string

func (*Export) UnmarshalVT added in v0.12.0 

func (m *Export) UnmarshalVT(dAtA []byte) error

func (*Export) UnmarshalVTUnsafe added in v0.12.0 

func (m *Export) UnmarshalVTUnsafe(dAtA []byte) error

type FieldOneof added in v0.3.0 

type FieldOneof struct {

	// cond specify either `expr` or `default`. Only one `default` can be set per oneof.
	//
	// Types that are assignable to Cond:
	//
	//	*FieldOneof_If
	//	*FieldOneof_Default
	Cond isFieldOneof_Cond `protobuf_oneof:"cond"`
	// def specify variables to be used in current oneof field's scope for field binding.
	Def []*VariableDefinition `protobuf:"bytes,3,rep,name=def,proto3" json:"def,omitempty"`
	// by used to refer to a name or message argument defined in a MessageRule, use `$.` to refer to the message argument.
	// Use CEL (https://github.com/google/cel-spec) to evaluate the expression.
	// Variables are already defined in MessageRule and FieldOneOf can be used.
	By string `protobuf:"bytes,4,opt,name=by,proto3" json:"by,omitempty"`
	// contains filtered or unexported fields
}

FieldOneof evaluate "messages" or other field only if expr is true and assign to the oneof field. This feature only available in oneof.

func (*FieldOneof) CloneMessageVT added in v0.12.0 

func (m *FieldOneof) CloneMessageVT() proto.Message

func (*FieldOneof) CloneVT added in v0.12.0 

func (m *FieldOneof) CloneVT() *FieldOneof

func (*FieldOneof) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use FieldOneof.ProtoReflect.Descriptor instead.

func (*FieldOneof) EqualMessageVT added in v0.12.0 

func (this *FieldOneof) EqualMessageVT(thatMsg proto.Message) bool

func (*FieldOneof) EqualVT added in v0.12.0 

func (this *FieldOneof) EqualVT(that *FieldOneof) bool

func (*FieldOneof) GetBy added in v0.3.0 

func (x *FieldOneof) GetBy() string

func (*FieldOneof) GetCond added in v0.3.0 

func (m *FieldOneof) GetCond() isFieldOneof_Cond

func (*FieldOneof) GetDef added in v0.7.0 

func (x *FieldOneof) GetDef() []*VariableDefinition

func (*FieldOneof) GetDefault added in v0.3.0 

func (x *FieldOneof) GetDefault() bool

func (*FieldOneof) GetIf added in v0.6.0 

func (x *FieldOneof) GetIf() string

func (*FieldOneof) MarshalToSizedBufferVT added in v0.12.0 

func (m *FieldOneof) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FieldOneof) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *FieldOneof) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FieldOneof) MarshalToVT added in v0.12.0 

func (m *FieldOneof) MarshalToVT(dAtA []byte) (int, error)

func (*FieldOneof) MarshalToVTStrict added in v0.12.0 

func (m *FieldOneof) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FieldOneof) MarshalVT added in v0.12.0 

func (m *FieldOneof) MarshalVT() (dAtA []byte, err error)

func (*FieldOneof) MarshalVTStrict added in v0.12.0 

func (m *FieldOneof) MarshalVTStrict() (dAtA []byte, err error)

func (*FieldOneof) ProtoMessage added in v0.3.0 

func (*FieldOneof) ProtoMessage()

func (*FieldOneof) ProtoReflect added in v0.3.0 

func (x *FieldOneof) ProtoReflect() protoreflect.Message

func (*FieldOneof) Reset added in v0.3.0 

func (x *FieldOneof) Reset()

func (*FieldOneof) SizeVT added in v0.12.0 

func (m *FieldOneof) SizeVT() (n int)

func (*FieldOneof) String added in v0.3.0 

func (x *FieldOneof) String() string

func (*FieldOneof) UnmarshalVT added in v0.12.0 

func (m *FieldOneof) UnmarshalVT(dAtA []byte) error

func (*FieldOneof) UnmarshalVTUnsafe added in v0.12.0 

func (m *FieldOneof) UnmarshalVTUnsafe(dAtA []byte) error

type FieldOneof_Default added in v0.3.0 

type FieldOneof_Default struct {
	// default used to assign a value when none of the other fields match any of the specified expressions.
	// Only one value can be defined per oneof.
	Default bool `protobuf:"varint,2,opt,name=default,proto3,oneof"`
}

func (*FieldOneof_Default) CloneVT added in v0.12.0 

func (m *FieldOneof_Default) CloneVT() isFieldOneof_Cond

func (*FieldOneof_Default) EqualVT added in v0.12.0 

func (this *FieldOneof_Default) EqualVT(thatIface isFieldOneof_Cond) bool

func (*FieldOneof_Default) MarshalToSizedBufferVT added in v0.12.0 

func (m *FieldOneof_Default) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FieldOneof_Default) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *FieldOneof_Default) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FieldOneof_Default) MarshalToVT added in v0.12.0 

func (m *FieldOneof_Default) MarshalToVT(dAtA []byte) (int, error)

func (*FieldOneof_Default) MarshalToVTStrict added in v0.12.0 

func (m *FieldOneof_Default) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FieldOneof_Default) SizeVT added in v0.12.0 

func (m *FieldOneof_Default) SizeVT() (n int)

type FieldOneof_If added in v0.6.0 

type FieldOneof_If struct {
	// if describes the condition to be assigned to field.
	// The return value must be of type bool.
	// Use CEL (https://github.com/google/cel-spec) to evaluate the expression.
	// Variables are already defined in MessageRule can be used.
	If string `protobuf:"bytes,1,opt,name=if,proto3,oneof"`
}

func (*FieldOneof_If) CloneVT added in v0.12.0 

func (m *FieldOneof_If) CloneVT() isFieldOneof_Cond

func (*FieldOneof_If) EqualVT added in v0.12.0 

func (this *FieldOneof_If) EqualVT(thatIface isFieldOneof_Cond) bool

func (*FieldOneof_If) MarshalToSizedBufferVT added in v0.12.0 

func (m *FieldOneof_If) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FieldOneof_If) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *FieldOneof_If) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FieldOneof_If) MarshalToVT added in v0.12.0 

func (m *FieldOneof_If) MarshalToVT(dAtA []byte) (int, error)

func (*FieldOneof_If) MarshalToVTStrict added in v0.12.0 

func (m *FieldOneof_If) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FieldOneof_If) SizeVT added in v0.12.0 

func (m *FieldOneof_If) SizeVT() (n int)

type FieldRule 

type FieldRule struct {

	// If custom_resolver is true, the field binding process is to be implemented in Go.
	// If there are any values retrieved by grpc.federation.message option, they are passed as arguments for custom resolver.
	CustomResolver *bool `protobuf:"varint,1,opt,name=custom_resolver,json=customResolver,proto3,oneof" json:"custom_resolver,omitempty"`
	// by used to refer to a name or message argument defined in a MessageRule, use `$.` to refer to the message argument.
	// Use CEL (https://github.com/google/cel-spec) to evaluate the expression.
	// Variables are already defined in MessageRule can be used.
	By *string `protobuf:"bytes,2,opt,name=by,proto3,oneof" json:"by,omitempty"`
	// alias can be used when alias is specified in grpc.federation.message option,
	// and specifies the field name to be referenced among the messages specified in alias of message option.
	// If the specified field has the same type or can be converted automatically, its value is assigned.
	Alias *string `protobuf:"bytes,3,opt,name=alias,proto3,oneof" json:"alias,omitempty"`
	// double literal value.
	Double *float64 `protobuf:"fixed64,4,opt,name=double,proto3,oneof" json:"double,omitempty"`
	// repeated double literal values.
	Doubles []float64 `protobuf:"fixed64,5,rep,packed,name=doubles,proto3" json:"doubles,omitempty"`
	// float literal value.
	Float *float32 `protobuf:"fixed32,6,opt,name=float,proto3,oneof" json:"float,omitempty"`
	// repeated float literal values.
	Floats []float32 `protobuf:"fixed32,7,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	// int32 literal value.
	Int32 *int32 `protobuf:"varint,8,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
	// repeated int32 literal values.
	Int32S []int32 `protobuf:"varint,9,rep,packed,name=int32s,proto3" json:"int32s,omitempty"`
	// int64 literal value.
	Int64 *int64 `protobuf:"varint,10,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
	// repeated int64 literal values.
	Int64S []int64 `protobuf:"varint,11,rep,packed,name=int64s,proto3" json:"int64s,omitempty"`
	// uint32 literal value.
	Uint32 *uint32 `protobuf:"varint,12,opt,name=uint32,proto3,oneof" json:"uint32,omitempty"`
	// repeated uint32 literal values.
	Uint32S []uint32 `protobuf:"varint,13,rep,packed,name=uint32s,proto3" json:"uint32s,omitempty"`
	// uint64 literal value.
	Uint64 *uint64 `protobuf:"varint,14,opt,name=uint64,proto3,oneof" json:"uint64,omitempty"`
	// repeated uint64 literal values.
	Uint64S []uint64 `protobuf:"varint,15,rep,packed,name=uint64s,proto3" json:"uint64s,omitempty"`
	// sint32 literal value.
	Sint32 *int32 `protobuf:"zigzag32,16,opt,name=sint32,proto3,oneof" json:"sint32,omitempty"`
	// repeated sint32 literal values.
	Sint32S []int32 `protobuf:"zigzag32,17,rep,packed,name=sint32s,proto3" json:"sint32s,omitempty"`
	// sint64 literal value.
	Sint64 *int64 `protobuf:"zigzag64,18,opt,name=sint64,proto3,oneof" json:"sint64,omitempty"`
	// repeated sint64 literal values.
	Sint64S []int64 `protobuf:"zigzag64,19,rep,packed,name=sint64s,proto3" json:"sint64s,omitempty"`
	// fixed32 literal value.
	Fixed32 *uint32 `protobuf:"fixed32,20,opt,name=fixed32,proto3,oneof" json:"fixed32,omitempty"`
	// repeated fixed32 literal values.
	Fixed32S []uint32 `protobuf:"fixed32,21,rep,packed,name=fixed32s,proto3" json:"fixed32s,omitempty"`
	// fixed64 literal value.
	Fixed64 *uint64 `protobuf:"fixed64,22,opt,name=fixed64,proto3,oneof" json:"fixed64,omitempty"`
	// repeated fixed64 literal values.
	Fixed64S []uint64 `protobuf:"fixed64,23,rep,packed,name=fixed64s,proto3" json:"fixed64s,omitempty"`
	// sfixed32 literal value.
	Sfixed32 *int32 `protobuf:"fixed32,24,opt,name=sfixed32,proto3,oneof" json:"sfixed32,omitempty"`
	// repeated sfixed32 literal values.
	Sfixed32S []int32 `protobuf:"fixed32,25,rep,packed,name=sfixed32s,proto3" json:"sfixed32s,omitempty"`
	// sfixed64 literal value.
	Sfixed64 *int64 `protobuf:"fixed64,26,opt,name=sfixed64,proto3,oneof" json:"sfixed64,omitempty"`
	// repeated sfixed64 literal values.
	Sfixed64S []int64 `protobuf:"fixed64,27,rep,packed,name=sfixed64s,proto3" json:"sfixed64s,omitempty"`
	// bool literal value.
	Bool *bool `protobuf:"varint,28,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
	// repeated bool literal values.
	Bools []bool `protobuf:"varint,29,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	// string literal value.
	String_ *string `protobuf:"bytes,30,opt,name=string,proto3,oneof" json:"string,omitempty"`
	// repeated string literal values.
	Strings []string `protobuf:"bytes,31,rep,name=strings,proto3" json:"strings,omitempty"`
	// bytes literal value.
	ByteString []byte `protobuf:"bytes,32,opt,name=byte_string,json=byteString,proto3,oneof" json:"byte_string,omitempty"`
	// repeated bytes literal values.
	ByteStrings [][]byte `protobuf:"bytes,33,rep,name=byte_strings,json=byteStrings,proto3" json:"byte_strings,omitempty"`
	// message literal value.
	Message *MessageValue `protobuf:"bytes,34,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// repeated message literal values.
	Messages []*MessageValue `protobuf:"bytes,35,rep,name=messages,proto3" json:"messages,omitempty"`
	// enum literal value.
	Enum *string `protobuf:"bytes,36,opt,name=enum,proto3,oneof" json:"enum,omitempty"`
	// repeated enum literal values.
	Enums []string `protobuf:"bytes,37,rep,name=enums,proto3" json:"enums,omitempty"`
	// env literal value.
	Env *string `protobuf:"bytes,38,opt,name=env,proto3,oneof" json:"env,omitempty"`
	// repeated env literal values.
	Envs []string `protobuf:"bytes,39,rep,name=envs,proto3" json:"envs,omitempty"`
	// use to evaluate any one of fields. this field only available in oneof.
	Oneof *FieldOneof `protobuf:"bytes,40,opt,name=oneof,proto3" json:"oneof,omitempty"`
	// contains filtered or unexported fields
}

FieldRule define gRPC Federation rules for the field of message.

func (*FieldRule) CloneMessageVT added in v0.12.0 

func (m *FieldRule) CloneMessageVT() proto.Message

func (*FieldRule) CloneVT added in v0.12.0 

func (m *FieldRule) CloneVT() *FieldRule

func (*FieldRule) Descriptor deprecated 

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

Deprecated: Use FieldRule.ProtoReflect.Descriptor instead.

func (*FieldRule) EqualMessageVT added in v0.12.0 

func (this *FieldRule) EqualMessageVT(thatMsg proto.Message) bool

func (*FieldRule) EqualVT added in v0.12.0 

func (this *FieldRule) EqualVT(that *FieldRule) bool

func (*FieldRule) GetAlias 

func (x *FieldRule) GetAlias() string

func (*FieldRule) GetBool 

func (x *FieldRule) GetBool() bool

func (*FieldRule) GetBools 

func (x *FieldRule) GetBools() []bool

func (*FieldRule) GetBy 

func (x *FieldRule) GetBy() string

func (*FieldRule) GetByteString 

func (x *FieldRule) GetByteString() []byte

func (*FieldRule) GetByteStrings 

func (x *FieldRule) GetByteStrings() [][]byte

func (*FieldRule) GetCustomResolver 

func (x *FieldRule) GetCustomResolver() bool

func (*FieldRule) GetDouble 

func (x *FieldRule) GetDouble() float64

func (*FieldRule) GetDoubles 

func (x *FieldRule) GetDoubles() []float64

func (*FieldRule) GetEnum 

func (x *FieldRule) GetEnum() string

func (*FieldRule) GetEnums 

func (x *FieldRule) GetEnums() []string

func (*FieldRule) GetEnv 

func (x *FieldRule) GetEnv() string

func (*FieldRule) GetEnvs 

func (x *FieldRule) GetEnvs() []string

func (*FieldRule) GetFixed32 

func (x *FieldRule) GetFixed32() uint32

func (*FieldRule) GetFixed32S 

func (x *FieldRule) GetFixed32S() []uint32

func (*FieldRule) GetFixed64 

func (x *FieldRule) GetFixed64() uint64

func (*FieldRule) GetFixed64S 

func (x *FieldRule) GetFixed64S() []uint64

func (*FieldRule) GetFloat 

func (x *FieldRule) GetFloat() float32

func (*FieldRule) GetFloats 

func (x *FieldRule) GetFloats() []float32

func (*FieldRule) GetInt32 

func (x *FieldRule) GetInt32() int32

func (*FieldRule) GetInt32S 

func (x *FieldRule) GetInt32S() []int32

func (*FieldRule) GetInt64 

func (x *FieldRule) GetInt64() int64

func (*FieldRule) GetInt64S 

func (x *FieldRule) GetInt64S() []int64

func (*FieldRule) GetMessage 

func (x *FieldRule) GetMessage() *MessageValue

func (*FieldRule) GetMessages 

func (x *FieldRule) GetMessages() []*MessageValue

func (*FieldRule) GetOneof added in v0.3.0 

func (x *FieldRule) GetOneof() *FieldOneof

func (*FieldRule) GetSfixed32 

func (x *FieldRule) GetSfixed32() int32

func (*FieldRule) GetSfixed32S 

func (x *FieldRule) GetSfixed32S() []int32

func (*FieldRule) GetSfixed64 

func (x *FieldRule) GetSfixed64() int64

func (*FieldRule) GetSfixed64S 

func (x *FieldRule) GetSfixed64S() []int64

func (*FieldRule) GetSint32 

func (x *FieldRule) GetSint32() int32

func (*FieldRule) GetSint32S 

func (x *FieldRule) GetSint32S() []int32

func (*FieldRule) GetSint64 

func (x *FieldRule) GetSint64() int64

func (*FieldRule) GetSint64S 

func (x *FieldRule) GetSint64S() []int64

func (*FieldRule) GetString_ 

func (x *FieldRule) GetString_() string

func (*FieldRule) GetStrings 

func (x *FieldRule) GetStrings() []string

func (*FieldRule) GetUint32 

func (x *FieldRule) GetUint32() uint32

func (*FieldRule) GetUint32S 

func (x *FieldRule) GetUint32S() []uint32

func (*FieldRule) GetUint64 

func (x *FieldRule) GetUint64() uint64

func (*FieldRule) GetUint64S 

func (x *FieldRule) GetUint64S() []uint64

func (*FieldRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *FieldRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FieldRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *FieldRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FieldRule) MarshalToVT added in v0.12.0 

func (m *FieldRule) MarshalToVT(dAtA []byte) (int, error)

func (*FieldRule) MarshalToVTStrict added in v0.12.0 

func (m *FieldRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FieldRule) MarshalVT added in v0.12.0 

func (m *FieldRule) MarshalVT() (dAtA []byte, err error)

func (*FieldRule) MarshalVTStrict added in v0.12.0 

func (m *FieldRule) MarshalVTStrict() (dAtA []byte, err error)

func (*FieldRule) ProtoMessage 

func (*FieldRule) ProtoMessage()

func (*FieldRule) ProtoReflect 

func (x *FieldRule) ProtoReflect() protoreflect.Message

func (*FieldRule) Reset 

func (x *FieldRule) Reset()

func (*FieldRule) SizeVT added in v0.12.0 

func (m *FieldRule) SizeVT() (n int)

func (*FieldRule) String 

func (x *FieldRule) String() string

func (*FieldRule) UnmarshalVT added in v0.12.0 

func (m *FieldRule) UnmarshalVT(dAtA []byte) error

func (*FieldRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *FieldRule) UnmarshalVTUnsafe(dAtA []byte) error

type Iterator added in v0.6.0 

type Iterator struct {

	// variable name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// src the value that will be the source for creating the iterator.
	// src must be a repeated type.
	Src string `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	// contains filtered or unexported fields
}

Iterator represents iterator variable.

func (*Iterator) CloneMessageVT added in v0.12.0 

func (m *Iterator) CloneMessageVT() proto.Message

func (*Iterator) CloneVT added in v0.12.0 

func (m *Iterator) CloneVT() *Iterator

func (*Iterator) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use Iterator.ProtoReflect.Descriptor instead.

func (*Iterator) EqualMessageVT added in v0.12.0 

func (this *Iterator) EqualMessageVT(thatMsg proto.Message) bool

func (*Iterator) EqualVT added in v0.12.0 

func (this *Iterator) EqualVT(that *Iterator) bool

func (*Iterator) GetName added in v0.6.0 

func (x *Iterator) GetName() string

func (*Iterator) GetSrc added in v0.6.0 

func (x *Iterator) GetSrc() string

func (*Iterator) MarshalToSizedBufferVT added in v0.12.0 

func (m *Iterator) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Iterator) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *Iterator) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Iterator) MarshalToVT added in v0.12.0 

func (m *Iterator) MarshalToVT(dAtA []byte) (int, error)

func (*Iterator) MarshalToVTStrict added in v0.12.0 

func (m *Iterator) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Iterator) MarshalVT added in v0.12.0 

func (m *Iterator) MarshalVT() (dAtA []byte, err error)

func (*Iterator) MarshalVTStrict added in v0.12.0 

func (m *Iterator) MarshalVTStrict() (dAtA []byte, err error)

func (*Iterator) ProtoMessage added in v0.6.0 

func (*Iterator) ProtoMessage()

func (*Iterator) ProtoReflect added in v0.6.0 

func (x *Iterator) ProtoReflect() protoreflect.Message

func (*Iterator) Reset added in v0.6.0 

func (x *Iterator) Reset()

func (*Iterator) SizeVT added in v0.12.0 

func (m *Iterator) SizeVT() (n int)

func (*Iterator) String added in v0.6.0 

func (x *Iterator) String() string

func (*Iterator) UnmarshalVT added in v0.12.0 

func (m *Iterator) UnmarshalVT(dAtA []byte) error

func (*Iterator) UnmarshalVTUnsafe added in v0.12.0 

func (m *Iterator) UnmarshalVTUnsafe(dAtA []byte) error

type LocalValue added in v0.10.0 

type LocalValue struct {
	// contains filtered or unexported fields
}

func NewLocalValue added in v0.10.0 

func NewLocalValue(env *cel.Env, argName string, arg any) *LocalValue

type MapExpr added in v0.6.0 

type MapExpr struct {

	// iterator define iterator variable.
	// When evaluating CEL in `expr`, we can refer to the name defined in iterator.
	Iterator *Iterator `protobuf:"bytes,1,opt,name=iterator,proto3" json:"iterator,omitempty"`
	// expr creates map elements using iterator variable.
	//
	// Types that are assignable to Expr:
	//
	//	*MapExpr_By
	//	*MapExpr_Message
	Expr isMapExpr_Expr `protobuf_oneof:"expr"`
	// contains filtered or unexported fields
}

MapExpr apply map operation for the specified repeated type.

func (*MapExpr) CloneMessageVT added in v0.12.0 

func (m *MapExpr) CloneMessageVT() proto.Message

func (*MapExpr) CloneVT added in v0.12.0 

func (m *MapExpr) CloneVT() *MapExpr

func (*MapExpr) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use MapExpr.ProtoReflect.Descriptor instead.

func (*MapExpr) EqualMessageVT added in v0.12.0 

func (this *MapExpr) EqualMessageVT(thatMsg proto.Message) bool

func (*MapExpr) EqualVT added in v0.12.0 

func (this *MapExpr) EqualVT(that *MapExpr) bool

func (*MapExpr) GetBy added in v0.6.0 

func (x *MapExpr) GetBy() string

func (*MapExpr) GetExpr added in v0.6.0 

func (m *MapExpr) GetExpr() isMapExpr_Expr

func (*MapExpr) GetIterator added in v0.6.0 

func (x *MapExpr) GetIterator() *Iterator

func (*MapExpr) GetMessage added in v0.6.0 

func (x *MapExpr) GetMessage() *MessageExpr

func (*MapExpr) MarshalToSizedBufferVT added in v0.12.0 

func (m *MapExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MapExpr) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MapExpr) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MapExpr) MarshalToVT added in v0.12.0 

func (m *MapExpr) MarshalToVT(dAtA []byte) (int, error)

func (*MapExpr) MarshalToVTStrict added in v0.12.0 

func (m *MapExpr) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MapExpr) MarshalVT added in v0.12.0 

func (m *MapExpr) MarshalVT() (dAtA []byte, err error)

func (*MapExpr) MarshalVTStrict added in v0.12.0 

func (m *MapExpr) MarshalVTStrict() (dAtA []byte, err error)

func (*MapExpr) ProtoMessage added in v0.6.0 

func (*MapExpr) ProtoMessage()

func (*MapExpr) ProtoReflect added in v0.6.0 

func (x *MapExpr) ProtoReflect() protoreflect.Message

func (*MapExpr) Reset added in v0.6.0 

func (x *MapExpr) Reset()

func (*MapExpr) SizeVT added in v0.12.0 

func (m *MapExpr) SizeVT() (n int)

func (*MapExpr) String added in v0.6.0 

func (x *MapExpr) String() string

func (*MapExpr) UnmarshalVT added in v0.12.0 

func (m *MapExpr) UnmarshalVT(dAtA []byte) error

func (*MapExpr) UnmarshalVTUnsafe added in v0.12.0 

func (m *MapExpr) UnmarshalVTUnsafe(dAtA []byte) error

type MapExpr_By added in v0.6.0 

type MapExpr_By struct {
	// `by` evaluates with CEL.
	// this can refer to the variable declared by `iterator`.
	By string `protobuf:"bytes,11,opt,name=by,proto3,oneof"`
}

func (*MapExpr_By) CloneVT added in v0.12.0 

func (m *MapExpr_By) CloneVT() isMapExpr_Expr

func (*MapExpr_By) EqualVT added in v0.12.0 

func (this *MapExpr_By) EqualVT(thatIface isMapExpr_Expr) bool

func (*MapExpr_By) MarshalToSizedBufferVT added in v0.12.0 

func (m *MapExpr_By) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MapExpr_By) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MapExpr_By) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MapExpr_By) MarshalToVT added in v0.12.0 

func (m *MapExpr_By) MarshalToVT(dAtA []byte) (int, error)

func (*MapExpr_By) MarshalToVTStrict added in v0.12.0 

func (m *MapExpr_By) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MapExpr_By) SizeVT added in v0.12.0 

func (m *MapExpr_By) SizeVT() (n int)

type MapExpr_Message added in v0.6.0 

type MapExpr_Message struct {
	// message gets with message arguments, and it is made an element of the map.
	// The result type of MapExpr is the repeated type of the specified message.
	Message *MessageExpr `protobuf:"bytes,12,opt,name=message,proto3,oneof"`
}

func (*MapExpr_Message) CloneVT added in v0.12.0 

func (m *MapExpr_Message) CloneVT() isMapExpr_Expr

func (*MapExpr_Message) EqualVT added in v0.12.0 

func (this *MapExpr_Message) EqualVT(thatIface isMapExpr_Expr) bool

func (*MapExpr_Message) MarshalToSizedBufferVT added in v0.12.0 

func (m *MapExpr_Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MapExpr_Message) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MapExpr_Message) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MapExpr_Message) MarshalToVT added in v0.12.0 

func (m *MapExpr_Message) MarshalToVT(dAtA []byte) (int, error)

func (*MapExpr_Message) MarshalToVTStrict added in v0.12.0 

func (m *MapExpr_Message) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MapExpr_Message) SizeVT added in v0.12.0 

func (m *MapExpr_Message) SizeVT() (n int)

type MapIteratorValue added in v0.10.0 

type MapIteratorValue struct {
	// contains filtered or unexported fields
}

type MessageExpr added in v0.7.0 

type MessageExpr struct {

	// name specify the message name by FQDN. format is `<package-name>.<message-name>`.
	// <package-name> can be omitted when referring to messages in the same package.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// args specify the parameters needed to get the message. This is called the "message arguments".
	Args []*Argument `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

MessageExpr represents dependent message.

func (*MessageExpr) CloneMessageVT added in v0.12.0 

func (m *MessageExpr) CloneMessageVT() proto.Message

func (*MessageExpr) CloneVT added in v0.12.0 

func (m *MessageExpr) CloneVT() *MessageExpr

func (*MessageExpr) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use MessageExpr.ProtoReflect.Descriptor instead.

func (*MessageExpr) EqualMessageVT added in v0.12.0 

func (this *MessageExpr) EqualMessageVT(thatMsg proto.Message) bool

func (*MessageExpr) EqualVT added in v0.12.0 

func (this *MessageExpr) EqualVT(that *MessageExpr) bool

func (*MessageExpr) GetArgs added in v0.7.0 

func (x *MessageExpr) GetArgs() []*Argument

func (*MessageExpr) GetName added in v0.7.0 

func (x *MessageExpr) GetName() string

func (*MessageExpr) MarshalToSizedBufferVT added in v0.12.0 

func (m *MessageExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageExpr) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MessageExpr) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MessageExpr) MarshalToVT added in v0.12.0 

func (m *MessageExpr) MarshalToVT(dAtA []byte) (int, error)

func (*MessageExpr) MarshalToVTStrict added in v0.12.0 

func (m *MessageExpr) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MessageExpr) MarshalVT added in v0.12.0 

func (m *MessageExpr) MarshalVT() (dAtA []byte, err error)

func (*MessageExpr) MarshalVTStrict added in v0.12.0 

func (m *MessageExpr) MarshalVTStrict() (dAtA []byte, err error)

func (*MessageExpr) ProtoMessage added in v0.7.0 

func (*MessageExpr) ProtoMessage()

func (*MessageExpr) ProtoReflect added in v0.7.0 

func (x *MessageExpr) ProtoReflect() protoreflect.Message

func (*MessageExpr) Reset added in v0.7.0 

func (x *MessageExpr) Reset()

func (*MessageExpr) SizeVT added in v0.12.0 

func (m *MessageExpr) SizeVT() (n int)

func (*MessageExpr) String added in v0.7.0 

func (x *MessageExpr) String() string

func (*MessageExpr) UnmarshalVT added in v0.12.0 

func (m *MessageExpr) UnmarshalVT(dAtA []byte) error

func (*MessageExpr) UnmarshalVTUnsafe added in v0.12.0 

func (m *MessageExpr) UnmarshalVTUnsafe(dAtA []byte) error

type MessageFieldValue 

type MessageFieldValue struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// double literal value.
	Double *float64 `protobuf:"fixed64,3,opt,name=double,proto3,oneof" json:"double,omitempty"`
	// repeated double literal values.
	Doubles []float64 `protobuf:"fixed64,4,rep,packed,name=doubles,proto3" json:"doubles,omitempty"`
	// float literal value.
	Float *float32 `protobuf:"fixed32,5,opt,name=float,proto3,oneof" json:"float,omitempty"`
	// repeated float literal values.
	Floats []float32 `protobuf:"fixed32,6,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	// int32 literal value.
	Int32 *int32 `protobuf:"varint,7,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
	// repeated int32 literal values.
	Int32S []int32 `protobuf:"varint,8,rep,packed,name=int32s,proto3" json:"int32s,omitempty"`
	// int64 literal value.
	Int64 *int64 `protobuf:"varint,9,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
	// repeated int64 literal values.
	Int64S []int64 `protobuf:"varint,10,rep,packed,name=int64s,proto3" json:"int64s,omitempty"`
	// uint32 literal value.
	Uint32 *uint32 `protobuf:"varint,11,opt,name=uint32,proto3,oneof" json:"uint32,omitempty"`
	// repeated uint32 literal values.
	Uint32S []uint32 `protobuf:"varint,12,rep,packed,name=uint32s,proto3" json:"uint32s,omitempty"`
	// uint64 literal value.
	Uint64 *uint64 `protobuf:"varint,13,opt,name=uint64,proto3,oneof" json:"uint64,omitempty"`
	// repeated uint64 literal values.
	Uint64S []uint64 `protobuf:"varint,14,rep,packed,name=uint64s,proto3" json:"uint64s,omitempty"`
	// sint32 literal value.
	Sint32 *int32 `protobuf:"zigzag32,15,opt,name=sint32,proto3,oneof" json:"sint32,omitempty"`
	// repeated sint32 literal values.
	Sint32S []int32 `protobuf:"zigzag32,16,rep,packed,name=sint32s,proto3" json:"sint32s,omitempty"`
	// sint64 literal value.
	Sint64 *int64 `protobuf:"zigzag64,17,opt,name=sint64,proto3,oneof" json:"sint64,omitempty"`
	// repeated sint64 literal values.
	Sint64S []int64 `protobuf:"zigzag64,18,rep,packed,name=sint64s,proto3" json:"sint64s,omitempty"`
	// fixed32 literal value.
	Fixed32 *uint32 `protobuf:"fixed32,19,opt,name=fixed32,proto3,oneof" json:"fixed32,omitempty"`
	// repeated fixed32 literal values.
	Fixed32S []uint32 `protobuf:"fixed32,20,rep,packed,name=fixed32s,proto3" json:"fixed32s,omitempty"`
	// fixed64 literal value.
	Fixed64 *uint64 `protobuf:"fixed64,21,opt,name=fixed64,proto3,oneof" json:"fixed64,omitempty"`
	// repeated fixed64 literal values.
	Fixed64S []uint64 `protobuf:"fixed64,22,rep,packed,name=fixed64s,proto3" json:"fixed64s,omitempty"`
	// sfixed32 literal value.
	Sfixed32 *int32 `protobuf:"fixed32,23,opt,name=sfixed32,proto3,oneof" json:"sfixed32,omitempty"`
	// repeated sfixed32 literal values.
	Sfixed32S []int32 `protobuf:"fixed32,24,rep,packed,name=sfixed32s,proto3" json:"sfixed32s,omitempty"`
	// sfixed64 literal value.
	Sfixed64 *int64 `protobuf:"fixed64,25,opt,name=sfixed64,proto3,oneof" json:"sfixed64,omitempty"`
	// repeated sfixed64 literal values.
	Sfixed64S []int64 `protobuf:"fixed64,26,rep,packed,name=sfixed64s,proto3" json:"sfixed64s,omitempty"`
	// bool literal value.
	Bool *bool `protobuf:"varint,27,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
	// repeated bool literal values.
	Bools []bool `protobuf:"varint,28,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	// string literal value.
	String_ *string `protobuf:"bytes,29,opt,name=string,proto3,oneof" json:"string,omitempty"`
	// repeated string literal values.
	Strings []string `protobuf:"bytes,30,rep,name=strings,proto3" json:"strings,omitempty"`
	// bytes literal value.
	ByteString []byte `protobuf:"bytes,31,opt,name=byte_string,json=byteString,proto3,oneof" json:"byte_string,omitempty"`
	// repeated bytes literal values.
	ByteStrings [][]byte `protobuf:"bytes,32,rep,name=byte_strings,json=byteStrings,proto3" json:"byte_strings,omitempty"`
	// message literal value.
	Message *MessageValue `protobuf:"bytes,33,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// repeated message literal values.
	Messages []*MessageValue `protobuf:"bytes,34,rep,name=messages,proto3" json:"messages,omitempty"`
	// enum literal value.
	Enum *string `protobuf:"bytes,35,opt,name=enum,proto3,oneof" json:"enum,omitempty"`
	// repeated enum literal values.
	Enums []string `protobuf:"bytes,36,rep,name=enums,proto3" json:"enums,omitempty"`
	// env literal value.
	Env *string `protobuf:"bytes,37,opt,name=env,proto3,oneof" json:"env,omitempty"`
	// repeated env literal values.
	Envs []string `protobuf:"bytes,38,rep,name=envs,proto3" json:"envs,omitempty"`
	// contains filtered or unexported fields
}

MessageFieldValue represents message's field.

func (*MessageFieldValue) CloneMessageVT added in v0.12.0 

func (m *MessageFieldValue) CloneMessageVT() proto.Message

func (*MessageFieldValue) CloneVT added in v0.12.0 

func (m *MessageFieldValue) CloneVT() *MessageFieldValue

func (*MessageFieldValue) Descriptor deprecated 

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

Deprecated: Use MessageFieldValue.ProtoReflect.Descriptor instead.

func (*MessageFieldValue) EqualMessageVT added in v0.12.0 

func (this *MessageFieldValue) EqualMessageVT(thatMsg proto.Message) bool

func (*MessageFieldValue) EqualVT added in v0.12.0 

func (this *MessageFieldValue) EqualVT(that *MessageFieldValue) bool

func (*MessageFieldValue) GetBool 

func (x *MessageFieldValue) GetBool() bool

func (*MessageFieldValue) GetBools 

func (x *MessageFieldValue) GetBools() []bool

func (*MessageFieldValue) GetByteString 

func (x *MessageFieldValue) GetByteString() []byte

func (*MessageFieldValue) GetByteStrings 

func (x *MessageFieldValue) GetByteStrings() [][]byte

func (*MessageFieldValue) GetDouble 

func (x *MessageFieldValue) GetDouble() float64

func (*MessageFieldValue) GetDoubles 

func (x *MessageFieldValue) GetDoubles() []float64

func (*MessageFieldValue) GetEnum 

func (x *MessageFieldValue) GetEnum() string

func (*MessageFieldValue) GetEnums 

func (x *MessageFieldValue) GetEnums() []string

func (*MessageFieldValue) GetEnv 

func (x *MessageFieldValue) GetEnv() string

func (*MessageFieldValue) GetEnvs 

func (x *MessageFieldValue) GetEnvs() []string

func (*MessageFieldValue) GetField 

func (x *MessageFieldValue) GetField() string

func (*MessageFieldValue) GetFixed32 

func (x *MessageFieldValue) GetFixed32() uint32

func (*MessageFieldValue) GetFixed32S 

func (x *MessageFieldValue) GetFixed32S() []uint32

func (*MessageFieldValue) GetFixed64 

func (x *MessageFieldValue) GetFixed64() uint64

func (*MessageFieldValue) GetFixed64S 

func (x *MessageFieldValue) GetFixed64S() []uint64

func (*MessageFieldValue) GetFloat 

func (x *MessageFieldValue) GetFloat() float32

func (*MessageFieldValue) GetFloats 

func (x *MessageFieldValue) GetFloats() []float32

func (*MessageFieldValue) GetInt32 

func (x *MessageFieldValue) GetInt32() int32

func (*MessageFieldValue) GetInt32S 

func (x *MessageFieldValue) GetInt32S() []int32

func (*MessageFieldValue) GetInt64 

func (x *MessageFieldValue) GetInt64() int64

func (*MessageFieldValue) GetInt64S 

func (x *MessageFieldValue) GetInt64S() []int64

func (*MessageFieldValue) GetMessage 

func (x *MessageFieldValue) GetMessage() *MessageValue

func (*MessageFieldValue) GetMessages 

func (x *MessageFieldValue) GetMessages() []*MessageValue

func (*MessageFieldValue) GetSfixed32 

func (x *MessageFieldValue) GetSfixed32() int32

func (*MessageFieldValue) GetSfixed32S 

func (x *MessageFieldValue) GetSfixed32S() []int32

func (*MessageFieldValue) GetSfixed64 

func (x *MessageFieldValue) GetSfixed64() int64

func (*MessageFieldValue) GetSfixed64S 

func (x *MessageFieldValue) GetSfixed64S() []int64

func (*MessageFieldValue) GetSint32 

func (x *MessageFieldValue) GetSint32() int32

func (*MessageFieldValue) GetSint32S 

func (x *MessageFieldValue) GetSint32S() []int32

func (*MessageFieldValue) GetSint64 

func (x *MessageFieldValue) GetSint64() int64

func (*MessageFieldValue) GetSint64S 

func (x *MessageFieldValue) GetSint64S() []int64

func (*MessageFieldValue) GetString_ 

func (x *MessageFieldValue) GetString_() string

func (*MessageFieldValue) GetStrings 

func (x *MessageFieldValue) GetStrings() []string

func (*MessageFieldValue) GetUint32 

func (x *MessageFieldValue) GetUint32() uint32

func (*MessageFieldValue) GetUint32S 

func (x *MessageFieldValue) GetUint32S() []uint32

func (*MessageFieldValue) GetUint64 

func (x *MessageFieldValue) GetUint64() uint64

func (*MessageFieldValue) GetUint64S 

func (x *MessageFieldValue) GetUint64S() []uint64

func (*MessageFieldValue) MarshalToSizedBufferVT added in v0.12.0 

func (m *MessageFieldValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageFieldValue) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MessageFieldValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MessageFieldValue) MarshalToVT added in v0.12.0 

func (m *MessageFieldValue) MarshalToVT(dAtA []byte) (int, error)

func (*MessageFieldValue) MarshalToVTStrict added in v0.12.0 

func (m *MessageFieldValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MessageFieldValue) MarshalVT added in v0.12.0 

func (m *MessageFieldValue) MarshalVT() (dAtA []byte, err error)

func (*MessageFieldValue) MarshalVTStrict added in v0.12.0 

func (m *MessageFieldValue) MarshalVTStrict() (dAtA []byte, err error)

func (*MessageFieldValue) ProtoMessage 

func (*MessageFieldValue) ProtoMessage()

func (*MessageFieldValue) ProtoReflect 

func (x *MessageFieldValue) ProtoReflect() protoreflect.Message

func (*MessageFieldValue) Reset 

func (x *MessageFieldValue) Reset()

func (*MessageFieldValue) SizeVT added in v0.12.0 

func (m *MessageFieldValue) SizeVT() (n int)

func (*MessageFieldValue) String 

func (x *MessageFieldValue) String() string

func (*MessageFieldValue) UnmarshalVT added in v0.12.0 

func (m *MessageFieldValue) UnmarshalVT(dAtA []byte) error

func (*MessageFieldValue) UnmarshalVTUnsafe added in v0.12.0 

func (m *MessageFieldValue) UnmarshalVTUnsafe(dAtA []byte) error

type MessageRule 

type MessageRule struct {

	// def specify variables to be used in field binding by `grpc.federation.field` option.
	Def []*VariableDefinition `protobuf:"bytes,1,rep,name=def,proto3" json:"def,omitempty"`
	// if custom_resolver is true, the resolver for this message is implemented by Go.
	// If there are any values retrieved by resolver or messages, they are passed as arguments for custom resolver.
	// Each field of the message returned by the custom resolver is automatically bound.
	// If you want to change the binding process for a particular field, set `custom_resolver=true` option for that field.
	CustomResolver *bool `protobuf:"varint,2,opt,name=custom_resolver,json=customResolver,proto3,oneof" json:"custom_resolver,omitempty"`
	// alias mapping between messages defined in other packages and messages defined on the federation service side.
	// The alias is the FQDN ( <package-name>.<message-name> ) to the message.
	// If this definition exists, type conversion is automatically performed before the field assignment operation.
	// If a message with this option has a field that is not present in the message specified by alias, and the alias option is not specified for that field, an error is occurred.
	Alias *string `protobuf:"bytes,3,opt,name=alias,proto3,oneof" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

MessageRule define gRPC Federation rules for the message.

func (*MessageRule) CloneMessageVT added in v0.12.0 

func (m *MessageRule) CloneMessageVT() proto.Message

func (*MessageRule) CloneVT added in v0.12.0 

func (m *MessageRule) CloneVT() *MessageRule

func (*MessageRule) Descriptor deprecated 

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

Deprecated: Use MessageRule.ProtoReflect.Descriptor instead.

func (*MessageRule) EqualMessageVT added in v0.12.0 

func (this *MessageRule) EqualMessageVT(thatMsg proto.Message) bool

func (*MessageRule) EqualVT added in v0.12.0 

func (this *MessageRule) EqualVT(that *MessageRule) bool

func (*MessageRule) GetAlias 

func (x *MessageRule) GetAlias() string

func (*MessageRule) GetCustomResolver 

func (x *MessageRule) GetCustomResolver() bool

func (*MessageRule) GetDef added in v0.6.0 

func (x *MessageRule) GetDef() []*VariableDefinition

func (*MessageRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *MessageRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MessageRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MessageRule) MarshalToVT added in v0.12.0 

func (m *MessageRule) MarshalToVT(dAtA []byte) (int, error)

func (*MessageRule) MarshalToVTStrict added in v0.12.0 

func (m *MessageRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MessageRule) MarshalVT added in v0.12.0 

func (m *MessageRule) MarshalVT() (dAtA []byte, err error)

func (*MessageRule) MarshalVTStrict added in v0.12.0 

func (m *MessageRule) MarshalVTStrict() (dAtA []byte, err error)

func (*MessageRule) ProtoMessage 

func (*MessageRule) ProtoMessage()

func (*MessageRule) ProtoReflect 

func (x *MessageRule) ProtoReflect() protoreflect.Message

func (*MessageRule) Reset 

func (x *MessageRule) Reset()

func (*MessageRule) SizeVT added in v0.12.0 

func (m *MessageRule) SizeVT() (n int)

func (*MessageRule) String 

func (x *MessageRule) String() string

func (*MessageRule) UnmarshalVT added in v0.12.0 

func (m *MessageRule) UnmarshalVT(dAtA []byte) error

func (*MessageRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *MessageRule) UnmarshalVTUnsafe(dAtA []byte) error

type MessageValue 

type MessageValue struct {

	// name specify the message name to be referred to by FQDN. format is `<package-name>.<message-name>`.
	// <package-name> can be omitted when referring to messages in the same package.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// fields represents message's fields.
	Fields []*MessageFieldValue `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

MessageValue represents message literal.

func (*MessageValue) CloneMessageVT added in v0.12.0 

func (m *MessageValue) CloneMessageVT() proto.Message

func (*MessageValue) CloneVT added in v0.12.0 

func (m *MessageValue) CloneVT() *MessageValue

func (*MessageValue) Descriptor deprecated 

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

Deprecated: Use MessageValue.ProtoReflect.Descriptor instead.

func (*MessageValue) EqualMessageVT added in v0.12.0 

func (this *MessageValue) EqualMessageVT(thatMsg proto.Message) bool

func (*MessageValue) EqualVT added in v0.12.0 

func (this *MessageValue) EqualVT(that *MessageValue) bool

func (*MessageValue) GetFields 

func (x *MessageValue) GetFields() []*MessageFieldValue

func (*MessageValue) GetName 

func (x *MessageValue) GetName() string

func (*MessageValue) MarshalToSizedBufferVT added in v0.12.0 

func (m *MessageValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MessageValue) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MessageValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MessageValue) MarshalToVT added in v0.12.0 

func (m *MessageValue) MarshalToVT(dAtA []byte) (int, error)

func (*MessageValue) MarshalToVTStrict added in v0.12.0 

func (m *MessageValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MessageValue) MarshalVT added in v0.12.0 

func (m *MessageValue) MarshalVT() (dAtA []byte, err error)

func (*MessageValue) MarshalVTStrict added in v0.12.0 

func (m *MessageValue) MarshalVTStrict() (dAtA []byte, err error)

func (*MessageValue) ProtoMessage 

func (*MessageValue) ProtoMessage()

func (*MessageValue) ProtoReflect 

func (x *MessageValue) ProtoReflect() protoreflect.Message

func (*MessageValue) Reset 

func (x *MessageValue) Reset()

func (*MessageValue) SizeVT added in v0.12.0 

func (m *MessageValue) SizeVT() (n int)

func (*MessageValue) String 

func (x *MessageValue) String() string

func (*MessageValue) UnmarshalVT added in v0.12.0 

func (m *MessageValue) UnmarshalVT(dAtA []byte) error

func (*MessageValue) UnmarshalVTUnsafe added in v0.12.0 

func (m *MessageValue) UnmarshalVTUnsafe(dAtA []byte) error

type MethodRequest 

type MethodRequest struct {

	// field name of the request message.
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// by used to refer to a name or message argument defined in a MessageRule, use `$.` to refer to the message argument.
	// Use CEL (https://github.com/google/cel-spec) to evaluate the expression.
	// Variables are already defined in MessageRule can be used.
	By *string `protobuf:"bytes,2,opt,name=by,proto3,oneof" json:"by,omitempty"`
	// double literal value.
	Double *float64 `protobuf:"fixed64,3,opt,name=double,proto3,oneof" json:"double,omitempty"`
	// repeated double literal values.
	Doubles []float64 `protobuf:"fixed64,4,rep,packed,name=doubles,proto3" json:"doubles,omitempty"`
	// float literal value.
	Float *float32 `protobuf:"fixed32,5,opt,name=float,proto3,oneof" json:"float,omitempty"`
	// repeated float literal values.
	Floats []float32 `protobuf:"fixed32,6,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	// int32 literal value.
	Int32 *int32 `protobuf:"varint,7,opt,name=int32,proto3,oneof" json:"int32,omitempty"`
	// repeated int32 literal values.
	Int32S []int32 `protobuf:"varint,8,rep,packed,name=int32s,proto3" json:"int32s,omitempty"`
	// int64 literal value.
	Int64 *int64 `protobuf:"varint,9,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
	// repeated int64 literal values.
	Int64S []int64 `protobuf:"varint,10,rep,packed,name=int64s,proto3" json:"int64s,omitempty"`
	// uint32 literal value.
	Uint32 *uint32 `protobuf:"varint,11,opt,name=uint32,proto3,oneof" json:"uint32,omitempty"`
	// repeated uint32 literal values.
	Uint32S []uint32 `protobuf:"varint,12,rep,packed,name=uint32s,proto3" json:"uint32s,omitempty"`
	// uint64 literal value.
	Uint64 *uint64 `protobuf:"varint,13,opt,name=uint64,proto3,oneof" json:"uint64,omitempty"`
	// repeated uint64 literal values.
	Uint64S []uint64 `protobuf:"varint,14,rep,packed,name=uint64s,proto3" json:"uint64s,omitempty"`
	// sint32 literal value.
	Sint32 *int32 `protobuf:"zigzag32,15,opt,name=sint32,proto3,oneof" json:"sint32,omitempty"`
	// repeated sint32 literal values.
	Sint32S []int32 `protobuf:"zigzag32,16,rep,packed,name=sint32s,proto3" json:"sint32s,omitempty"`
	// sint64 literal value.
	Sint64 *int64 `protobuf:"zigzag64,17,opt,name=sint64,proto3,oneof" json:"sint64,omitempty"`
	// repeated sint64 literal values.
	Sint64S []int64 `protobuf:"zigzag64,18,rep,packed,name=sint64s,proto3" json:"sint64s,omitempty"`
	// fixed32 literal value.
	Fixed32 *uint32 `protobuf:"fixed32,19,opt,name=fixed32,proto3,oneof" json:"fixed32,omitempty"`
	// repeated fixed32 literal values.
	Fixed32S []uint32 `protobuf:"fixed32,20,rep,packed,name=fixed32s,proto3" json:"fixed32s,omitempty"`
	// fixed64 literal value.
	Fixed64 *uint64 `protobuf:"fixed64,21,opt,name=fixed64,proto3,oneof" json:"fixed64,omitempty"`
	// repeated fixed64 literal values.
	Fixed64S []uint64 `protobuf:"fixed64,22,rep,packed,name=fixed64s,proto3" json:"fixed64s,omitempty"`
	// sfixed32 literal value.
	Sfixed32 *int32 `protobuf:"fixed32,23,opt,name=sfixed32,proto3,oneof" json:"sfixed32,omitempty"`
	// repeated sfixed32 literal values.
	Sfixed32S []int32 `protobuf:"fixed32,24,rep,packed,name=sfixed32s,proto3" json:"sfixed32s,omitempty"`
	// sfixed64 literal value.
	Sfixed64 *int64 `protobuf:"fixed64,25,opt,name=sfixed64,proto3,oneof" json:"sfixed64,omitempty"`
	// repeated sfixed64 literal values.
	Sfixed64S []int64 `protobuf:"fixed64,26,rep,packed,name=sfixed64s,proto3" json:"sfixed64s,omitempty"`
	// bool literal value.
	Bool *bool `protobuf:"varint,27,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
	// repeated bool literal values.
	Bools []bool `protobuf:"varint,28,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	// string literal value.
	String_ *string `protobuf:"bytes,29,opt,name=string,proto3,oneof" json:"string,omitempty"`
	// repeated string literal values.
	Strings []string `protobuf:"bytes,30,rep,name=strings,proto3" json:"strings,omitempty"`
	// bytes literal value.
	ByteString []byte `protobuf:"bytes,31,opt,name=byte_string,json=byteString,proto3,oneof" json:"byte_string,omitempty"`
	// repeated bytes literal values.
	ByteStrings [][]byte `protobuf:"bytes,32,rep,name=byte_strings,json=byteStrings,proto3" json:"byte_strings,omitempty"`
	// message literal value.
	Message *MessageValue `protobuf:"bytes,33,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// repeated message literal values.
	Messages []*MessageValue `protobuf:"bytes,34,rep,name=messages,proto3" json:"messages,omitempty"`
	// enum literal value.
	Enum *string `protobuf:"bytes,35,opt,name=enum,proto3,oneof" json:"enum,omitempty"`
	// repeated enum literal values.
	Enums []string `protobuf:"bytes,36,rep,name=enums,proto3" json:"enums,omitempty"`
	// env literal value.
	Env *string `protobuf:"bytes,37,opt,name=env,proto3,oneof" json:"env,omitempty"`
	// repeated env literal values.
	Envs []string `protobuf:"bytes,38,rep,name=envs,proto3" json:"envs,omitempty"`
	// contains filtered or unexported fields
}

MethodRequest define parameters to be used for gRPC method request.

func (*MethodRequest) CloneMessageVT added in v0.12.0 

func (m *MethodRequest) CloneMessageVT() proto.Message

func (*MethodRequest) CloneVT added in v0.12.0 

func (m *MethodRequest) CloneVT() *MethodRequest

func (*MethodRequest) Descriptor deprecated 

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

Deprecated: Use MethodRequest.ProtoReflect.Descriptor instead.

func (*MethodRequest) EqualMessageVT added in v0.12.0 

func (this *MethodRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*MethodRequest) EqualVT added in v0.12.0 

func (this *MethodRequest) EqualVT(that *MethodRequest) bool

func (*MethodRequest) GetBool 

func (x *MethodRequest) GetBool() bool

func (*MethodRequest) GetBools 

func (x *MethodRequest) GetBools() []bool

func (*MethodRequest) GetBy 

func (x *MethodRequest) GetBy() string

func (*MethodRequest) GetByteString 

func (x *MethodRequest) GetByteString() []byte

func (*MethodRequest) GetByteStrings 

func (x *MethodRequest) GetByteStrings() [][]byte

func (*MethodRequest) GetDouble 

func (x *MethodRequest) GetDouble() float64

func (*MethodRequest) GetDoubles 

func (x *MethodRequest) GetDoubles() []float64

func (*MethodRequest) GetEnum 

func (x *MethodRequest) GetEnum() string

func (*MethodRequest) GetEnums 

func (x *MethodRequest) GetEnums() []string

func (*MethodRequest) GetEnv 

func (x *MethodRequest) GetEnv() string

func (*MethodRequest) GetEnvs 

func (x *MethodRequest) GetEnvs() []string

func (*MethodRequest) GetField 

func (x *MethodRequest) GetField() string

func (*MethodRequest) GetFixed32 

func (x *MethodRequest) GetFixed32() uint32

func (*MethodRequest) GetFixed32S 

func (x *MethodRequest) GetFixed32S() []uint32

func (*MethodRequest) GetFixed64 

func (x *MethodRequest) GetFixed64() uint64

func (*MethodRequest) GetFixed64S 

func (x *MethodRequest) GetFixed64S() []uint64

func (*MethodRequest) GetFloat 

func (x *MethodRequest) GetFloat() float32

func (*MethodRequest) GetFloats 

func (x *MethodRequest) GetFloats() []float32

func (*MethodRequest) GetInt32 

func (x *MethodRequest) GetInt32() int32

func (*MethodRequest) GetInt32S 

func (x *MethodRequest) GetInt32S() []int32

func (*MethodRequest) GetInt64 

func (x *MethodRequest) GetInt64() int64

func (*MethodRequest) GetInt64S 

func (x *MethodRequest) GetInt64S() []int64

func (*MethodRequest) GetMessage 

func (x *MethodRequest) GetMessage() *MessageValue

func (*MethodRequest) GetMessages 

func (x *MethodRequest) GetMessages() []*MessageValue

func (*MethodRequest) GetSfixed32 

func (x *MethodRequest) GetSfixed32() int32

func (*MethodRequest) GetSfixed32S 

func (x *MethodRequest) GetSfixed32S() []int32

func (*MethodRequest) GetSfixed64 

func (x *MethodRequest) GetSfixed64() int64

func (*MethodRequest) GetSfixed64S 

func (x *MethodRequest) GetSfixed64S() []int64

func (*MethodRequest) GetSint32 

func (x *MethodRequest) GetSint32() int32

func (*MethodRequest) GetSint32S 

func (x *MethodRequest) GetSint32S() []int32

func (*MethodRequest) GetSint64 

func (x *MethodRequest) GetSint64() int64

func (*MethodRequest) GetSint64S 

func (x *MethodRequest) GetSint64S() []int64

func (*MethodRequest) GetString_ 

func (x *MethodRequest) GetString_() string

func (*MethodRequest) GetStrings 

func (x *MethodRequest) GetStrings() []string

func (*MethodRequest) GetUint32 

func (x *MethodRequest) GetUint32() uint32

func (*MethodRequest) GetUint32S 

func (x *MethodRequest) GetUint32S() []uint32

func (*MethodRequest) GetUint64 

func (x *MethodRequest) GetUint64() uint64

func (*MethodRequest) GetUint64S 

func (x *MethodRequest) GetUint64S() []uint64

func (*MethodRequest) MarshalToSizedBufferVT added in v0.12.0 

func (m *MethodRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MethodRequest) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MethodRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MethodRequest) MarshalToVT added in v0.12.0 

func (m *MethodRequest) MarshalToVT(dAtA []byte) (int, error)

func (*MethodRequest) MarshalToVTStrict added in v0.12.0 

func (m *MethodRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MethodRequest) MarshalVT added in v0.12.0 

func (m *MethodRequest) MarshalVT() (dAtA []byte, err error)

func (*MethodRequest) MarshalVTStrict added in v0.12.0 

func (m *MethodRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*MethodRequest) ProtoMessage 

func (*MethodRequest) ProtoMessage()

func (*MethodRequest) ProtoReflect 

func (x *MethodRequest) ProtoReflect() protoreflect.Message

func (*MethodRequest) Reset 

func (x *MethodRequest) Reset()

func (*MethodRequest) SizeVT added in v0.12.0 

func (m *MethodRequest) SizeVT() (n int)

func (*MethodRequest) String 

func (x *MethodRequest) String() string

func (*MethodRequest) UnmarshalVT added in v0.12.0 

func (m *MethodRequest) UnmarshalVT(dAtA []byte) error

func (*MethodRequest) UnmarshalVTUnsafe added in v0.12.0 

func (m *MethodRequest) UnmarshalVTUnsafe(dAtA []byte) error

type MethodResponse 

type MethodResponse struct {

	// name specify the unique name that can be used in a `MessageRule` / `FieldRule` for the same message for a specific field in the response.
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// field name in response message.
	Field *string `protobuf:"bytes,2,opt,name=field,proto3,oneof" json:"field,omitempty"`
	// autobind if the value referenced by `field` is a message type,
	// the value of a field with the same name and type as the field name of its own message is automatically assigned to the value of the field in the message.
	// If multiple autobinds are used at the same message,
	// you must explicitly use the `grpc.federation.field` option to do the binding yourself, since duplicate field names cannot be correctly determined as one.
	Autobind *bool `protobuf:"varint,3,opt,name=autobind,proto3,oneof" json:"autobind,omitempty"`
	// contains filtered or unexported fields
}

MethodResponse define which value of the method response is referenced.

func (*MethodResponse) CloneMessageVT added in v0.12.0 

func (m *MethodResponse) CloneMessageVT() proto.Message

func (*MethodResponse) CloneVT added in v0.12.0 

func (m *MethodResponse) CloneVT() *MethodResponse

func (*MethodResponse) Descriptor deprecated 

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

Deprecated: Use MethodResponse.ProtoReflect.Descriptor instead.

func (*MethodResponse) EqualMessageVT added in v0.12.0 

func (this *MethodResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*MethodResponse) EqualVT added in v0.12.0 

func (this *MethodResponse) EqualVT(that *MethodResponse) bool

func (*MethodResponse) GetAutobind 

func (x *MethodResponse) GetAutobind() bool

func (*MethodResponse) GetField 

func (x *MethodResponse) GetField() string

func (*MethodResponse) GetName 

func (x *MethodResponse) GetName() string

func (*MethodResponse) MarshalToSizedBufferVT added in v0.12.0 

func (m *MethodResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MethodResponse) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MethodResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MethodResponse) MarshalToVT added in v0.12.0 

func (m *MethodResponse) MarshalToVT(dAtA []byte) (int, error)

func (*MethodResponse) MarshalToVTStrict added in v0.12.0 

func (m *MethodResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MethodResponse) MarshalVT added in v0.12.0 

func (m *MethodResponse) MarshalVT() (dAtA []byte, err error)

func (*MethodResponse) MarshalVTStrict added in v0.12.0 

func (m *MethodResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*MethodResponse) ProtoMessage 

func (*MethodResponse) ProtoMessage()

func (*MethodResponse) ProtoReflect 

func (x *MethodResponse) ProtoReflect() protoreflect.Message

func (*MethodResponse) Reset 

func (x *MethodResponse) Reset()

func (*MethodResponse) SizeVT added in v0.12.0 

func (m *MethodResponse) SizeVT() (n int)

func (*MethodResponse) String 

func (x *MethodResponse) String() string

func (*MethodResponse) UnmarshalVT added in v0.12.0 

func (m *MethodResponse) UnmarshalVT(dAtA []byte) error

func (*MethodResponse) UnmarshalVTUnsafe added in v0.12.0 

func (m *MethodResponse) UnmarshalVTUnsafe(dAtA []byte) error

type MethodRule 

type MethodRule struct {

	// the time to timeout. If the specified time period elapses, DEADLINE_EXCEEDED status is returned.
	// If you want to handle this error, you need to implement a custom error handler in Go.
	// The format is the same as Go's time.Duration format. See https://pkg.go.dev/time#ParseDuration.
	Timeout *string `protobuf:"bytes,1,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*MethodRule) CloneMessageVT added in v0.12.0 

func (m *MethodRule) CloneMessageVT() proto.Message

func (*MethodRule) CloneVT added in v0.12.0 

func (m *MethodRule) CloneVT() *MethodRule

func (*MethodRule) Descriptor deprecated 

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

Deprecated: Use MethodRule.ProtoReflect.Descriptor instead.

func (*MethodRule) EqualMessageVT added in v0.12.0 

func (this *MethodRule) EqualMessageVT(thatMsg proto.Message) bool

func (*MethodRule) EqualVT added in v0.12.0 

func (this *MethodRule) EqualVT(that *MethodRule) bool

func (*MethodRule) GetTimeout 

func (x *MethodRule) GetTimeout() string

func (*MethodRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *MethodRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MethodRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *MethodRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*MethodRule) MarshalToVT added in v0.12.0 

func (m *MethodRule) MarshalToVT(dAtA []byte) (int, error)

func (*MethodRule) MarshalToVTStrict added in v0.12.0 

func (m *MethodRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*MethodRule) MarshalVT added in v0.12.0 

func (m *MethodRule) MarshalVT() (dAtA []byte, err error)

func (*MethodRule) MarshalVTStrict added in v0.12.0 

func (m *MethodRule) MarshalVTStrict() (dAtA []byte, err error)

func (*MethodRule) ProtoMessage 

func (*MethodRule) ProtoMessage()

func (*MethodRule) ProtoReflect 

func (x *MethodRule) ProtoReflect() protoreflect.Message

func (*MethodRule) Reset 

func (x *MethodRule) Reset()

func (*MethodRule) SizeVT added in v0.12.0 

func (m *MethodRule) SizeVT() (n int)

func (*MethodRule) String 

func (x *MethodRule) String() string

func (*MethodRule) UnmarshalVT added in v0.12.0 

func (m *MethodRule) UnmarshalVT(dAtA []byte) error

func (*MethodRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *MethodRule) UnmarshalVTUnsafe(dAtA []byte) error

type OneofRule 

type OneofRule struct {
	// contains filtered or unexported fields
}

func (*OneofRule) CloneMessageVT added in v0.12.0 

func (m *OneofRule) CloneMessageVT() proto.Message

func (*OneofRule) CloneVT added in v0.12.0 

func (m *OneofRule) CloneVT() *OneofRule

func (*OneofRule) Descriptor deprecated 

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

Deprecated: Use OneofRule.ProtoReflect.Descriptor instead.

func (*OneofRule) EqualMessageVT added in v0.12.0 

func (this *OneofRule) EqualMessageVT(thatMsg proto.Message) bool

func (*OneofRule) EqualVT added in v0.12.0 

func (this *OneofRule) EqualVT(that *OneofRule) bool

func (*OneofRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *OneofRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OneofRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *OneofRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*OneofRule) MarshalToVT added in v0.12.0 

func (m *OneofRule) MarshalToVT(dAtA []byte) (int, error)

func (*OneofRule) MarshalToVTStrict added in v0.12.0 

func (m *OneofRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*OneofRule) MarshalVT added in v0.12.0 

func (m *OneofRule) MarshalVT() (dAtA []byte, err error)

func (*OneofRule) MarshalVTStrict added in v0.12.0 

func (m *OneofRule) MarshalVTStrict() (dAtA []byte, err error)

func (*OneofRule) ProtoMessage 

func (*OneofRule) ProtoMessage()

func (*OneofRule) ProtoReflect 

func (x *OneofRule) ProtoReflect() protoreflect.Message

func (*OneofRule) Reset 

func (x *OneofRule) Reset()

func (*OneofRule) SizeVT added in v0.12.0 

func (m *OneofRule) SizeVT() (n int)

func (*OneofRule) String 

func (x *OneofRule) String() string

func (*OneofRule) UnmarshalVT added in v0.12.0 

func (m *OneofRule) UnmarshalVT(dAtA []byte) error

func (*OneofRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *OneofRule) UnmarshalVTUnsafe(dAtA []byte) error

type PluginRule added in v0.10.0 

type PluginRule struct {
	Export []*Export `protobuf:"bytes,1,rep,name=export,proto3" json:"export,omitempty"`
	// contains filtered or unexported fields
}

PluginRule define schema of CEL plugin.

func (*PluginRule) CloneMessageVT added in v0.12.0 

func (m *PluginRule) CloneMessageVT() proto.Message

func (*PluginRule) CloneVT added in v0.12.0 

func (m *PluginRule) CloneVT() *PluginRule

func (*PluginRule) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use PluginRule.ProtoReflect.Descriptor instead.

func (*PluginRule) EqualMessageVT added in v0.12.0 

func (this *PluginRule) EqualMessageVT(thatMsg proto.Message) bool

func (*PluginRule) EqualVT added in v0.12.0 

func (this *PluginRule) EqualVT(that *PluginRule) bool

func (*PluginRule) GetExport added in v0.10.0 

func (x *PluginRule) GetExport() []*Export

func (*PluginRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *PluginRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PluginRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *PluginRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*PluginRule) MarshalToVT added in v0.12.0 

func (m *PluginRule) MarshalToVT(dAtA []byte) (int, error)

func (*PluginRule) MarshalToVTStrict added in v0.12.0 

func (m *PluginRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*PluginRule) MarshalVT added in v0.12.0 

func (m *PluginRule) MarshalVT() (dAtA []byte, err error)

func (*PluginRule) MarshalVTStrict added in v0.12.0 

func (m *PluginRule) MarshalVTStrict() (dAtA []byte, err error)

func (*PluginRule) ProtoMessage added in v0.10.0 

func (*PluginRule) ProtoMessage()

func (*PluginRule) ProtoReflect added in v0.10.0 

func (x *PluginRule) ProtoReflect() protoreflect.Message

func (*PluginRule) Reset added in v0.10.0 

func (x *PluginRule) Reset()

func (*PluginRule) SizeVT added in v0.12.0 

func (m *PluginRule) SizeVT() (n int)

func (*PluginRule) String added in v0.10.0 

func (x *PluginRule) String() string

func (*PluginRule) UnmarshalVT added in v0.12.0 

func (m *PluginRule) UnmarshalVT(dAtA []byte) error

func (*PluginRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *PluginRule) UnmarshalVTUnsafe(dAtA []byte) error

type PreconditionFailureViolation added in v0.10.0 

type PreconditionFailureViolation struct {
	Type    string
	Subject string
	Desc    string
}

type ProtoMessage added in v0.10.0 

type ProtoMessage = protoadapt.MessageV1

type RWMutex added in v0.10.0 

type RWMutex = sync.RWMutex

type ReceiverType added in v0.10.0 

type ReceiverType struct {

	// name is the message name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// desc is the description of plugin.
	// This description is used as documentation at code generation.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// methods describe the definition of the method for the message.
	Methods []*CELFunction `protobuf:"bytes,3,rep,name=methods,proto3" json:"methods,omitempty"`
	// contains filtered or unexported fields
}

ReceiverType represents methods tied to the message.

func (*ReceiverType) CloneMessageVT added in v0.12.0 

func (m *ReceiverType) CloneMessageVT() proto.Message

func (*ReceiverType) CloneVT added in v0.12.0 

func (m *ReceiverType) CloneVT() *ReceiverType

func (*ReceiverType) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use ReceiverType.ProtoReflect.Descriptor instead.

func (*ReceiverType) EqualMessageVT added in v0.12.0 

func (this *ReceiverType) EqualMessageVT(thatMsg proto.Message) bool

func (*ReceiverType) EqualVT added in v0.12.0 

func (this *ReceiverType) EqualVT(that *ReceiverType) bool

func (*ReceiverType) GetDesc added in v0.10.0 

func (x *ReceiverType) GetDesc() string

func (*ReceiverType) GetMethods added in v0.10.0 

func (x *ReceiverType) GetMethods() []*CELFunction

func (*ReceiverType) GetName added in v0.10.0 

func (x *ReceiverType) GetName() string

func (*ReceiverType) MarshalToSizedBufferVT added in v0.12.0 

func (m *ReceiverType) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReceiverType) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ReceiverType) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ReceiverType) MarshalToVT added in v0.12.0 

func (m *ReceiverType) MarshalToVT(dAtA []byte) (int, error)

func (*ReceiverType) MarshalToVTStrict added in v0.12.0 

func (m *ReceiverType) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ReceiverType) MarshalVT added in v0.12.0 

func (m *ReceiverType) MarshalVT() (dAtA []byte, err error)

func (*ReceiverType) MarshalVTStrict added in v0.12.0 

func (m *ReceiverType) MarshalVTStrict() (dAtA []byte, err error)

func (*ReceiverType) ProtoMessage added in v0.10.0 

func (*ReceiverType) ProtoMessage()

func (*ReceiverType) ProtoReflect added in v0.10.0 

func (x *ReceiverType) ProtoReflect() protoreflect.Message

func (*ReceiverType) Reset added in v0.10.0 

func (x *ReceiverType) Reset()

func (*ReceiverType) SizeVT added in v0.12.0 

func (m *ReceiverType) SizeVT() (n int)

func (*ReceiverType) String added in v0.10.0 

func (x *ReceiverType) String() string

func (*ReceiverType) UnmarshalVT added in v0.12.0 

func (m *ReceiverType) UnmarshalVT(dAtA []byte) error

func (*ReceiverType) UnmarshalVTUnsafe added in v0.12.0 

func (m *ReceiverType) UnmarshalVTUnsafe(dAtA []byte) error

type RecoveredError added in v0.4.0 

type RecoveredError struct {
	Message string
	Stack   []string
}

RecoveredError represents recovered error.

func RecoverError added in v0.4.0 

func RecoverError(v interface{}, rawStack []byte) *RecoveredError

func (*RecoveredError) Error added in v0.4.0 

func (e *RecoveredError) Error() string

type RetryPolicy 

type RetryPolicy struct {

	// Types that are assignable to Policy:
	//
	//	*RetryPolicy_Constant
	//	*RetryPolicy_Exponential
	Policy isRetryPolicy_Policy `protobuf_oneof:"policy"`
	// contains filtered or unexported fields
}

RetryPolicy define the retry policy if the method call fails.

func (*RetryPolicy) CloneMessageVT added in v0.12.0 

func (m *RetryPolicy) CloneMessageVT() proto.Message

func (*RetryPolicy) CloneVT added in v0.12.0 

func (m *RetryPolicy) CloneVT() *RetryPolicy

func (*RetryPolicy) Descriptor deprecated 

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

Deprecated: Use RetryPolicy.ProtoReflect.Descriptor instead.

func (*RetryPolicy) EqualMessageVT added in v0.12.0 

func (this *RetryPolicy) EqualMessageVT(thatMsg proto.Message) bool

func (*RetryPolicy) EqualVT added in v0.12.0 

func (this *RetryPolicy) EqualVT(that *RetryPolicy) bool

func (*RetryPolicy) GetConstant 

func (x *RetryPolicy) GetConstant() *RetryPolicyConstant

func (*RetryPolicy) GetExponential 

func (x *RetryPolicy) GetExponential() *RetryPolicyExponential

func (*RetryPolicy) GetPolicy 

func (m *RetryPolicy) GetPolicy() isRetryPolicy_Policy

func (*RetryPolicy) MarshalToSizedBufferVT added in v0.12.0 

func (m *RetryPolicy) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RetryPolicy) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *RetryPolicy) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy) MarshalToVT added in v0.12.0 

func (m *RetryPolicy) MarshalToVT(dAtA []byte) (int, error)

func (*RetryPolicy) MarshalToVTStrict added in v0.12.0 

func (m *RetryPolicy) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy) MarshalVT added in v0.12.0 

func (m *RetryPolicy) MarshalVT() (dAtA []byte, err error)

func (*RetryPolicy) MarshalVTStrict added in v0.12.0 

func (m *RetryPolicy) MarshalVTStrict() (dAtA []byte, err error)

func (*RetryPolicy) ProtoMessage 

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) ProtoReflect 

func (x *RetryPolicy) ProtoReflect() protoreflect.Message

func (*RetryPolicy) Reset 

func (x *RetryPolicy) Reset()

func (*RetryPolicy) SizeVT added in v0.12.0 

func (m *RetryPolicy) SizeVT() (n int)

func (*RetryPolicy) String 

func (x *RetryPolicy) String() string

func (*RetryPolicy) UnmarshalVT added in v0.12.0 

func (m *RetryPolicy) UnmarshalVT(dAtA []byte) error

func (*RetryPolicy) UnmarshalVTUnsafe added in v0.12.0 

func (m *RetryPolicy) UnmarshalVTUnsafe(dAtA []byte) error

type RetryPolicyConstant 

type RetryPolicyConstant struct {

	// interval value. ( default value is 1s ).
	Interval *string `protobuf:"bytes,1,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
	// max retry count. ( default value is 5. If zero is specified, it never stops )
	MaxRetries *uint64 `protobuf:"varint,2,opt,name=max_retries,json=maxRetries,proto3,oneof" json:"max_retries,omitempty"`
	// contains filtered or unexported fields
}

RetryPolicyConstant define "constant" based retry policy.

func (*RetryPolicyConstant) CloneMessageVT added in v0.12.0 

func (m *RetryPolicyConstant) CloneMessageVT() proto.Message

func (*RetryPolicyConstant) CloneVT added in v0.12.0 

func (m *RetryPolicyConstant) CloneVT() *RetryPolicyConstant

func (*RetryPolicyConstant) Descriptor deprecated 

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

Deprecated: Use RetryPolicyConstant.ProtoReflect.Descriptor instead.

func (*RetryPolicyConstant) EqualMessageVT added in v0.12.0 

func (this *RetryPolicyConstant) EqualMessageVT(thatMsg proto.Message) bool

func (*RetryPolicyConstant) EqualVT added in v0.12.0 

func (this *RetryPolicyConstant) EqualVT(that *RetryPolicyConstant) bool

func (*RetryPolicyConstant) GetInterval 

func (x *RetryPolicyConstant) GetInterval() string

func (*RetryPolicyConstant) GetMaxRetries 

func (x *RetryPolicyConstant) GetMaxRetries() uint64

func (*RetryPolicyConstant) MarshalToSizedBufferVT added in v0.12.0 

func (m *RetryPolicyConstant) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RetryPolicyConstant) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *RetryPolicyConstant) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RetryPolicyConstant) MarshalToVT added in v0.12.0 

func (m *RetryPolicyConstant) MarshalToVT(dAtA []byte) (int, error)

func (*RetryPolicyConstant) MarshalToVTStrict added in v0.12.0 

func (m *RetryPolicyConstant) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RetryPolicyConstant) MarshalVT added in v0.12.0 

func (m *RetryPolicyConstant) MarshalVT() (dAtA []byte, err error)

func (*RetryPolicyConstant) MarshalVTStrict added in v0.12.0 

func (m *RetryPolicyConstant) MarshalVTStrict() (dAtA []byte, err error)

func (*RetryPolicyConstant) ProtoMessage 

func (*RetryPolicyConstant) ProtoMessage()

func (*RetryPolicyConstant) ProtoReflect 

func (x *RetryPolicyConstant) ProtoReflect() protoreflect.Message

func (*RetryPolicyConstant) Reset 

func (x *RetryPolicyConstant) Reset()

func (*RetryPolicyConstant) SizeVT added in v0.12.0 

func (m *RetryPolicyConstant) SizeVT() (n int)

func (*RetryPolicyConstant) String 

func (x *RetryPolicyConstant) String() string

func (*RetryPolicyConstant) UnmarshalVT added in v0.12.0 

func (m *RetryPolicyConstant) UnmarshalVT(dAtA []byte) error

func (*RetryPolicyConstant) UnmarshalVTUnsafe added in v0.12.0 

func (m *RetryPolicyConstant) UnmarshalVTUnsafe(dAtA []byte) error

type RetryPolicyExponential 

type RetryPolicyExponential struct {

	// initial interval value. ( default value is "500ms" ).
	InitialInterval *string `protobuf:"bytes,1,opt,name=initial_interval,json=initialInterval,proto3,oneof" json:"initial_interval,omitempty"`
	// randomization factor value. ( default value is 0.5 ).
	RandomizationFactor *float64 `` /* 126-byte string literal not displayed */
	// multiplier. ( default value is 1.5 ).
	Multiplier *float64 `protobuf:"fixed64,3,opt,name=multiplier,proto3,oneof" json:"multiplier,omitempty"`
	// max interval value. ( default value is "60s" ).
	MaxInterval *string `protobuf:"bytes,4,opt,name=max_interval,json=maxInterval,proto3,oneof" json:"max_interval,omitempty"`
	// max retry count. ( default value is 5. If zero is specified, it never stops ).
	MaxRetries *uint64 `protobuf:"varint,5,opt,name=max_retries,json=maxRetries,proto3,oneof" json:"max_retries,omitempty"`
	// contains filtered or unexported fields
}

RetryPolicyExponential define "exponential backoff" based retry policy.

func (*RetryPolicyExponential) CloneMessageVT added in v0.12.0 

func (m *RetryPolicyExponential) CloneMessageVT() proto.Message

func (*RetryPolicyExponential) CloneVT added in v0.12.0 

func (m *RetryPolicyExponential) CloneVT() *RetryPolicyExponential

func (*RetryPolicyExponential) Descriptor deprecated 

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

Deprecated: Use RetryPolicyExponential.ProtoReflect.Descriptor instead.

func (*RetryPolicyExponential) EqualMessageVT added in v0.12.0 

func (this *RetryPolicyExponential) EqualMessageVT(thatMsg proto.Message) bool

func (*RetryPolicyExponential) EqualVT added in v0.12.0 

func (this *RetryPolicyExponential) EqualVT(that *RetryPolicyExponential) bool

func (*RetryPolicyExponential) GetInitialInterval 

func (x *RetryPolicyExponential) GetInitialInterval() string

func (*RetryPolicyExponential) GetMaxInterval 

func (x *RetryPolicyExponential) GetMaxInterval() string

func (*RetryPolicyExponential) GetMaxRetries 

func (x *RetryPolicyExponential) GetMaxRetries() uint64

func (*RetryPolicyExponential) GetMultiplier 

func (x *RetryPolicyExponential) GetMultiplier() float64

func (*RetryPolicyExponential) GetRandomizationFactor 

func (x *RetryPolicyExponential) GetRandomizationFactor() float64

func (*RetryPolicyExponential) MarshalToSizedBufferVT added in v0.12.0 

func (m *RetryPolicyExponential) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RetryPolicyExponential) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *RetryPolicyExponential) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RetryPolicyExponential) MarshalToVT added in v0.12.0 

func (m *RetryPolicyExponential) MarshalToVT(dAtA []byte) (int, error)

func (*RetryPolicyExponential) MarshalToVTStrict added in v0.12.0 

func (m *RetryPolicyExponential) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RetryPolicyExponential) MarshalVT added in v0.12.0 

func (m *RetryPolicyExponential) MarshalVT() (dAtA []byte, err error)

func (*RetryPolicyExponential) MarshalVTStrict added in v0.12.0 

func (m *RetryPolicyExponential) MarshalVTStrict() (dAtA []byte, err error)

func (*RetryPolicyExponential) ProtoMessage 

func (*RetryPolicyExponential) ProtoMessage()

func (*RetryPolicyExponential) ProtoReflect 

func (x *RetryPolicyExponential) ProtoReflect() protoreflect.Message

func (*RetryPolicyExponential) Reset 

func (x *RetryPolicyExponential) Reset()

func (*RetryPolicyExponential) SizeVT added in v0.12.0 

func (m *RetryPolicyExponential) SizeVT() (n int)

func (*RetryPolicyExponential) String 

func (x *RetryPolicyExponential) String() string

func (*RetryPolicyExponential) UnmarshalVT added in v0.12.0 

func (m *RetryPolicyExponential) UnmarshalVT(dAtA []byte) error

func (*RetryPolicyExponential) UnmarshalVTUnsafe added in v0.12.0 

func (m *RetryPolicyExponential) UnmarshalVTUnsafe(dAtA []byte) error

type RetryPolicy_Constant 

type RetryPolicy_Constant struct {
	// retry according to the "constant" policy.
	Constant *RetryPolicyConstant `protobuf:"bytes,1,opt,name=constant,proto3,oneof"`
}

func (*RetryPolicy_Constant) CloneVT added in v0.12.0 

func (m *RetryPolicy_Constant) CloneVT() isRetryPolicy_Policy

func (*RetryPolicy_Constant) EqualVT added in v0.12.0 

func (this *RetryPolicy_Constant) EqualVT(thatIface isRetryPolicy_Policy) bool

func (*RetryPolicy_Constant) MarshalToSizedBufferVT added in v0.12.0 

func (m *RetryPolicy_Constant) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RetryPolicy_Constant) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *RetryPolicy_Constant) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy_Constant) MarshalToVT added in v0.12.0 

func (m *RetryPolicy_Constant) MarshalToVT(dAtA []byte) (int, error)

func (*RetryPolicy_Constant) MarshalToVTStrict added in v0.12.0 

func (m *RetryPolicy_Constant) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy_Constant) SizeVT added in v0.12.0 

func (m *RetryPolicy_Constant) SizeVT() (n int)

type RetryPolicy_Exponential 

type RetryPolicy_Exponential struct {
	// retry according to the "exponential backoff" policy.
	// The following Go library is used in the implementation,
	// so please refer to the library documentation for how to specify each parameter.
	// https://pkg.go.dev/github.com/cenkalti/backoff/v4#section-readme.
	Exponential *RetryPolicyExponential `protobuf:"bytes,2,opt,name=exponential,proto3,oneof"`
}

func (*RetryPolicy_Exponential) CloneVT added in v0.12.0 

func (m *RetryPolicy_Exponential) CloneVT() isRetryPolicy_Policy

func (*RetryPolicy_Exponential) EqualVT added in v0.12.0 

func (this *RetryPolicy_Exponential) EqualVT(thatIface isRetryPolicy_Policy) bool

func (*RetryPolicy_Exponential) MarshalToSizedBufferVT added in v0.12.0 

func (m *RetryPolicy_Exponential) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RetryPolicy_Exponential) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *RetryPolicy_Exponential) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy_Exponential) MarshalToVT added in v0.12.0 

func (m *RetryPolicy_Exponential) MarshalToVT(dAtA []byte) (int, error)

func (*RetryPolicy_Exponential) MarshalToVTStrict added in v0.12.0 

func (m *RetryPolicy_Exponential) MarshalToVTStrict(dAtA []byte) (int, error)

func (*RetryPolicy_Exponential) SizeVT added in v0.12.0 

func (m *RetryPolicy_Exponential) SizeVT() (n int)

type ReturnValue added in v0.10.0 

type ReturnValue uint64

func BoolToReturnValue added in v0.10.0 

func BoolToReturnValue(v bool) ReturnValue

func BytesToReturnValue added in v0.10.0 

func BytesToReturnValue(v []byte) ReturnValue

func ErrorToReturnValue added in v0.10.0 

func ErrorToReturnValue(err error) ReturnValue

func Float32ToReturnValue added in v0.10.0 

func Float32ToReturnValue(v float32) ReturnValue

func Float64ToReturnValue added in v0.10.0 

func Float64ToReturnValue(v float64) ReturnValue

func Int32ToReturnValue added in v0.10.0 

func Int32ToReturnValue(v int32) ReturnValue

func Int64ToReturnValue added in v0.10.0 

func Int64ToReturnValue(v int64) ReturnValue

func MessageToReturnValue added in v0.10.0 

func MessageToReturnValue[T any](v *T) ReturnValue

These are dummy APIs to compile plugin SDK at host context.

func StringToReturnValue added in v0.10.0 

func StringToReturnValue(v string) ReturnValue

func Uint32ToReturnValue added in v0.10.0 

func Uint32ToReturnValue(v uint32) ReturnValue

func Uint64ToReturnValue added in v0.10.0 

func Uint64ToReturnValue(v uint64) ReturnValue

type ServiceDependency 

type ServiceDependency struct {

	// name to be used when initializing the gRPC client.
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// service is the name of the dependent service.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

ServiceDependency assigns a uniquely determined name to the service.

func (*ServiceDependency) CloneMessageVT added in v0.12.0 

func (m *ServiceDependency) CloneMessageVT() proto.Message

func (*ServiceDependency) CloneVT added in v0.12.0 

func (m *ServiceDependency) CloneVT() *ServiceDependency

func (*ServiceDependency) Descriptor deprecated 

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

Deprecated: Use ServiceDependency.ProtoReflect.Descriptor instead.

func (*ServiceDependency) EqualMessageVT added in v0.12.0 

func (this *ServiceDependency) EqualMessageVT(thatMsg proto.Message) bool

func (*ServiceDependency) EqualVT added in v0.12.0 

func (this *ServiceDependency) EqualVT(that *ServiceDependency) bool

func (*ServiceDependency) GetName 

func (x *ServiceDependency) GetName() string

func (*ServiceDependency) GetService 

func (x *ServiceDependency) GetService() string

func (*ServiceDependency) MarshalToSizedBufferVT added in v0.12.0 

func (m *ServiceDependency) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ServiceDependency) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ServiceDependency) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ServiceDependency) MarshalToVT added in v0.12.0 

func (m *ServiceDependency) MarshalToVT(dAtA []byte) (int, error)

func (*ServiceDependency) MarshalToVTStrict added in v0.12.0 

func (m *ServiceDependency) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ServiceDependency) MarshalVT added in v0.12.0 

func (m *ServiceDependency) MarshalVT() (dAtA []byte, err error)

func (*ServiceDependency) MarshalVTStrict added in v0.12.0 

func (m *ServiceDependency) MarshalVTStrict() (dAtA []byte, err error)

func (*ServiceDependency) ProtoMessage 

func (*ServiceDependency) ProtoMessage()

func (*ServiceDependency) ProtoReflect 

func (x *ServiceDependency) ProtoReflect() protoreflect.Message

func (*ServiceDependency) Reset 

func (x *ServiceDependency) Reset()

func (*ServiceDependency) SizeVT added in v0.12.0 

func (m *ServiceDependency) SizeVT() (n int)

func (*ServiceDependency) String 

func (x *ServiceDependency) String() string

func (*ServiceDependency) UnmarshalVT added in v0.12.0 

func (m *ServiceDependency) UnmarshalVT(dAtA []byte) error

func (*ServiceDependency) UnmarshalVTUnsafe added in v0.12.0 

func (m *ServiceDependency) UnmarshalVTUnsafe(dAtA []byte) error

type ServiceRule 

type ServiceRule struct {

	// dependencies defines a unique name for all services on which federation service depends.
	// The name will be used when creating the gRPC client.
	Dependencies []*ServiceDependency `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

ServiceRule define gRPC Federation rules for the service.

func (*ServiceRule) CloneMessageVT added in v0.12.0 

func (m *ServiceRule) CloneMessageVT() proto.Message

func (*ServiceRule) CloneVT added in v0.12.0 

func (m *ServiceRule) CloneVT() *ServiceRule

func (*ServiceRule) Descriptor deprecated 

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

Deprecated: Use ServiceRule.ProtoReflect.Descriptor instead.

func (*ServiceRule) EqualMessageVT added in v0.12.0 

func (this *ServiceRule) EqualMessageVT(thatMsg proto.Message) bool

func (*ServiceRule) EqualVT added in v0.12.0 

func (this *ServiceRule) EqualVT(that *ServiceRule) bool

func (*ServiceRule) GetDependencies 

func (x *ServiceRule) GetDependencies() []*ServiceDependency

func (*ServiceRule) MarshalToSizedBufferVT added in v0.12.0 

func (m *ServiceRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ServiceRule) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ServiceRule) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ServiceRule) MarshalToVT added in v0.12.0 

func (m *ServiceRule) MarshalToVT(dAtA []byte) (int, error)

func (*ServiceRule) MarshalToVTStrict added in v0.12.0 

func (m *ServiceRule) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ServiceRule) MarshalVT added in v0.12.0 

func (m *ServiceRule) MarshalVT() (dAtA []byte, err error)

func (*ServiceRule) MarshalVTStrict added in v0.12.0 

func (m *ServiceRule) MarshalVTStrict() (dAtA []byte, err error)

func (*ServiceRule) ProtoMessage 

func (*ServiceRule) ProtoMessage()

func (*ServiceRule) ProtoReflect 

func (x *ServiceRule) ProtoReflect() protoreflect.Message

func (*ServiceRule) Reset 

func (x *ServiceRule) Reset()

func (*ServiceRule) SizeVT added in v0.12.0 

func (m *ServiceRule) SizeVT() (n int)

func (*ServiceRule) String 

func (x *ServiceRule) String() string

func (*ServiceRule) UnmarshalVT added in v0.12.0 

func (m *ServiceRule) UnmarshalVT(dAtA []byte) error

func (*ServiceRule) UnmarshalVTUnsafe added in v0.12.0 

func (m *ServiceRule) UnmarshalVTUnsafe(dAtA []byte) error

type ValidationError added in v0.3.3 

type ValidationError struct {

	// code is a gRPC status code for validation error.
	Code code.Code `protobuf:"varint,1,opt,name=code,proto3,enum=google.rpc.Code" json:"code,omitempty"`
	// message is a gRPC status message for validation error.
	// If omitted, the message will be auto-generated from the configurations.
	Message *string `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// if specifies validation rule in CEL.
	// If the condition is true, the validation returns an error.
	// The return value must always be of type boolean.
	// Either if or details must be specified.
	If *string `protobuf:"bytes,3,opt,name=if,proto3,oneof" json:"if,omitempty"`
	// details is a list of validation rules and error details.
	// If the validation fails, the corresponding error details are set.
	// Either if or details must be specified.
	Details []*ValidationErrorDetail `protobuf:"bytes,4,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

ValidationError represents a validation rule and validation error to be returned.

func (*ValidationError) CloneMessageVT added in v0.12.0 

func (m *ValidationError) CloneMessageVT() proto.Message

func (*ValidationError) CloneVT added in v0.12.0 

func (m *ValidationError) CloneVT() *ValidationError

func (*ValidationError) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use ValidationError.ProtoReflect.Descriptor instead.

func (*ValidationError) EqualMessageVT added in v0.12.0 

func (this *ValidationError) EqualMessageVT(thatMsg proto.Message) bool

func (*ValidationError) EqualVT added in v0.12.0 

func (this *ValidationError) EqualVT(that *ValidationError) bool

func (*ValidationError) GetCode added in v0.3.3 

func (x *ValidationError) GetCode() code.Code

func (*ValidationError) GetDetails added in v0.3.3 

func (x *ValidationError) GetDetails() []*ValidationErrorDetail

func (*ValidationError) GetIf added in v0.7.2 

func (x *ValidationError) GetIf() string

func (*ValidationError) GetMessage added in v0.3.3 

func (x *ValidationError) GetMessage() string

func (*ValidationError) MarshalToSizedBufferVT added in v0.12.0 

func (m *ValidationError) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidationError) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ValidationError) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ValidationError) MarshalToVT added in v0.12.0 

func (m *ValidationError) MarshalToVT(dAtA []byte) (int, error)

func (*ValidationError) MarshalToVTStrict added in v0.12.0 

func (m *ValidationError) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ValidationError) MarshalVT added in v0.12.0 

func (m *ValidationError) MarshalVT() (dAtA []byte, err error)

func (*ValidationError) MarshalVTStrict added in v0.12.0 

func (m *ValidationError) MarshalVTStrict() (dAtA []byte, err error)

func (*ValidationError) ProtoMessage added in v0.3.3 

func (*ValidationError) ProtoMessage()

func (*ValidationError) ProtoReflect added in v0.3.3 

func (x *ValidationError) ProtoReflect() protoreflect.Message

func (*ValidationError) Reset added in v0.3.3 

func (x *ValidationError) Reset()

func (*ValidationError) SizeVT added in v0.12.0 

func (m *ValidationError) SizeVT() (n int)

func (*ValidationError) String added in v0.3.3 

func (x *ValidationError) String() string

func (*ValidationError) UnmarshalVT added in v0.12.0 

func (m *ValidationError) UnmarshalVT(dAtA []byte) error

func (*ValidationError) UnmarshalVTUnsafe added in v0.12.0 

func (m *ValidationError) UnmarshalVTUnsafe(dAtA []byte) error

type ValidationErrorDetail added in v0.3.3 

type ValidationErrorDetail struct {

	// if specifies validation rule in CEL. If the condition is true, the validation returns an error.
	If string `protobuf:"bytes,1,opt,name=if,proto3" json:"if,omitempty"`
	// message represents arbitrary messages to describe the detail of the error.
	Message []*MessageExpr `protobuf:"bytes,2,rep,name=message,proto3" json:"message,omitempty"`
	// error_info describes the cause of the error with structured details.
	ErrorInfo []*errdetails.ErrorInfo `protobuf:"bytes,3,rep,name=error_info,json=errorInfo,proto3" json:"error_info,omitempty"`
	// retry_info describes when the clients can retry a failed request.
	RetryInfo []*errdetails.RetryInfo `protobuf:"bytes,4,rep,name=retry_info,json=retryInfo,proto3" json:"retry_info,omitempty"`
	// debug_info describes additional debugging info.
	DebugInfo []*errdetails.DebugInfo `protobuf:"bytes,5,rep,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
	// quota_failure describes how a quota check failed.
	QuotaFailure []*errdetails.QuotaFailure `protobuf:"bytes,6,rep,name=quota_failure,json=quotaFailure,proto3" json:"quota_failure,omitempty"`
	// precondition_failure describes what preconditions have failed.
	PreconditionFailure []*errdetails.PreconditionFailure `protobuf:"bytes,7,rep,name=precondition_failure,json=preconditionFailure,proto3" json:"precondition_failure,omitempty"`
	// bad_request describes violations in a client request.
	BadRequest []*errdetails.BadRequest `protobuf:"bytes,8,rep,name=bad_request,json=badRequest,proto3" json:"bad_request,omitempty"`
	// request_info contains metadata about the request that clients can attach.
	RequestInfo []*errdetails.RequestInfo `protobuf:"bytes,9,rep,name=request_info,json=requestInfo,proto3" json:"request_info,omitempty"`
	// resource_info describes the resource that is being accessed.
	ResourceInfo []*errdetails.ResourceInfo `protobuf:"bytes,10,rep,name=resource_info,json=resourceInfo,proto3" json:"resource_info,omitempty"`
	// help provides links to documentation or for performing an out of band action.
	Help []*errdetails.Help `protobuf:"bytes,11,rep,name=help,proto3" json:"help,omitempty"`
	// localized_message provides a localized error message that is safe to return to the user.
	LocalizedMessage []*errdetails.LocalizedMessage `protobuf:"bytes,12,rep,name=localized_message,json=localizedMessage,proto3" json:"localized_message,omitempty"`
	// contains filtered or unexported fields
}

ValidationErrorDetail represents a pair of validation rule and error details to be set.

func (*ValidationErrorDetail) CloneMessageVT added in v0.12.0 

func (m *ValidationErrorDetail) CloneMessageVT() proto.Message

func (*ValidationErrorDetail) CloneVT added in v0.12.0 

func (m *ValidationErrorDetail) CloneVT() *ValidationErrorDetail

func (*ValidationErrorDetail) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use ValidationErrorDetail.ProtoReflect.Descriptor instead.

func (*ValidationErrorDetail) EqualMessageVT added in v0.12.0 

func (this *ValidationErrorDetail) EqualMessageVT(thatMsg proto.Message) bool

func (*ValidationErrorDetail) EqualVT added in v0.12.0 

func (this *ValidationErrorDetail) EqualVT(that *ValidationErrorDetail) bool

func (*ValidationErrorDetail) GetBadRequest added in v0.3.3 

func (x *ValidationErrorDetail) GetBadRequest() []*errdetails.BadRequest

func (*ValidationErrorDetail) GetDebugInfo added in v0.3.3 

func (x *ValidationErrorDetail) GetDebugInfo() []*errdetails.DebugInfo

func (*ValidationErrorDetail) GetErrorInfo added in v0.3.3 

func (x *ValidationErrorDetail) GetErrorInfo() []*errdetails.ErrorInfo

func (*ValidationErrorDetail) GetHelp added in v0.3.3 

func (x *ValidationErrorDetail) GetHelp() []*errdetails.Help

func (*ValidationErrorDetail) GetIf added in v0.7.2 

func (x *ValidationErrorDetail) GetIf() string

func (*ValidationErrorDetail) GetLocalizedMessage added in v0.3.3 

func (x *ValidationErrorDetail) GetLocalizedMessage() []*errdetails.LocalizedMessage

func (*ValidationErrorDetail) GetMessage added in v0.7.0 

func (x *ValidationErrorDetail) GetMessage() []*MessageExpr

func (*ValidationErrorDetail) GetPreconditionFailure added in v0.3.3 

func (x *ValidationErrorDetail) GetPreconditionFailure() []*errdetails.PreconditionFailure

func (*ValidationErrorDetail) GetQuotaFailure added in v0.3.3 

func (x *ValidationErrorDetail) GetQuotaFailure() []*errdetails.QuotaFailure

func (*ValidationErrorDetail) GetRequestInfo added in v0.3.3 

func (x *ValidationErrorDetail) GetRequestInfo() []*errdetails.RequestInfo

func (*ValidationErrorDetail) GetResourceInfo added in v0.3.3 

func (x *ValidationErrorDetail) GetResourceInfo() []*errdetails.ResourceInfo

func (*ValidationErrorDetail) GetRetryInfo added in v0.3.3 

func (x *ValidationErrorDetail) GetRetryInfo() []*errdetails.RetryInfo

func (*ValidationErrorDetail) MarshalToSizedBufferVT added in v0.12.0 

func (m *ValidationErrorDetail) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidationErrorDetail) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ValidationErrorDetail) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ValidationErrorDetail) MarshalToVT added in v0.12.0 

func (m *ValidationErrorDetail) MarshalToVT(dAtA []byte) (int, error)

func (*ValidationErrorDetail) MarshalToVTStrict added in v0.12.0 

func (m *ValidationErrorDetail) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ValidationErrorDetail) MarshalVT added in v0.12.0 

func (m *ValidationErrorDetail) MarshalVT() (dAtA []byte, err error)

func (*ValidationErrorDetail) MarshalVTStrict added in v0.12.0 

func (m *ValidationErrorDetail) MarshalVTStrict() (dAtA []byte, err error)

func (*ValidationErrorDetail) ProtoMessage added in v0.3.3 

func (*ValidationErrorDetail) ProtoMessage()

func (*ValidationErrorDetail) ProtoReflect added in v0.3.3 

func (x *ValidationErrorDetail) ProtoReflect() protoreflect.Message

func (*ValidationErrorDetail) Reset added in v0.3.3 

func (x *ValidationErrorDetail) Reset()

func (*ValidationErrorDetail) SizeVT added in v0.12.0 

func (m *ValidationErrorDetail) SizeVT() (n int)

func (*ValidationErrorDetail) String added in v0.3.3 

func (x *ValidationErrorDetail) String() string

func (*ValidationErrorDetail) UnmarshalVT added in v0.12.0 

func (m *ValidationErrorDetail) UnmarshalVT(dAtA []byte) error

func (*ValidationErrorDetail) UnmarshalVTUnsafe added in v0.12.0 

func (m *ValidationErrorDetail) UnmarshalVTUnsafe(dAtA []byte) error

type ValidationExpr added in v0.7.0 

type ValidationExpr struct {

	// name is a unique name for the validation.
	// If set, the validation error type will be <message-name><name>Error.
	// If omitted, the validation error type will be ValidationError.
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// error defines the actual validation rules and an error to returned if the validation fails.
	Error *ValidationError `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Validation represents a validation rule against variables defined within the current scope.

func (*ValidationExpr) CloneMessageVT added in v0.12.0 

func (m *ValidationExpr) CloneMessageVT() proto.Message

func (*ValidationExpr) CloneVT added in v0.12.0 

func (m *ValidationExpr) CloneVT() *ValidationExpr

func (*ValidationExpr) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ValidationExpr.ProtoReflect.Descriptor instead.

func (*ValidationExpr) EqualMessageVT added in v0.12.0 

func (this *ValidationExpr) EqualMessageVT(thatMsg proto.Message) bool

func (*ValidationExpr) EqualVT added in v0.12.0 

func (this *ValidationExpr) EqualVT(that *ValidationExpr) bool

func (*ValidationExpr) GetError added in v0.7.0 

func (x *ValidationExpr) GetError() *ValidationError

func (*ValidationExpr) GetName added in v0.7.0 

func (x *ValidationExpr) GetName() string

func (*ValidationExpr) MarshalToSizedBufferVT added in v0.12.0 

func (m *ValidationExpr) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ValidationExpr) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *ValidationExpr) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ValidationExpr) MarshalToVT added in v0.12.0 

func (m *ValidationExpr) MarshalToVT(dAtA []byte) (int, error)

func (*ValidationExpr) MarshalToVTStrict added in v0.12.0 

func (m *ValidationExpr) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ValidationExpr) MarshalVT added in v0.12.0 

func (m *ValidationExpr) MarshalVT() (dAtA []byte, err error)

func (*ValidationExpr) MarshalVTStrict added in v0.12.0 

func (m *ValidationExpr) MarshalVTStrict() (dAtA []byte, err error)

func (*ValidationExpr) ProtoMessage added in v0.7.0 

func (*ValidationExpr) ProtoMessage()

func (*ValidationExpr) ProtoReflect added in v0.7.0 

func (x *ValidationExpr) ProtoReflect() protoreflect.Message

func (*ValidationExpr) Reset added in v0.7.0 

func (x *ValidationExpr) Reset()

func (*ValidationExpr) SizeVT added in v0.12.0 

func (m *ValidationExpr) SizeVT() (n int)

func (*ValidationExpr) String added in v0.7.0 

func (x *ValidationExpr) String() string

func (*ValidationExpr) UnmarshalVT added in v0.12.0 

func (m *ValidationExpr) UnmarshalVT(dAtA []byte) error

func (*ValidationExpr) UnmarshalVTUnsafe added in v0.12.0 

func (m *ValidationExpr) UnmarshalVTUnsafe(dAtA []byte) error

type VariableDefinition added in v0.6.0 

type VariableDefinition struct {

	// name is a variable name.
	// This name can be referenced in all CELs defined after itself in the same message.
	// It can also be referenced in `grpc.federation.field` option.
	Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// if specify the condition for evaluating expr.
	// this value evaluated by CEL and it must return a boolean value.
	// If the result of evaluation is `false`, the value assigned to name is the default value of the result of evaluation of `expr`.
	If *string `protobuf:"bytes,2,opt,name=if,proto3,oneof" json:"if,omitempty"`
	// autobind if the result value of `expr` is a message type,
	// the value of a field with the same name and type as the field name of its own message is automatically assigned to the value of the field in the message.
	// If multiple autobinds are used at the same message,
	// you must explicitly use the `grpc.federation.field` option to do the binding yourself, since duplicate field names cannot be correctly determined as one.
	Autobind *bool `protobuf:"varint,3,opt,name=autobind,proto3,oneof" json:"autobind,omitempty"`
	// expr specify the value to be assigned to name.
	//
	// Types that are assignable to Expr:
	//
	//	*VariableDefinition_By
	//	*VariableDefinition_Map
	//	*VariableDefinition_Message
	//	*VariableDefinition_Call
	//	*VariableDefinition_Validation
	Expr isVariableDefinition_Expr `protobuf_oneof:"expr"`
	// contains filtered or unexported fields
}

VariableDefinition represents variable definition.

func (*VariableDefinition) CloneMessageVT added in v0.12.0 

func (m *VariableDefinition) CloneMessageVT() proto.Message

func (*VariableDefinition) CloneVT added in v0.12.0 

func (m *VariableDefinition) CloneVT() *VariableDefinition

func (*VariableDefinition) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use VariableDefinition.ProtoReflect.Descriptor instead.

func (*VariableDefinition) EqualMessageVT added in v0.12.0 

func (this *VariableDefinition) EqualMessageVT(thatMsg proto.Message) bool

func (*VariableDefinition) EqualVT added in v0.12.0 

func (this *VariableDefinition) EqualVT(that *VariableDefinition) bool

func (*VariableDefinition) GetAutobind added in v0.6.0 

func (x *VariableDefinition) GetAutobind() bool

func (*VariableDefinition) GetBy added in v0.6.0 

func (x *VariableDefinition) GetBy() string

func (*VariableDefinition) GetCall added in v0.6.0 

func (x *VariableDefinition) GetCall() *CallExpr

func (*VariableDefinition) GetExpr added in v0.6.0 

func (m *VariableDefinition) GetExpr() isVariableDefinition_Expr

func (*VariableDefinition) GetIf added in v0.6.0 

func (x *VariableDefinition) GetIf() string

func (*VariableDefinition) GetMap added in v0.6.0 

func (x *VariableDefinition) GetMap() *MapExpr

func (*VariableDefinition) GetMessage added in v0.6.0 

func (x *VariableDefinition) GetMessage() *MessageExpr

func (*VariableDefinition) GetName added in v0.6.0 

func (x *VariableDefinition) GetName() string

func (*VariableDefinition) GetValidation added in v0.6.0 

func (x *VariableDefinition) GetValidation() *ValidationExpr

func (*VariableDefinition) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition) MarshalToVT added in v0.12.0 

func (m *VariableDefinition) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition) MarshalVT added in v0.12.0 

func (m *VariableDefinition) MarshalVT() (dAtA []byte, err error)

func (*VariableDefinition) MarshalVTStrict added in v0.12.0 

func (m *VariableDefinition) MarshalVTStrict() (dAtA []byte, err error)

func (*VariableDefinition) ProtoMessage added in v0.6.0 

func (*VariableDefinition) ProtoMessage()

func (*VariableDefinition) ProtoReflect added in v0.6.0 

func (x *VariableDefinition) ProtoReflect() protoreflect.Message

func (*VariableDefinition) Reset added in v0.6.0 

func (x *VariableDefinition) Reset()

func (*VariableDefinition) SizeVT added in v0.12.0 

func (m *VariableDefinition) SizeVT() (n int)

func (*VariableDefinition) String added in v0.6.0 

func (x *VariableDefinition) String() string

func (*VariableDefinition) UnmarshalVT added in v0.12.0 

func (m *VariableDefinition) UnmarshalVT(dAtA []byte) error

func (*VariableDefinition) UnmarshalVTUnsafe added in v0.12.0 

func (m *VariableDefinition) UnmarshalVTUnsafe(dAtA []byte) error

type VariableDefinition_By added in v0.6.0 

type VariableDefinition_By struct {
	// `by` evaluates with CEL.
	By string `protobuf:"bytes,11,opt,name=by,proto3,oneof"`
}

func (*VariableDefinition_By) CloneVT added in v0.12.0 

func (m *VariableDefinition_By) CloneVT() isVariableDefinition_Expr

func (*VariableDefinition_By) EqualVT added in v0.12.0 

func (this *VariableDefinition_By) EqualVT(thatIface isVariableDefinition_Expr) bool

func (*VariableDefinition_By) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition_By) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition_By) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition_By) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_By) MarshalToVT added in v0.12.0 

func (m *VariableDefinition_By) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition_By) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition_By) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_By) SizeVT added in v0.12.0 

func (m *VariableDefinition_By) SizeVT() (n int)

type VariableDefinition_Call added in v0.6.0 

type VariableDefinition_Call struct {
	// call specifies how to call gRPC method.
	Call *CallExpr `protobuf:"bytes,14,opt,name=call,proto3,oneof"`
}

func (*VariableDefinition_Call) CloneVT added in v0.12.0 

func (m *VariableDefinition_Call) CloneVT() isVariableDefinition_Expr

func (*VariableDefinition_Call) EqualVT added in v0.12.0 

func (this *VariableDefinition_Call) EqualVT(thatIface isVariableDefinition_Expr) bool

func (*VariableDefinition_Call) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition_Call) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition_Call) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition_Call) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Call) MarshalToVT added in v0.12.0 

func (m *VariableDefinition_Call) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition_Call) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition_Call) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Call) SizeVT added in v0.12.0 

func (m *VariableDefinition_Call) SizeVT() (n int)

type VariableDefinition_Map added in v0.6.0 

type VariableDefinition_Map struct {
	// map apply map operation for the specified repeated type.
	Map *MapExpr `protobuf:"bytes,12,opt,name=map,proto3,oneof"`
}

func (*VariableDefinition_Map) CloneVT added in v0.12.0 

func (m *VariableDefinition_Map) CloneVT() isVariableDefinition_Expr

func (*VariableDefinition_Map) EqualVT added in v0.12.0 

func (this *VariableDefinition_Map) EqualVT(thatIface isVariableDefinition_Expr) bool

func (*VariableDefinition_Map) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition_Map) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition_Map) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition_Map) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Map) MarshalToVT added in v0.12.0 

func (m *VariableDefinition_Map) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition_Map) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition_Map) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Map) SizeVT added in v0.12.0 

func (m *VariableDefinition_Map) SizeVT() (n int)

type VariableDefinition_Message added in v0.6.0 

type VariableDefinition_Message struct {
	// message gets with message arguments.
	Message *MessageExpr `protobuf:"bytes,13,opt,name=message,proto3,oneof"`
}

func (*VariableDefinition_Message) CloneVT added in v0.12.0 

func (m *VariableDefinition_Message) CloneVT() isVariableDefinition_Expr

func (*VariableDefinition_Message) EqualVT added in v0.12.0 

func (this *VariableDefinition_Message) EqualVT(thatIface isVariableDefinition_Expr) bool

func (*VariableDefinition_Message) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition_Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition_Message) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition_Message) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Message) MarshalToVT added in v0.12.0 

func (m *VariableDefinition_Message) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition_Message) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition_Message) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Message) SizeVT added in v0.12.0 

func (m *VariableDefinition_Message) SizeVT() (n int)

type VariableDefinition_Validation added in v0.6.0 

type VariableDefinition_Validation struct {
	// validation defines the validation rule and error.
	Validation *ValidationExpr `protobuf:"bytes,15,opt,name=validation,proto3,oneof"`
}

func (*VariableDefinition_Validation) CloneVT added in v0.12.0 

func (m *VariableDefinition_Validation) CloneVT() isVariableDefinition_Expr

func (*VariableDefinition_Validation) EqualVT added in v0.12.0 

func (this *VariableDefinition_Validation) EqualVT(thatIface isVariableDefinition_Expr) bool

func (*VariableDefinition_Validation) MarshalToSizedBufferVT added in v0.12.0 

func (m *VariableDefinition_Validation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VariableDefinition_Validation) MarshalToSizedBufferVTStrict added in v0.12.0 

func (m *VariableDefinition_Validation) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Validation) MarshalToVT added in v0.12.0 

func (m *VariableDefinition_Validation) MarshalToVT(dAtA []byte) (int, error)

func (*VariableDefinition_Validation) MarshalToVTStrict added in v0.12.0 

func (m *VariableDefinition_Validation) MarshalToVTStrict(dAtA []byte) (int, error)

func (*VariableDefinition_Validation) SizeVT added in v0.12.0 

func (m *VariableDefinition_Validation) SizeVT() (n int)

Source Files

View all Source files

Directories

Path Synopsis
plugin

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.