diff options
Diffstat (limited to 'vendor/github.com/authzed/spicedb/pkg/proto/impl')
6 files changed, 6949 insertions, 0 deletions
diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.go new file mode 100644 index 0000000..67ee033 --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.go @@ -0,0 +1,1205 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.34.2 +// protoc (unknown) +// source: impl/v1/impl.proto + +package implv1 + +import ( + v1alpha1 "google.golang.org/genproto/googleapis/api/expr/v1alpha1" + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type RelationMetadata_RelationKind int32 + +const ( + RelationMetadata_UNKNOWN_KIND RelationMetadata_RelationKind = 0 + RelationMetadata_RELATION RelationMetadata_RelationKind = 1 + RelationMetadata_PERMISSION RelationMetadata_RelationKind = 2 +) + +// Enum value maps for RelationMetadata_RelationKind. +var ( + RelationMetadata_RelationKind_name = map[int32]string{ + 0: "UNKNOWN_KIND", + 1: "RELATION", + 2: "PERMISSION", + } + RelationMetadata_RelationKind_value = map[string]int32{ + "UNKNOWN_KIND": 0, + "RELATION": 1, + "PERMISSION": 2, + } +) + +func (x RelationMetadata_RelationKind) Enum() *RelationMetadata_RelationKind { + p := new(RelationMetadata_RelationKind) + *p = x + return p +} + +func (x RelationMetadata_RelationKind) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (RelationMetadata_RelationKind) Descriptor() protoreflect.EnumDescriptor { + return file_impl_v1_impl_proto_enumTypes[0].Descriptor() +} + +func (RelationMetadata_RelationKind) Type() protoreflect.EnumType { + return &file_impl_v1_impl_proto_enumTypes[0] +} + +func (x RelationMetadata_RelationKind) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use RelationMetadata_RelationKind.Descriptor instead. +func (RelationMetadata_RelationKind) EnumDescriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{6, 0} +} + +type DecodedCaveat struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // we do kind_oneof in case we decide to have non-CEL expressions + // + // Types that are assignable to KindOneof: + // + // *DecodedCaveat_Cel + KindOneof isDecodedCaveat_KindOneof `protobuf_oneof:"kind_oneof"` + Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` +} + +func (x *DecodedCaveat) Reset() { + *x = DecodedCaveat{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedCaveat) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedCaveat) ProtoMessage() {} + +func (x *DecodedCaveat) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedCaveat.ProtoReflect.Descriptor instead. +func (*DecodedCaveat) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{0} +} + +func (m *DecodedCaveat) GetKindOneof() isDecodedCaveat_KindOneof { + if m != nil { + return m.KindOneof + } + return nil +} + +func (x *DecodedCaveat) GetCel() *v1alpha1.CheckedExpr { + if x, ok := x.GetKindOneof().(*DecodedCaveat_Cel); ok { + return x.Cel + } + return nil +} + +func (x *DecodedCaveat) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +type isDecodedCaveat_KindOneof interface { + isDecodedCaveat_KindOneof() +} + +type DecodedCaveat_Cel struct { + Cel *v1alpha1.CheckedExpr `protobuf:"bytes,1,opt,name=cel,proto3,oneof"` +} + +func (*DecodedCaveat_Cel) isDecodedCaveat_KindOneof() {} + +type DecodedZookie struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` + // Types that are assignable to VersionOneof: + // + // *DecodedZookie_V1 + // *DecodedZookie_V2 + VersionOneof isDecodedZookie_VersionOneof `protobuf_oneof:"version_oneof"` +} + +func (x *DecodedZookie) Reset() { + *x = DecodedZookie{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZookie) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZookie) ProtoMessage() {} + +func (x *DecodedZookie) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZookie.ProtoReflect.Descriptor instead. +func (*DecodedZookie) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{1} +} + +func (x *DecodedZookie) GetVersion() uint32 { + if x != nil { + return x.Version + } + return 0 +} + +func (m *DecodedZookie) GetVersionOneof() isDecodedZookie_VersionOneof { + if m != nil { + return m.VersionOneof + } + return nil +} + +func (x *DecodedZookie) GetV1() *DecodedZookie_V1Zookie { + if x, ok := x.GetVersionOneof().(*DecodedZookie_V1); ok { + return x.V1 + } + return nil +} + +func (x *DecodedZookie) GetV2() *DecodedZookie_V2Zookie { + if x, ok := x.GetVersionOneof().(*DecodedZookie_V2); ok { + return x.V2 + } + return nil +} + +type isDecodedZookie_VersionOneof interface { + isDecodedZookie_VersionOneof() +} + +type DecodedZookie_V1 struct { + V1 *DecodedZookie_V1Zookie `protobuf:"bytes,2,opt,name=v1,proto3,oneof"` +} + +type DecodedZookie_V2 struct { + V2 *DecodedZookie_V2Zookie `protobuf:"bytes,3,opt,name=v2,proto3,oneof"` +} + +func (*DecodedZookie_V1) isDecodedZookie_VersionOneof() {} + +func (*DecodedZookie_V2) isDecodedZookie_VersionOneof() {} + +type DecodedZedToken struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Types that are assignable to VersionOneof: + // + // *DecodedZedToken_DeprecatedV1Zookie + // *DecodedZedToken_V1 + VersionOneof isDecodedZedToken_VersionOneof `protobuf_oneof:"version_oneof"` +} + +func (x *DecodedZedToken) Reset() { + *x = DecodedZedToken{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZedToken) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZedToken) ProtoMessage() {} + +func (x *DecodedZedToken) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZedToken.ProtoReflect.Descriptor instead. +func (*DecodedZedToken) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{2} +} + +func (m *DecodedZedToken) GetVersionOneof() isDecodedZedToken_VersionOneof { + if m != nil { + return m.VersionOneof + } + return nil +} + +func (x *DecodedZedToken) GetDeprecatedV1Zookie() *DecodedZedToken_V1Zookie { + if x, ok := x.GetVersionOneof().(*DecodedZedToken_DeprecatedV1Zookie); ok { + return x.DeprecatedV1Zookie + } + return nil +} + +func (x *DecodedZedToken) GetV1() *DecodedZedToken_V1ZedToken { + if x, ok := x.GetVersionOneof().(*DecodedZedToken_V1); ok { + return x.V1 + } + return nil +} + +type isDecodedZedToken_VersionOneof interface { + isDecodedZedToken_VersionOneof() +} + +type DecodedZedToken_DeprecatedV1Zookie struct { + DeprecatedV1Zookie *DecodedZedToken_V1Zookie `protobuf:"bytes,2,opt,name=deprecated_v1_zookie,json=deprecatedV1Zookie,proto3,oneof"` +} + +type DecodedZedToken_V1 struct { + V1 *DecodedZedToken_V1ZedToken `protobuf:"bytes,3,opt,name=v1,proto3,oneof"` +} + +func (*DecodedZedToken_DeprecatedV1Zookie) isDecodedZedToken_VersionOneof() {} + +func (*DecodedZedToken_V1) isDecodedZedToken_VersionOneof() {} + +type DecodedCursor struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // we do version_oneof in case we decide to add a new version. + // + // Types that are assignable to VersionOneof: + // + // *DecodedCursor_V1 + VersionOneof isDecodedCursor_VersionOneof `protobuf_oneof:"version_oneof"` +} + +func (x *DecodedCursor) Reset() { + *x = DecodedCursor{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedCursor) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedCursor) ProtoMessage() {} + +func (x *DecodedCursor) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedCursor.ProtoReflect.Descriptor instead. +func (*DecodedCursor) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{3} +} + +func (m *DecodedCursor) GetVersionOneof() isDecodedCursor_VersionOneof { + if m != nil { + return m.VersionOneof + } + return nil +} + +func (x *DecodedCursor) GetV1() *V1Cursor { + if x, ok := x.GetVersionOneof().(*DecodedCursor_V1); ok { + return x.V1 + } + return nil +} + +type isDecodedCursor_VersionOneof interface { + isDecodedCursor_VersionOneof() +} + +type DecodedCursor_V1 struct { + V1 *V1Cursor `protobuf:"bytes,1,opt,name=v1,proto3,oneof"` +} + +func (*DecodedCursor_V1) isDecodedCursor_VersionOneof() {} + +type V1Cursor struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // revision is the string form of the revision for the cursor. + Revision string `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"` + // sections are the sections of the dispatching cursor. + Sections []string `protobuf:"bytes,2,rep,name=sections,proto3" json:"sections,omitempty"` + // call_and_parameters_hash is a hash of the call that manufactured this cursor and all its + // parameters, including limits and zedtoken, to ensure no inputs changed when using this cursor. + CallAndParametersHash string `protobuf:"bytes,3,opt,name=call_and_parameters_hash,json=callAndParametersHash,proto3" json:"call_and_parameters_hash,omitempty"` + // dispatch_version is the version of the dispatcher which created the cursor. + DispatchVersion uint32 `protobuf:"varint,4,opt,name=dispatch_version,json=dispatchVersion,proto3" json:"dispatch_version,omitempty"` + // flags are flags set by the API caller. + Flags map[string]string `protobuf:"bytes,5,rep,name=flags,proto3" json:"flags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +} + +func (x *V1Cursor) Reset() { + *x = V1Cursor{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *V1Cursor) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*V1Cursor) ProtoMessage() {} + +func (x *V1Cursor) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[4] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use V1Cursor.ProtoReflect.Descriptor instead. +func (*V1Cursor) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{4} +} + +func (x *V1Cursor) GetRevision() string { + if x != nil { + return x.Revision + } + return "" +} + +func (x *V1Cursor) GetSections() []string { + if x != nil { + return x.Sections + } + return nil +} + +func (x *V1Cursor) GetCallAndParametersHash() string { + if x != nil { + return x.CallAndParametersHash + } + return "" +} + +func (x *V1Cursor) GetDispatchVersion() uint32 { + if x != nil { + return x.DispatchVersion + } + return 0 +} + +func (x *V1Cursor) GetFlags() map[string]string { + if x != nil { + return x.Flags + } + return nil +} + +type DocComment struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Comment string `protobuf:"bytes,1,opt,name=comment,proto3" json:"comment,omitempty"` +} + +func (x *DocComment) Reset() { + *x = DocComment{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DocComment) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DocComment) ProtoMessage() {} + +func (x *DocComment) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[5] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DocComment.ProtoReflect.Descriptor instead. +func (*DocComment) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{5} +} + +func (x *DocComment) GetComment() string { + if x != nil { + return x.Comment + } + return "" +} + +type RelationMetadata struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Kind RelationMetadata_RelationKind `protobuf:"varint,1,opt,name=kind,proto3,enum=impl.v1.RelationMetadata_RelationKind" json:"kind,omitempty"` +} + +func (x *RelationMetadata) Reset() { + *x = RelationMetadata{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RelationMetadata) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RelationMetadata) ProtoMessage() {} + +func (x *RelationMetadata) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[6] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use RelationMetadata.ProtoReflect.Descriptor instead. +func (*RelationMetadata) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{6} +} + +func (x *RelationMetadata) GetKind() RelationMetadata_RelationKind { + if x != nil { + return x.Kind + } + return RelationMetadata_UNKNOWN_KIND +} + +type NamespaceAndRevision struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` + Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"` +} + +func (x *NamespaceAndRevision) Reset() { + *x = NamespaceAndRevision{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *NamespaceAndRevision) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*NamespaceAndRevision) ProtoMessage() {} + +func (x *NamespaceAndRevision) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[7] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use NamespaceAndRevision.ProtoReflect.Descriptor instead. +func (*NamespaceAndRevision) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{7} +} + +func (x *NamespaceAndRevision) GetNamespaceName() string { + if x != nil { + return x.NamespaceName + } + return "" +} + +func (x *NamespaceAndRevision) GetRevision() string { + if x != nil { + return x.Revision + } + return "" +} + +type V1Alpha1Revision struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + NsRevisions []*NamespaceAndRevision `protobuf:"bytes,1,rep,name=ns_revisions,json=nsRevisions,proto3" json:"ns_revisions,omitempty"` +} + +func (x *V1Alpha1Revision) Reset() { + *x = V1Alpha1Revision{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *V1Alpha1Revision) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*V1Alpha1Revision) ProtoMessage() {} + +func (x *V1Alpha1Revision) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[8] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use V1Alpha1Revision.ProtoReflect.Descriptor instead. +func (*V1Alpha1Revision) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{8} +} + +func (x *V1Alpha1Revision) GetNsRevisions() []*NamespaceAndRevision { + if x != nil { + return x.NsRevisions + } + return nil +} + +type DecodedZookie_V1Zookie struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"` +} + +func (x *DecodedZookie_V1Zookie) Reset() { + *x = DecodedZookie_V1Zookie{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZookie_V1Zookie) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZookie_V1Zookie) ProtoMessage() {} + +func (x *DecodedZookie_V1Zookie) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[9] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZookie_V1Zookie.ProtoReflect.Descriptor instead. +func (*DecodedZookie_V1Zookie) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{1, 0} +} + +func (x *DecodedZookie_V1Zookie) GetRevision() uint64 { + if x != nil { + return x.Revision + } + return 0 +} + +type DecodedZookie_V2Zookie struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Revision string `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"` +} + +func (x *DecodedZookie_V2Zookie) Reset() { + *x = DecodedZookie_V2Zookie{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZookie_V2Zookie) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZookie_V2Zookie) ProtoMessage() {} + +func (x *DecodedZookie_V2Zookie) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[10] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZookie_V2Zookie.ProtoReflect.Descriptor instead. +func (*DecodedZookie_V2Zookie) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{1, 1} +} + +func (x *DecodedZookie_V2Zookie) GetRevision() string { + if x != nil { + return x.Revision + } + return "" +} + +type DecodedZedToken_V1Zookie struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"` +} + +func (x *DecodedZedToken_V1Zookie) Reset() { + *x = DecodedZedToken_V1Zookie{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZedToken_V1Zookie) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZedToken_V1Zookie) ProtoMessage() {} + +func (x *DecodedZedToken_V1Zookie) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[11] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZedToken_V1Zookie.ProtoReflect.Descriptor instead. +func (*DecodedZedToken_V1Zookie) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{2, 0} +} + +func (x *DecodedZedToken_V1Zookie) GetRevision() uint64 { + if x != nil { + return x.Revision + } + return 0 +} + +type DecodedZedToken_V1ZedToken struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Revision string `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"` +} + +func (x *DecodedZedToken_V1ZedToken) Reset() { + *x = DecodedZedToken_V1ZedToken{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_impl_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DecodedZedToken_V1ZedToken) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DecodedZedToken_V1ZedToken) ProtoMessage() {} + +func (x *DecodedZedToken_V1ZedToken) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_impl_proto_msgTypes[12] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DecodedZedToken_V1ZedToken.ProtoReflect.Descriptor instead. +func (*DecodedZedToken_V1ZedToken) Descriptor() ([]byte, []int) { + return file_impl_v1_impl_proto_rawDescGZIP(), []int{2, 1} +} + +func (x *DecodedZedToken_V1ZedToken) GetRevision() string { + if x != nil { + return x.Revision + } + return "" +} + +var File_impl_v1_impl_proto protoreflect.FileDescriptor + +var file_impl_v1_impl_proto_rawDesc = []byte{ + 0x0a, 0x12, 0x69, 0x6d, 0x70, 0x6c, 0x2f, 0x76, 0x31, 0x2f, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x1a, 0x26, 0x67, + 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x65, 0x78, 0x70, 0x72, 0x2f, 0x76, + 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2f, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x65, 0x64, 0x2e, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x6c, 0x0a, 0x0d, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, + 0x43, 0x61, 0x76, 0x65, 0x61, 0x74, 0x12, 0x39, 0x0a, 0x03, 0x63, 0x65, 0x6c, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x61, 0x70, 0x69, + 0x2e, 0x65, 0x78, 0x70, 0x72, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x2e, 0x43, + 0x68, 0x65, 0x63, 0x6b, 0x65, 0x64, 0x45, 0x78, 0x70, 0x72, 0x48, 0x00, 0x52, 0x03, 0x63, 0x65, + 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x42, 0x0c, 0x0a, 0x0a, 0x6b, 0x69, 0x6e, 0x64, 0x5f, 0x6f, 0x6e, + 0x65, 0x6f, 0x66, 0x22, 0xf0, 0x01, 0x0a, 0x0d, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, 0x5a, + 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, + 0x31, 0x0a, 0x02, 0x76, 0x31, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x69, 0x6d, + 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, 0x5a, 0x6f, 0x6f, + 0x6b, 0x69, 0x65, 0x2e, 0x56, 0x31, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x48, 0x00, 0x52, 0x02, + 0x76, 0x31, 0x12, 0x31, 0x0a, 0x02, 0x76, 0x32, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, + 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, + 0x5a, 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x2e, 0x56, 0x32, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x48, + 0x00, 0x52, 0x02, 0x76, 0x32, 0x1a, 0x26, 0x0a, 0x08, 0x56, 0x31, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, + 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x1a, 0x26, 0x0a, + 0x08, 0x56, 0x32, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x76, + 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65, 0x76, + 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x0f, 0x0a, 0x0d, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, + 0x5f, 0x6f, 0x6e, 0x65, 0x6f, 0x66, 0x22, 0x82, 0x02, 0x0a, 0x0f, 0x44, 0x65, 0x63, 0x6f, 0x64, + 0x65, 0x64, 0x5a, 0x65, 0x64, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x55, 0x0a, 0x14, 0x64, 0x65, + 0x70, 0x72, 0x65, 0x63, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x76, 0x31, 0x5f, 0x7a, 0x6f, 0x6f, 0x6b, + 0x69, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, + 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, 0x5a, 0x65, 0x64, 0x54, 0x6f, 0x6b, + 0x65, 0x6e, 0x2e, 0x56, 0x31, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, 0x65, 0x48, 0x00, 0x52, 0x12, 0x64, + 0x65, 0x70, 0x72, 0x65, 0x63, 0x61, 0x74, 0x65, 0x64, 0x56, 0x31, 0x5a, 0x6f, 0x6f, 0x6b, 0x69, + 0x65, 0x12, 0x35, 0x0a, 0x02, 0x76, 0x31, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, + 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, 0x5a, + 0x65, 0x64, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x2e, 0x56, 0x31, 0x5a, 0x65, 0x64, 0x54, 0x6f, 0x6b, + 0x65, 0x6e, 0x48, 0x00, 0x52, 0x02, 0x76, 0x31, 0x1a, 0x26, 0x0a, 0x08, 0x56, 0x31, 0x5a, 0x6f, + 0x6f, 0x6b, 0x69, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, + 0x1a, 0x28, 0x0a, 0x0a, 0x56, 0x31, 0x5a, 0x65, 0x64, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x1a, + 0x0a, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x0f, 0x0a, 0x0d, 0x76, 0x65, + 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x6e, 0x65, 0x6f, 0x66, 0x22, 0x45, 0x0a, 0x0d, 0x44, + 0x65, 0x63, 0x6f, 0x64, 0x65, 0x64, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x12, 0x23, 0x0a, 0x02, + 0x76, 0x31, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, + 0x76, 0x31, 0x2e, 0x56, 0x31, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x48, 0x00, 0x52, 0x02, 0x76, + 0x31, 0x42, 0x0f, 0x0a, 0x0d, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x6e, 0x65, + 0x6f, 0x66, 0x22, 0x94, 0x02, 0x0a, 0x08, 0x56, 0x31, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x12, + 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x73, + 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x08, 0x73, + 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x18, 0x63, 0x61, 0x6c, 0x6c, 0x5f, + 0x61, 0x6e, 0x64, 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x5f, 0x68, + 0x61, 0x73, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x15, 0x63, 0x61, 0x6c, 0x6c, 0x41, + 0x6e, 0x64, 0x50, 0x61, 0x72, 0x61, 0x6d, 0x65, 0x74, 0x65, 0x72, 0x73, 0x48, 0x61, 0x73, 0x68, + 0x12, 0x29, 0x0a, 0x10, 0x64, 0x69, 0x73, 0x70, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x76, 0x65, 0x72, + 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0f, 0x64, 0x69, 0x73, 0x70, + 0x61, 0x74, 0x63, 0x68, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x05, 0x66, + 0x6c, 0x61, 0x67, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x69, 0x6d, 0x70, + 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x56, 0x31, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x2e, 0x46, 0x6c, + 0x61, 0x67, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x05, 0x66, 0x6c, 0x61, 0x67, 0x73, 0x1a, + 0x38, 0x0a, 0x0a, 0x46, 0x6c, 0x61, 0x67, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, + 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, + 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x26, 0x0a, 0x0a, 0x44, 0x6f, 0x63, + 0x43, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x65, + 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, + 0x74, 0x22, 0x8e, 0x01, 0x0a, 0x10, 0x52, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, + 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x3a, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0e, 0x32, 0x26, 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x52, + 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, + 0x52, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4b, 0x69, 0x6e, 0x64, 0x52, 0x04, 0x6b, 0x69, + 0x6e, 0x64, 0x22, 0x3e, 0x0a, 0x0c, 0x52, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4b, 0x69, + 0x6e, 0x64, 0x12, 0x10, 0x0a, 0x0c, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x5f, 0x4b, 0x49, + 0x4e, 0x44, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x45, 0x4c, 0x41, 0x54, 0x49, 0x4f, 0x4e, + 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x50, 0x45, 0x52, 0x4d, 0x49, 0x53, 0x53, 0x49, 0x4f, 0x4e, + 0x10, 0x02, 0x22, 0x59, 0x0a, 0x14, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x41, + 0x6e, 0x64, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x25, 0x0a, 0x0e, 0x6e, 0x61, + 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x4e, 0x61, 0x6d, + 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x54, 0x0a, + 0x10, 0x56, 0x31, 0x41, 0x6c, 0x70, 0x68, 0x61, 0x31, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, + 0x6e, 0x12, 0x40, 0x0a, 0x0c, 0x6e, 0x73, 0x5f, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, + 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, + 0x31, 0x2e, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x41, 0x6e, 0x64, 0x52, 0x65, + 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0b, 0x6e, 0x73, 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, + 0x6f, 0x6e, 0x73, 0x42, 0x8a, 0x01, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x2e, 0x69, 0x6d, 0x70, 0x6c, + 0x2e, 0x76, 0x31, 0x42, 0x09, 0x49, 0x6d, 0x70, 0x6c, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, + 0x5a, 0x33, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, + 0x68, 0x7a, 0x65, 0x64, 0x2f, 0x73, 0x70, 0x69, 0x63, 0x65, 0x64, 0x62, 0x2f, 0x70, 0x6b, 0x67, + 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x69, 0x6d, 0x70, 0x6c, 0x2f, 0x76, 0x31, 0x3b, 0x69, + 0x6d, 0x70, 0x6c, 0x76, 0x31, 0xa2, 0x02, 0x03, 0x49, 0x58, 0x58, 0xaa, 0x02, 0x07, 0x49, 0x6d, + 0x70, 0x6c, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x07, 0x49, 0x6d, 0x70, 0x6c, 0x5c, 0x56, 0x31, 0xe2, + 0x02, 0x13, 0x49, 0x6d, 0x70, 0x6c, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x08, 0x49, 0x6d, 0x70, 0x6c, 0x3a, 0x3a, 0x56, 0x31, + 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_impl_v1_impl_proto_rawDescOnce sync.Once + file_impl_v1_impl_proto_rawDescData = file_impl_v1_impl_proto_rawDesc +) + +func file_impl_v1_impl_proto_rawDescGZIP() []byte { + file_impl_v1_impl_proto_rawDescOnce.Do(func() { + file_impl_v1_impl_proto_rawDescData = protoimpl.X.CompressGZIP(file_impl_v1_impl_proto_rawDescData) + }) + return file_impl_v1_impl_proto_rawDescData +} + +var file_impl_v1_impl_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_impl_v1_impl_proto_msgTypes = make([]protoimpl.MessageInfo, 14) +var file_impl_v1_impl_proto_goTypes = []any{ + (RelationMetadata_RelationKind)(0), // 0: impl.v1.RelationMetadata.RelationKind + (*DecodedCaveat)(nil), // 1: impl.v1.DecodedCaveat + (*DecodedZookie)(nil), // 2: impl.v1.DecodedZookie + (*DecodedZedToken)(nil), // 3: impl.v1.DecodedZedToken + (*DecodedCursor)(nil), // 4: impl.v1.DecodedCursor + (*V1Cursor)(nil), // 5: impl.v1.V1Cursor + (*DocComment)(nil), // 6: impl.v1.DocComment + (*RelationMetadata)(nil), // 7: impl.v1.RelationMetadata + (*NamespaceAndRevision)(nil), // 8: impl.v1.NamespaceAndRevision + (*V1Alpha1Revision)(nil), // 9: impl.v1.V1Alpha1Revision + (*DecodedZookie_V1Zookie)(nil), // 10: impl.v1.DecodedZookie.V1Zookie + (*DecodedZookie_V2Zookie)(nil), // 11: impl.v1.DecodedZookie.V2Zookie + (*DecodedZedToken_V1Zookie)(nil), // 12: impl.v1.DecodedZedToken.V1Zookie + (*DecodedZedToken_V1ZedToken)(nil), // 13: impl.v1.DecodedZedToken.V1ZedToken + nil, // 14: impl.v1.V1Cursor.FlagsEntry + (*v1alpha1.CheckedExpr)(nil), // 15: google.api.expr.v1alpha1.CheckedExpr +} +var file_impl_v1_impl_proto_depIdxs = []int32{ + 15, // 0: impl.v1.DecodedCaveat.cel:type_name -> google.api.expr.v1alpha1.CheckedExpr + 10, // 1: impl.v1.DecodedZookie.v1:type_name -> impl.v1.DecodedZookie.V1Zookie + 11, // 2: impl.v1.DecodedZookie.v2:type_name -> impl.v1.DecodedZookie.V2Zookie + 12, // 3: impl.v1.DecodedZedToken.deprecated_v1_zookie:type_name -> impl.v1.DecodedZedToken.V1Zookie + 13, // 4: impl.v1.DecodedZedToken.v1:type_name -> impl.v1.DecodedZedToken.V1ZedToken + 5, // 5: impl.v1.DecodedCursor.v1:type_name -> impl.v1.V1Cursor + 14, // 6: impl.v1.V1Cursor.flags:type_name -> impl.v1.V1Cursor.FlagsEntry + 0, // 7: impl.v1.RelationMetadata.kind:type_name -> impl.v1.RelationMetadata.RelationKind + 8, // 8: impl.v1.V1Alpha1Revision.ns_revisions:type_name -> impl.v1.NamespaceAndRevision + 9, // [9:9] is the sub-list for method output_type + 9, // [9:9] is the sub-list for method input_type + 9, // [9:9] is the sub-list for extension type_name + 9, // [9:9] is the sub-list for extension extendee + 0, // [0:9] is the sub-list for field type_name +} + +func init() { file_impl_v1_impl_proto_init() } +func file_impl_v1_impl_proto_init() { + if File_impl_v1_impl_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_impl_v1_impl_proto_msgTypes[0].Exporter = func(v any, i int) any { + switch v := v.(*DecodedCaveat); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[1].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZookie); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[2].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZedToken); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[3].Exporter = func(v any, i int) any { + switch v := v.(*DecodedCursor); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[4].Exporter = func(v any, i int) any { + switch v := v.(*V1Cursor); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[5].Exporter = func(v any, i int) any { + switch v := v.(*DocComment); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[6].Exporter = func(v any, i int) any { + switch v := v.(*RelationMetadata); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[7].Exporter = func(v any, i int) any { + switch v := v.(*NamespaceAndRevision); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[8].Exporter = func(v any, i int) any { + switch v := v.(*V1Alpha1Revision); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[9].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZookie_V1Zookie); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[10].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZookie_V2Zookie); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[11].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZedToken_V1Zookie); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_impl_v1_impl_proto_msgTypes[12].Exporter = func(v any, i int) any { + switch v := v.(*DecodedZedToken_V1ZedToken); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + file_impl_v1_impl_proto_msgTypes[0].OneofWrappers = []any{ + (*DecodedCaveat_Cel)(nil), + } + file_impl_v1_impl_proto_msgTypes[1].OneofWrappers = []any{ + (*DecodedZookie_V1)(nil), + (*DecodedZookie_V2)(nil), + } + file_impl_v1_impl_proto_msgTypes[2].OneofWrappers = []any{ + (*DecodedZedToken_DeprecatedV1Zookie)(nil), + (*DecodedZedToken_V1)(nil), + } + file_impl_v1_impl_proto_msgTypes[3].OneofWrappers = []any{ + (*DecodedCursor_V1)(nil), + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_impl_v1_impl_proto_rawDesc, + NumEnums: 1, + NumMessages: 14, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_impl_v1_impl_proto_goTypes, + DependencyIndexes: file_impl_v1_impl_proto_depIdxs, + EnumInfos: file_impl_v1_impl_proto_enumTypes, + MessageInfos: file_impl_v1_impl_proto_msgTypes, + }.Build() + File_impl_v1_impl_proto = out.File + file_impl_v1_impl_proto_rawDesc = nil + file_impl_v1_impl_proto_goTypes = nil + file_impl_v1_impl_proto_depIdxs = nil +} diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.validate.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.validate.go new file mode 100644 index 0000000..dea8479 --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl.pb.validate.go @@ -0,0 +1,1672 @@ +// Code generated by protoc-gen-validate. DO NOT EDIT. +// source: impl/v1/impl.proto + +package implv1 + +import ( + "bytes" + "errors" + "fmt" + "net" + "net/mail" + "net/url" + "regexp" + "sort" + "strings" + "time" + "unicode/utf8" + + "google.golang.org/protobuf/types/known/anypb" +) + +// ensure the imports are used +var ( + _ = bytes.MinRead + _ = errors.New("") + _ = fmt.Print + _ = utf8.UTFMax + _ = (*regexp.Regexp)(nil) + _ = (*strings.Reader)(nil) + _ = net.IPv4len + _ = time.Duration(0) + _ = (*url.URL)(nil) + _ = (*mail.Address)(nil) + _ = anypb.Any{} + _ = sort.Sort +) + +// Validate checks the field values on DecodedCaveat with the rules defined in +// the proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *DecodedCaveat) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedCaveat with the rules defined +// in the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in DecodedCaveatMultiError, or +// nil if none found. +func (m *DecodedCaveat) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedCaveat) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Name + + switch v := m.KindOneof.(type) { + case *DecodedCaveat_Cel: + if v == nil { + err := DecodedCaveatValidationError{ + field: "KindOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetCel()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedCaveatValidationError{ + field: "Cel", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedCaveatValidationError{ + field: "Cel", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetCel()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedCaveatValidationError{ + field: "Cel", + reason: "embedded message failed validation", + cause: err, + } + } + } + + default: + _ = v // ensures v is used + } + + if len(errors) > 0 { + return DecodedCaveatMultiError(errors) + } + + return nil +} + +// DecodedCaveatMultiError is an error wrapping multiple validation errors +// returned by DecodedCaveat.ValidateAll() if the designated constraints +// aren't met. +type DecodedCaveatMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedCaveatMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedCaveatMultiError) AllErrors() []error { return m } + +// DecodedCaveatValidationError is the validation error returned by +// DecodedCaveat.Validate if the designated constraints aren't met. +type DecodedCaveatValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedCaveatValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedCaveatValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedCaveatValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedCaveatValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedCaveatValidationError) ErrorName() string { return "DecodedCaveatValidationError" } + +// Error satisfies the builtin error interface +func (e DecodedCaveatValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedCaveat.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedCaveatValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedCaveatValidationError{} + +// Validate checks the field values on DecodedZookie with the rules defined in +// the proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *DecodedZookie) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZookie with the rules defined +// in the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in DecodedZookieMultiError, or +// nil if none found. +func (m *DecodedZookie) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZookie) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Version + + switch v := m.VersionOneof.(type) { + case *DecodedZookie_V1: + if v == nil { + err := DecodedZookieValidationError{ + field: "VersionOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetV1()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedZookieValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedZookieValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetV1()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedZookieValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + } + } + } + + case *DecodedZookie_V2: + if v == nil { + err := DecodedZookieValidationError{ + field: "VersionOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetV2()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedZookieValidationError{ + field: "V2", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedZookieValidationError{ + field: "V2", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetV2()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedZookieValidationError{ + field: "V2", + reason: "embedded message failed validation", + cause: err, + } + } + } + + default: + _ = v // ensures v is used + } + + if len(errors) > 0 { + return DecodedZookieMultiError(errors) + } + + return nil +} + +// DecodedZookieMultiError is an error wrapping multiple validation errors +// returned by DecodedZookie.ValidateAll() if the designated constraints +// aren't met. +type DecodedZookieMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZookieMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZookieMultiError) AllErrors() []error { return m } + +// DecodedZookieValidationError is the validation error returned by +// DecodedZookie.Validate if the designated constraints aren't met. +type DecodedZookieValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZookieValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZookieValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZookieValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZookieValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZookieValidationError) ErrorName() string { return "DecodedZookieValidationError" } + +// Error satisfies the builtin error interface +func (e DecodedZookieValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZookie.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZookieValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZookieValidationError{} + +// Validate checks the field values on DecodedZedToken with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *DecodedZedToken) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZedToken with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// DecodedZedTokenMultiError, or nil if none found. +func (m *DecodedZedToken) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZedToken) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + switch v := m.VersionOneof.(type) { + case *DecodedZedToken_DeprecatedV1Zookie: + if v == nil { + err := DecodedZedTokenValidationError{ + field: "VersionOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetDeprecatedV1Zookie()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedZedTokenValidationError{ + field: "DeprecatedV1Zookie", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedZedTokenValidationError{ + field: "DeprecatedV1Zookie", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetDeprecatedV1Zookie()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedZedTokenValidationError{ + field: "DeprecatedV1Zookie", + reason: "embedded message failed validation", + cause: err, + } + } + } + + case *DecodedZedToken_V1: + if v == nil { + err := DecodedZedTokenValidationError{ + field: "VersionOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetV1()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedZedTokenValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedZedTokenValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetV1()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedZedTokenValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + } + } + } + + default: + _ = v // ensures v is used + } + + if len(errors) > 0 { + return DecodedZedTokenMultiError(errors) + } + + return nil +} + +// DecodedZedTokenMultiError is an error wrapping multiple validation errors +// returned by DecodedZedToken.ValidateAll() if the designated constraints +// aren't met. +type DecodedZedTokenMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZedTokenMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZedTokenMultiError) AllErrors() []error { return m } + +// DecodedZedTokenValidationError is the validation error returned by +// DecodedZedToken.Validate if the designated constraints aren't met. +type DecodedZedTokenValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZedTokenValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZedTokenValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZedTokenValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZedTokenValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZedTokenValidationError) ErrorName() string { return "DecodedZedTokenValidationError" } + +// Error satisfies the builtin error interface +func (e DecodedZedTokenValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZedToken.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZedTokenValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZedTokenValidationError{} + +// Validate checks the field values on DecodedCursor with the rules defined in +// the proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *DecodedCursor) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedCursor with the rules defined +// in the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in DecodedCursorMultiError, or +// nil if none found. +func (m *DecodedCursor) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedCursor) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + switch v := m.VersionOneof.(type) { + case *DecodedCursor_V1: + if v == nil { + err := DecodedCursorValidationError{ + field: "VersionOneof", + reason: "oneof value cannot be a typed-nil", + } + if !all { + return err + } + errors = append(errors, err) + } + + if all { + switch v := interface{}(m.GetV1()).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, DecodedCursorValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, DecodedCursorValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(m.GetV1()).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return DecodedCursorValidationError{ + field: "V1", + reason: "embedded message failed validation", + cause: err, + } + } + } + + default: + _ = v // ensures v is used + } + + if len(errors) > 0 { + return DecodedCursorMultiError(errors) + } + + return nil +} + +// DecodedCursorMultiError is an error wrapping multiple validation errors +// returned by DecodedCursor.ValidateAll() if the designated constraints +// aren't met. +type DecodedCursorMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedCursorMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedCursorMultiError) AllErrors() []error { return m } + +// DecodedCursorValidationError is the validation error returned by +// DecodedCursor.Validate if the designated constraints aren't met. +type DecodedCursorValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedCursorValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedCursorValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedCursorValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedCursorValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedCursorValidationError) ErrorName() string { return "DecodedCursorValidationError" } + +// Error satisfies the builtin error interface +func (e DecodedCursorValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedCursor.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedCursorValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedCursorValidationError{} + +// Validate checks the field values on V1Cursor with the rules defined in the +// proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *V1Cursor) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on V1Cursor with the rules defined in +// the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in V1CursorMultiError, or nil +// if none found. +func (m *V1Cursor) ValidateAll() error { + return m.validate(true) +} + +func (m *V1Cursor) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Revision + + // no validation rules for CallAndParametersHash + + // no validation rules for DispatchVersion + + // no validation rules for Flags + + if len(errors) > 0 { + return V1CursorMultiError(errors) + } + + return nil +} + +// V1CursorMultiError is an error wrapping multiple validation errors returned +// by V1Cursor.ValidateAll() if the designated constraints aren't met. +type V1CursorMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m V1CursorMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m V1CursorMultiError) AllErrors() []error { return m } + +// V1CursorValidationError is the validation error returned by +// V1Cursor.Validate if the designated constraints aren't met. +type V1CursorValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e V1CursorValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e V1CursorValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e V1CursorValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e V1CursorValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e V1CursorValidationError) ErrorName() string { return "V1CursorValidationError" } + +// Error satisfies the builtin error interface +func (e V1CursorValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sV1Cursor.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = V1CursorValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = V1CursorValidationError{} + +// Validate checks the field values on DocComment with the rules defined in the +// proto definition for this message. If any rules are violated, the first +// error encountered is returned, or nil if there are no violations. +func (m *DocComment) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DocComment with the rules defined in +// the proto definition for this message. If any rules are violated, the +// result is a list of violation errors wrapped in DocCommentMultiError, or +// nil if none found. +func (m *DocComment) ValidateAll() error { + return m.validate(true) +} + +func (m *DocComment) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Comment + + if len(errors) > 0 { + return DocCommentMultiError(errors) + } + + return nil +} + +// DocCommentMultiError is an error wrapping multiple validation errors +// returned by DocComment.ValidateAll() if the designated constraints aren't met. +type DocCommentMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DocCommentMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DocCommentMultiError) AllErrors() []error { return m } + +// DocCommentValidationError is the validation error returned by +// DocComment.Validate if the designated constraints aren't met. +type DocCommentValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DocCommentValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DocCommentValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DocCommentValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DocCommentValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DocCommentValidationError) ErrorName() string { return "DocCommentValidationError" } + +// Error satisfies the builtin error interface +func (e DocCommentValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDocComment.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DocCommentValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DocCommentValidationError{} + +// Validate checks the field values on RelationMetadata with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *RelationMetadata) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on RelationMetadata with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// RelationMetadataMultiError, or nil if none found. +func (m *RelationMetadata) ValidateAll() error { + return m.validate(true) +} + +func (m *RelationMetadata) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Kind + + if len(errors) > 0 { + return RelationMetadataMultiError(errors) + } + + return nil +} + +// RelationMetadataMultiError is an error wrapping multiple validation errors +// returned by RelationMetadata.ValidateAll() if the designated constraints +// aren't met. +type RelationMetadataMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m RelationMetadataMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m RelationMetadataMultiError) AllErrors() []error { return m } + +// RelationMetadataValidationError is the validation error returned by +// RelationMetadata.Validate if the designated constraints aren't met. +type RelationMetadataValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e RelationMetadataValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e RelationMetadataValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e RelationMetadataValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e RelationMetadataValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e RelationMetadataValidationError) ErrorName() string { return "RelationMetadataValidationError" } + +// Error satisfies the builtin error interface +func (e RelationMetadataValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sRelationMetadata.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = RelationMetadataValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = RelationMetadataValidationError{} + +// Validate checks the field values on NamespaceAndRevision with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *NamespaceAndRevision) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on NamespaceAndRevision with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// NamespaceAndRevisionMultiError, or nil if none found. +func (m *NamespaceAndRevision) ValidateAll() error { + return m.validate(true) +} + +func (m *NamespaceAndRevision) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for NamespaceName + + // no validation rules for Revision + + if len(errors) > 0 { + return NamespaceAndRevisionMultiError(errors) + } + + return nil +} + +// NamespaceAndRevisionMultiError is an error wrapping multiple validation +// errors returned by NamespaceAndRevision.ValidateAll() if the designated +// constraints aren't met. +type NamespaceAndRevisionMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m NamespaceAndRevisionMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m NamespaceAndRevisionMultiError) AllErrors() []error { return m } + +// NamespaceAndRevisionValidationError is the validation error returned by +// NamespaceAndRevision.Validate if the designated constraints aren't met. +type NamespaceAndRevisionValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e NamespaceAndRevisionValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e NamespaceAndRevisionValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e NamespaceAndRevisionValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e NamespaceAndRevisionValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e NamespaceAndRevisionValidationError) ErrorName() string { + return "NamespaceAndRevisionValidationError" +} + +// Error satisfies the builtin error interface +func (e NamespaceAndRevisionValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sNamespaceAndRevision.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = NamespaceAndRevisionValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = NamespaceAndRevisionValidationError{} + +// Validate checks the field values on V1Alpha1Revision with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *V1Alpha1Revision) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on V1Alpha1Revision with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// V1Alpha1RevisionMultiError, or nil if none found. +func (m *V1Alpha1Revision) ValidateAll() error { + return m.validate(true) +} + +func (m *V1Alpha1Revision) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + for idx, item := range m.GetNsRevisions() { + _, _ = idx, item + + if all { + switch v := interface{}(item).(type) { + case interface{ ValidateAll() error }: + if err := v.ValidateAll(); err != nil { + errors = append(errors, V1Alpha1RevisionValidationError{ + field: fmt.Sprintf("NsRevisions[%v]", idx), + reason: "embedded message failed validation", + cause: err, + }) + } + case interface{ Validate() error }: + if err := v.Validate(); err != nil { + errors = append(errors, V1Alpha1RevisionValidationError{ + field: fmt.Sprintf("NsRevisions[%v]", idx), + reason: "embedded message failed validation", + cause: err, + }) + } + } + } else if v, ok := interface{}(item).(interface{ Validate() error }); ok { + if err := v.Validate(); err != nil { + return V1Alpha1RevisionValidationError{ + field: fmt.Sprintf("NsRevisions[%v]", idx), + reason: "embedded message failed validation", + cause: err, + } + } + } + + } + + if len(errors) > 0 { + return V1Alpha1RevisionMultiError(errors) + } + + return nil +} + +// V1Alpha1RevisionMultiError is an error wrapping multiple validation errors +// returned by V1Alpha1Revision.ValidateAll() if the designated constraints +// aren't met. +type V1Alpha1RevisionMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m V1Alpha1RevisionMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m V1Alpha1RevisionMultiError) AllErrors() []error { return m } + +// V1Alpha1RevisionValidationError is the validation error returned by +// V1Alpha1Revision.Validate if the designated constraints aren't met. +type V1Alpha1RevisionValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e V1Alpha1RevisionValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e V1Alpha1RevisionValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e V1Alpha1RevisionValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e V1Alpha1RevisionValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e V1Alpha1RevisionValidationError) ErrorName() string { return "V1Alpha1RevisionValidationError" } + +// Error satisfies the builtin error interface +func (e V1Alpha1RevisionValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sV1Alpha1Revision.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = V1Alpha1RevisionValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = V1Alpha1RevisionValidationError{} + +// Validate checks the field values on DecodedZookie_V1Zookie with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *DecodedZookie_V1Zookie) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZookie_V1Zookie with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// DecodedZookie_V1ZookieMultiError, or nil if none found. +func (m *DecodedZookie_V1Zookie) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZookie_V1Zookie) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Revision + + if len(errors) > 0 { + return DecodedZookie_V1ZookieMultiError(errors) + } + + return nil +} + +// DecodedZookie_V1ZookieMultiError is an error wrapping multiple validation +// errors returned by DecodedZookie_V1Zookie.ValidateAll() if the designated +// constraints aren't met. +type DecodedZookie_V1ZookieMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZookie_V1ZookieMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZookie_V1ZookieMultiError) AllErrors() []error { return m } + +// DecodedZookie_V1ZookieValidationError is the validation error returned by +// DecodedZookie_V1Zookie.Validate if the designated constraints aren't met. +type DecodedZookie_V1ZookieValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZookie_V1ZookieValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZookie_V1ZookieValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZookie_V1ZookieValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZookie_V1ZookieValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZookie_V1ZookieValidationError) ErrorName() string { + return "DecodedZookie_V1ZookieValidationError" +} + +// Error satisfies the builtin error interface +func (e DecodedZookie_V1ZookieValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZookie_V1Zookie.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZookie_V1ZookieValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZookie_V1ZookieValidationError{} + +// Validate checks the field values on DecodedZookie_V2Zookie with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *DecodedZookie_V2Zookie) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZookie_V2Zookie with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// DecodedZookie_V2ZookieMultiError, or nil if none found. +func (m *DecodedZookie_V2Zookie) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZookie_V2Zookie) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Revision + + if len(errors) > 0 { + return DecodedZookie_V2ZookieMultiError(errors) + } + + return nil +} + +// DecodedZookie_V2ZookieMultiError is an error wrapping multiple validation +// errors returned by DecodedZookie_V2Zookie.ValidateAll() if the designated +// constraints aren't met. +type DecodedZookie_V2ZookieMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZookie_V2ZookieMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZookie_V2ZookieMultiError) AllErrors() []error { return m } + +// DecodedZookie_V2ZookieValidationError is the validation error returned by +// DecodedZookie_V2Zookie.Validate if the designated constraints aren't met. +type DecodedZookie_V2ZookieValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZookie_V2ZookieValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZookie_V2ZookieValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZookie_V2ZookieValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZookie_V2ZookieValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZookie_V2ZookieValidationError) ErrorName() string { + return "DecodedZookie_V2ZookieValidationError" +} + +// Error satisfies the builtin error interface +func (e DecodedZookie_V2ZookieValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZookie_V2Zookie.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZookie_V2ZookieValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZookie_V2ZookieValidationError{} + +// Validate checks the field values on DecodedZedToken_V1Zookie with the rules +// defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *DecodedZedToken_V1Zookie) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZedToken_V1Zookie with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// DecodedZedToken_V1ZookieMultiError, or nil if none found. +func (m *DecodedZedToken_V1Zookie) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZedToken_V1Zookie) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Revision + + if len(errors) > 0 { + return DecodedZedToken_V1ZookieMultiError(errors) + } + + return nil +} + +// DecodedZedToken_V1ZookieMultiError is an error wrapping multiple validation +// errors returned by DecodedZedToken_V1Zookie.ValidateAll() if the designated +// constraints aren't met. +type DecodedZedToken_V1ZookieMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZedToken_V1ZookieMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZedToken_V1ZookieMultiError) AllErrors() []error { return m } + +// DecodedZedToken_V1ZookieValidationError is the validation error returned by +// DecodedZedToken_V1Zookie.Validate if the designated constraints aren't met. +type DecodedZedToken_V1ZookieValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZedToken_V1ZookieValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZedToken_V1ZookieValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZedToken_V1ZookieValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZedToken_V1ZookieValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZedToken_V1ZookieValidationError) ErrorName() string { + return "DecodedZedToken_V1ZookieValidationError" +} + +// Error satisfies the builtin error interface +func (e DecodedZedToken_V1ZookieValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZedToken_V1Zookie.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZedToken_V1ZookieValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZedToken_V1ZookieValidationError{} + +// Validate checks the field values on DecodedZedToken_V1ZedToken with the +// rules defined in the proto definition for this message. If any rules are +// violated, the first error encountered is returned, or nil if there are no violations. +func (m *DecodedZedToken_V1ZedToken) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on DecodedZedToken_V1ZedToken with the +// rules defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// DecodedZedToken_V1ZedTokenMultiError, or nil if none found. +func (m *DecodedZedToken_V1ZedToken) ValidateAll() error { + return m.validate(true) +} + +func (m *DecodedZedToken_V1ZedToken) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Revision + + if len(errors) > 0 { + return DecodedZedToken_V1ZedTokenMultiError(errors) + } + + return nil +} + +// DecodedZedToken_V1ZedTokenMultiError is an error wrapping multiple +// validation errors returned by DecodedZedToken_V1ZedToken.ValidateAll() if +// the designated constraints aren't met. +type DecodedZedToken_V1ZedTokenMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m DecodedZedToken_V1ZedTokenMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m DecodedZedToken_V1ZedTokenMultiError) AllErrors() []error { return m } + +// DecodedZedToken_V1ZedTokenValidationError is the validation error returned +// by DecodedZedToken_V1ZedToken.Validate if the designated constraints aren't met. +type DecodedZedToken_V1ZedTokenValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e DecodedZedToken_V1ZedTokenValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e DecodedZedToken_V1ZedTokenValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e DecodedZedToken_V1ZedTokenValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e DecodedZedToken_V1ZedTokenValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e DecodedZedToken_V1ZedTokenValidationError) ErrorName() string { + return "DecodedZedToken_V1ZedTokenValidationError" +} + +// Error satisfies the builtin error interface +func (e DecodedZedToken_V1ZedTokenValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sDecodedZedToken_V1ZedToken.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = DecodedZedToken_V1ZedTokenValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = DecodedZedToken_V1ZedTokenValidationError{} diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl_vtproto.pb.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl_vtproto.pb.go new file mode 100644 index 0000000..95e3685 --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/impl_vtproto.pb.go @@ -0,0 +1,3335 @@ +// Code generated by protoc-gen-go-vtproto. DO NOT EDIT. +// protoc-gen-go-vtproto version: v0.6.1-0.20240409071808-615f978279ca +// source: impl/v1/impl.proto + +package implv1 + +import ( + fmt "fmt" + protohelpers "github.com/planetscale/vtprotobuf/protohelpers" + v1alpha1 "google.golang.org/genproto/googleapis/api/expr/v1alpha1" + proto "google.golang.org/protobuf/proto" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + io "io" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +func (m *DecodedCaveat) CloneVT() *DecodedCaveat { + if m == nil { + return (*DecodedCaveat)(nil) + } + r := new(DecodedCaveat) + r.Name = m.Name + if m.KindOneof != nil { + r.KindOneof = m.KindOneof.(interface { + CloneVT() isDecodedCaveat_KindOneof + }).CloneVT() + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedCaveat) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedCaveat_Cel) CloneVT() isDecodedCaveat_KindOneof { + if m == nil { + return (*DecodedCaveat_Cel)(nil) + } + r := new(DecodedCaveat_Cel) + if rhs := m.Cel; rhs != nil { + if vtpb, ok := interface{}(rhs).(interface{ CloneVT() *v1alpha1.CheckedExpr }); ok { + r.Cel = vtpb.CloneVT() + } else { + r.Cel = proto.Clone(rhs).(*v1alpha1.CheckedExpr) + } + } + return r +} + +func (m *DecodedZookie_V1Zookie) CloneVT() *DecodedZookie_V1Zookie { + if m == nil { + return (*DecodedZookie_V1Zookie)(nil) + } + r := new(DecodedZookie_V1Zookie) + r.Revision = m.Revision + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZookie_V1Zookie) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZookie_V2Zookie) CloneVT() *DecodedZookie_V2Zookie { + if m == nil { + return (*DecodedZookie_V2Zookie)(nil) + } + r := new(DecodedZookie_V2Zookie) + r.Revision = m.Revision + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZookie_V2Zookie) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZookie) CloneVT() *DecodedZookie { + if m == nil { + return (*DecodedZookie)(nil) + } + r := new(DecodedZookie) + r.Version = m.Version + if m.VersionOneof != nil { + r.VersionOneof = m.VersionOneof.(interface { + CloneVT() isDecodedZookie_VersionOneof + }).CloneVT() + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZookie) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZookie_V1) CloneVT() isDecodedZookie_VersionOneof { + if m == nil { + return (*DecodedZookie_V1)(nil) + } + r := new(DecodedZookie_V1) + r.V1 = m.V1.CloneVT() + return r +} + +func (m *DecodedZookie_V2) CloneVT() isDecodedZookie_VersionOneof { + if m == nil { + return (*DecodedZookie_V2)(nil) + } + r := new(DecodedZookie_V2) + r.V2 = m.V2.CloneVT() + return r +} + +func (m *DecodedZedToken_V1Zookie) CloneVT() *DecodedZedToken_V1Zookie { + if m == nil { + return (*DecodedZedToken_V1Zookie)(nil) + } + r := new(DecodedZedToken_V1Zookie) + r.Revision = m.Revision + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZedToken_V1Zookie) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZedToken_V1ZedToken) CloneVT() *DecodedZedToken_V1ZedToken { + if m == nil { + return (*DecodedZedToken_V1ZedToken)(nil) + } + r := new(DecodedZedToken_V1ZedToken) + r.Revision = m.Revision + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZedToken_V1ZedToken) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZedToken) CloneVT() *DecodedZedToken { + if m == nil { + return (*DecodedZedToken)(nil) + } + r := new(DecodedZedToken) + if m.VersionOneof != nil { + r.VersionOneof = m.VersionOneof.(interface { + CloneVT() isDecodedZedToken_VersionOneof + }).CloneVT() + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedZedToken) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedZedToken_DeprecatedV1Zookie) CloneVT() isDecodedZedToken_VersionOneof { + if m == nil { + return (*DecodedZedToken_DeprecatedV1Zookie)(nil) + } + r := new(DecodedZedToken_DeprecatedV1Zookie) + r.DeprecatedV1Zookie = m.DeprecatedV1Zookie.CloneVT() + return r +} + +func (m *DecodedZedToken_V1) CloneVT() isDecodedZedToken_VersionOneof { + if m == nil { + return (*DecodedZedToken_V1)(nil) + } + r := new(DecodedZedToken_V1) + r.V1 = m.V1.CloneVT() + return r +} + +func (m *DecodedCursor) CloneVT() *DecodedCursor { + if m == nil { + return (*DecodedCursor)(nil) + } + r := new(DecodedCursor) + if m.VersionOneof != nil { + r.VersionOneof = m.VersionOneof.(interface { + CloneVT() isDecodedCursor_VersionOneof + }).CloneVT() + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DecodedCursor) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DecodedCursor_V1) CloneVT() isDecodedCursor_VersionOneof { + if m == nil { + return (*DecodedCursor_V1)(nil) + } + r := new(DecodedCursor_V1) + r.V1 = m.V1.CloneVT() + return r +} + +func (m *V1Cursor) CloneVT() *V1Cursor { + if m == nil { + return (*V1Cursor)(nil) + } + r := new(V1Cursor) + r.Revision = m.Revision + r.CallAndParametersHash = m.CallAndParametersHash + r.DispatchVersion = m.DispatchVersion + if rhs := m.Sections; rhs != nil { + tmpContainer := make([]string, len(rhs)) + copy(tmpContainer, rhs) + r.Sections = tmpContainer + } + if rhs := m.Flags; rhs != nil { + tmpContainer := make(map[string]string, len(rhs)) + for k, v := range rhs { + tmpContainer[k] = v + } + r.Flags = tmpContainer + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *V1Cursor) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *DocComment) CloneVT() *DocComment { + if m == nil { + return (*DocComment)(nil) + } + r := new(DocComment) + r.Comment = m.Comment + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *DocComment) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *RelationMetadata) CloneVT() *RelationMetadata { + if m == nil { + return (*RelationMetadata)(nil) + } + r := new(RelationMetadata) + r.Kind = m.Kind + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *RelationMetadata) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *NamespaceAndRevision) CloneVT() *NamespaceAndRevision { + if m == nil { + return (*NamespaceAndRevision)(nil) + } + r := new(NamespaceAndRevision) + r.NamespaceName = m.NamespaceName + r.Revision = m.Revision + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *NamespaceAndRevision) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (m *V1Alpha1Revision) CloneVT() *V1Alpha1Revision { + if m == nil { + return (*V1Alpha1Revision)(nil) + } + r := new(V1Alpha1Revision) + if rhs := m.NsRevisions; rhs != nil { + tmpContainer := make([]*NamespaceAndRevision, len(rhs)) + for k, v := range rhs { + tmpContainer[k] = v.CloneVT() + } + r.NsRevisions = tmpContainer + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *V1Alpha1Revision) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (this *DecodedCaveat) EqualVT(that *DecodedCaveat) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.KindOneof == nil && that.KindOneof != nil { + return false + } else if this.KindOneof != nil { + if that.KindOneof == nil { + return false + } + if !this.KindOneof.(interface { + EqualVT(isDecodedCaveat_KindOneof) bool + }).EqualVT(that.KindOneof) { + return false + } + } + if this.Name != that.Name { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedCaveat) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedCaveat) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedCaveat_Cel) EqualVT(thatIface isDecodedCaveat_KindOneof) bool { + that, ok := thatIface.(*DecodedCaveat_Cel) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.Cel, that.Cel; p != q { + if p == nil { + p = &v1alpha1.CheckedExpr{} + } + if q == nil { + q = &v1alpha1.CheckedExpr{} + } + if equal, ok := interface{}(p).(interface { + EqualVT(*v1alpha1.CheckedExpr) bool + }); ok { + if !equal.EqualVT(q) { + return false + } + } else if !proto.Equal(p, q) { + return false + } + } + return true +} + +func (this *DecodedZookie_V1Zookie) EqualVT(that *DecodedZookie_V1Zookie) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Revision != that.Revision { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZookie_V1Zookie) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZookie_V1Zookie) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZookie_V2Zookie) EqualVT(that *DecodedZookie_V2Zookie) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Revision != that.Revision { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZookie_V2Zookie) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZookie_V2Zookie) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZookie) EqualVT(that *DecodedZookie) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.VersionOneof == nil && that.VersionOneof != nil { + return false + } else if this.VersionOneof != nil { + if that.VersionOneof == nil { + return false + } + if !this.VersionOneof.(interface { + EqualVT(isDecodedZookie_VersionOneof) bool + }).EqualVT(that.VersionOneof) { + return false + } + } + if this.Version != that.Version { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZookie) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZookie) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZookie_V1) EqualVT(thatIface isDecodedZookie_VersionOneof) bool { + that, ok := thatIface.(*DecodedZookie_V1) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.V1, that.V1; p != q { + if p == nil { + p = &DecodedZookie_V1Zookie{} + } + if q == nil { + q = &DecodedZookie_V1Zookie{} + } + if !p.EqualVT(q) { + return false + } + } + return true +} + +func (this *DecodedZookie_V2) EqualVT(thatIface isDecodedZookie_VersionOneof) bool { + that, ok := thatIface.(*DecodedZookie_V2) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.V2, that.V2; p != q { + if p == nil { + p = &DecodedZookie_V2Zookie{} + } + if q == nil { + q = &DecodedZookie_V2Zookie{} + } + if !p.EqualVT(q) { + return false + } + } + return true +} + +func (this *DecodedZedToken_V1Zookie) EqualVT(that *DecodedZedToken_V1Zookie) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Revision != that.Revision { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZedToken_V1Zookie) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZedToken_V1Zookie) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZedToken_V1ZedToken) EqualVT(that *DecodedZedToken_V1ZedToken) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Revision != that.Revision { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZedToken_V1ZedToken) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZedToken_V1ZedToken) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZedToken) EqualVT(that *DecodedZedToken) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.VersionOneof == nil && that.VersionOneof != nil { + return false + } else if this.VersionOneof != nil { + if that.VersionOneof == nil { + return false + } + if !this.VersionOneof.(interface { + EqualVT(isDecodedZedToken_VersionOneof) bool + }).EqualVT(that.VersionOneof) { + return false + } + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedZedToken) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedZedToken) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedZedToken_DeprecatedV1Zookie) EqualVT(thatIface isDecodedZedToken_VersionOneof) bool { + that, ok := thatIface.(*DecodedZedToken_DeprecatedV1Zookie) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.DeprecatedV1Zookie, that.DeprecatedV1Zookie; p != q { + if p == nil { + p = &DecodedZedToken_V1Zookie{} + } + if q == nil { + q = &DecodedZedToken_V1Zookie{} + } + if !p.EqualVT(q) { + return false + } + } + return true +} + +func (this *DecodedZedToken_V1) EqualVT(thatIface isDecodedZedToken_VersionOneof) bool { + that, ok := thatIface.(*DecodedZedToken_V1) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.V1, that.V1; p != q { + if p == nil { + p = &DecodedZedToken_V1ZedToken{} + } + if q == nil { + q = &DecodedZedToken_V1ZedToken{} + } + if !p.EqualVT(q) { + return false + } + } + return true +} + +func (this *DecodedCursor) EqualVT(that *DecodedCursor) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.VersionOneof == nil && that.VersionOneof != nil { + return false + } else if this.VersionOneof != nil { + if that.VersionOneof == nil { + return false + } + if !this.VersionOneof.(interface { + EqualVT(isDecodedCursor_VersionOneof) bool + }).EqualVT(that.VersionOneof) { + return false + } + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DecodedCursor) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DecodedCursor) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DecodedCursor_V1) EqualVT(thatIface isDecodedCursor_VersionOneof) bool { + that, ok := thatIface.(*DecodedCursor_V1) + if !ok { + return false + } + if this == that { + return true + } + if this == nil && that != nil || this != nil && that == nil { + return false + } + if p, q := this.V1, that.V1; p != q { + if p == nil { + p = &V1Cursor{} + } + if q == nil { + q = &V1Cursor{} + } + if !p.EqualVT(q) { + return false + } + } + return true +} + +func (this *V1Cursor) EqualVT(that *V1Cursor) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Revision != that.Revision { + return false + } + if len(this.Sections) != len(that.Sections) { + return false + } + for i, vx := range this.Sections { + vy := that.Sections[i] + if vx != vy { + return false + } + } + if this.CallAndParametersHash != that.CallAndParametersHash { + return false + } + if this.DispatchVersion != that.DispatchVersion { + return false + } + if len(this.Flags) != len(that.Flags) { + return false + } + for i, vx := range this.Flags { + vy, ok := that.Flags[i] + if !ok { + return false + } + if vx != vy { + return false + } + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *V1Cursor) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*V1Cursor) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *DocComment) EqualVT(that *DocComment) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Comment != that.Comment { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *DocComment) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*DocComment) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *RelationMetadata) EqualVT(that *RelationMetadata) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Kind != that.Kind { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *RelationMetadata) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*RelationMetadata) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *NamespaceAndRevision) EqualVT(that *NamespaceAndRevision) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.NamespaceName != that.NamespaceName { + return false + } + if this.Revision != that.Revision { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *NamespaceAndRevision) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*NamespaceAndRevision) + if !ok { + return false + } + return this.EqualVT(that) +} +func (this *V1Alpha1Revision) EqualVT(that *V1Alpha1Revision) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if len(this.NsRevisions) != len(that.NsRevisions) { + return false + } + for i, vx := range this.NsRevisions { + vy := that.NsRevisions[i] + if p, q := vx, vy; p != q { + if p == nil { + p = &NamespaceAndRevision{} + } + if q == nil { + q = &NamespaceAndRevision{} + } + if !p.EqualVT(q) { + return false + } + } + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *V1Alpha1Revision) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*V1Alpha1Revision) + if !ok { + return false + } + return this.EqualVT(that) +} +func (m *DecodedCaveat) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedCaveat) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedCaveat) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if vtmsg, ok := m.KindOneof.(interface { + MarshalToSizedBufferVT([]byte) (int, error) + }); ok { + size, err := vtmsg.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + } + if len(m.Name) > 0 { + i -= len(m.Name) + copy(dAtA[i:], m.Name) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Name))) + i-- + dAtA[i] = 0x12 + } + return len(dAtA) - i, nil +} + +func (m *DecodedCaveat_Cel) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedCaveat_Cel) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.Cel != nil { + if vtmsg, ok := interface{}(m.Cel).(interface { + MarshalToSizedBufferVT([]byte) (int, error) + }); ok { + size, err := vtmsg.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + } else { + encoded, err := proto.Marshal(m.Cel) + if err != nil { + return 0, err + } + i -= len(encoded) + copy(dAtA[i:], encoded) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(encoded))) + } + i-- + dAtA[i] = 0xa + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} +func (m *DecodedZookie_V1Zookie) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZookie_V1Zookie) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZookie_V1Zookie) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if m.Revision != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Revision)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil +} + +func (m *DecodedZookie_V2Zookie) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZookie_V2Zookie) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZookie_V2Zookie) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.Revision) > 0 { + i -= len(m.Revision) + copy(dAtA[i:], m.Revision) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Revision))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} + +func (m *DecodedZookie) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZookie) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZookie) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if vtmsg, ok := m.VersionOneof.(interface { + MarshalToSizedBufferVT([]byte) (int, error) + }); ok { + size, err := vtmsg.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + } + if m.Version != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Version)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil +} + +func (m *DecodedZookie_V1) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZookie_V1) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.V1 != nil { + size, err := m.V1.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0x12 + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0x12 + } + return len(dAtA) - i, nil +} +func (m *DecodedZookie_V2) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZookie_V2) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.V2 != nil { + size, err := m.V2.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0x1a + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0x1a + } + return len(dAtA) - i, nil +} +func (m *DecodedZedToken_V1Zookie) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZedToken_V1Zookie) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZedToken_V1Zookie) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if m.Revision != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Revision)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil +} + +func (m *DecodedZedToken_V1ZedToken) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZedToken_V1ZedToken) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZedToken_V1ZedToken) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.Revision) > 0 { + i -= len(m.Revision) + copy(dAtA[i:], m.Revision) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Revision))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} + +func (m *DecodedZedToken) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedZedToken) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZedToken) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if vtmsg, ok := m.VersionOneof.(interface { + MarshalToSizedBufferVT([]byte) (int, error) + }); ok { + size, err := vtmsg.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + } + return len(dAtA) - i, nil +} + +func (m *DecodedZedToken_DeprecatedV1Zookie) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZedToken_DeprecatedV1Zookie) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.DeprecatedV1Zookie != nil { + size, err := m.DeprecatedV1Zookie.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0x12 + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0x12 + } + return len(dAtA) - i, nil +} +func (m *DecodedZedToken_V1) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedZedToken_V1) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.V1 != nil { + size, err := m.V1.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0x1a + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0x1a + } + return len(dAtA) - i, nil +} +func (m *DecodedCursor) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DecodedCursor) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedCursor) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if vtmsg, ok := m.VersionOneof.(interface { + MarshalToSizedBufferVT([]byte) (int, error) + }); ok { + size, err := vtmsg.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + } + return len(dAtA) - i, nil +} + +func (m *DecodedCursor_V1) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DecodedCursor_V1) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + i := len(dAtA) + if m.V1 != nil { + size, err := m.V1.MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0xa + } else { + i = protohelpers.EncodeVarint(dAtA, i, 0) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} +func (m *V1Cursor) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *V1Cursor) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *V1Cursor) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.Flags) > 0 { + for k := range m.Flags { + v := m.Flags[k] + baseI := i + i -= len(v) + copy(dAtA[i:], v) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(v))) + i-- + dAtA[i] = 0x12 + i -= len(k) + copy(dAtA[i:], k) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(k))) + i-- + dAtA[i] = 0xa + i = protohelpers.EncodeVarint(dAtA, i, uint64(baseI-i)) + i-- + dAtA[i] = 0x2a + } + } + if m.DispatchVersion != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.DispatchVersion)) + i-- + dAtA[i] = 0x20 + } + if len(m.CallAndParametersHash) > 0 { + i -= len(m.CallAndParametersHash) + copy(dAtA[i:], m.CallAndParametersHash) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.CallAndParametersHash))) + i-- + dAtA[i] = 0x1a + } + if len(m.Sections) > 0 { + for iNdEx := len(m.Sections) - 1; iNdEx >= 0; iNdEx-- { + i -= len(m.Sections[iNdEx]) + copy(dAtA[i:], m.Sections[iNdEx]) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Sections[iNdEx]))) + i-- + dAtA[i] = 0x12 + } + } + if len(m.Revision) > 0 { + i -= len(m.Revision) + copy(dAtA[i:], m.Revision) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Revision))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} + +func (m *DocComment) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *DocComment) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *DocComment) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.Comment) > 0 { + i -= len(m.Comment) + copy(dAtA[i:], m.Comment) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Comment))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} + +func (m *RelationMetadata) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *RelationMetadata) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *RelationMetadata) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if m.Kind != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Kind)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil +} + +func (m *NamespaceAndRevision) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *NamespaceAndRevision) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *NamespaceAndRevision) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.Revision) > 0 { + i -= len(m.Revision) + copy(dAtA[i:], m.Revision) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.Revision))) + i-- + dAtA[i] = 0x12 + } + if len(m.NamespaceName) > 0 { + i -= len(m.NamespaceName) + copy(dAtA[i:], m.NamespaceName) + i = protohelpers.EncodeVarint(dAtA, i, uint64(len(m.NamespaceName))) + i-- + dAtA[i] = 0xa + } + return len(dAtA) - i, nil +} + +func (m *V1Alpha1Revision) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *V1Alpha1Revision) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *V1Alpha1Revision) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if len(m.NsRevisions) > 0 { + for iNdEx := len(m.NsRevisions) - 1; iNdEx >= 0; iNdEx-- { + size, err := m.NsRevisions[iNdEx].MarshalToSizedBufferVT(dAtA[:i]) + if err != nil { + return 0, err + } + i -= size + i = protohelpers.EncodeVarint(dAtA, i, uint64(size)) + i-- + dAtA[i] = 0xa + } + } + return len(dAtA) - i, nil +} + +func (m *DecodedCaveat) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if vtmsg, ok := m.KindOneof.(interface{ SizeVT() int }); ok { + n += vtmsg.SizeVT() + } + l = len(m.Name) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedCaveat_Cel) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Cel != nil { + if size, ok := interface{}(m.Cel).(interface { + SizeVT() int + }); ok { + l = size.SizeVT() + } else { + l = proto.Size(m.Cel) + } + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *DecodedZookie_V1Zookie) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Revision != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.Revision)) + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZookie_V2Zookie) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + l = len(m.Revision) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZookie) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Version != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.Version)) + } + if vtmsg, ok := m.VersionOneof.(interface{ SizeVT() int }); ok { + n += vtmsg.SizeVT() + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZookie_V1) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.V1 != nil { + l = m.V1.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *DecodedZookie_V2) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.V2 != nil { + l = m.V2.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *DecodedZedToken_V1Zookie) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Revision != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.Revision)) + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZedToken_V1ZedToken) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + l = len(m.Revision) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZedToken) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if vtmsg, ok := m.VersionOneof.(interface{ SizeVT() int }); ok { + n += vtmsg.SizeVT() + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedZedToken_DeprecatedV1Zookie) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.DeprecatedV1Zookie != nil { + l = m.DeprecatedV1Zookie.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *DecodedZedToken_V1) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.V1 != nil { + l = m.V1.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *DecodedCursor) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if vtmsg, ok := m.VersionOneof.(interface{ SizeVT() int }); ok { + n += vtmsg.SizeVT() + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedCursor_V1) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.V1 != nil { + l = m.V1.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } else { + n += 2 + } + return n +} +func (m *V1Cursor) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + l = len(m.Revision) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + if len(m.Sections) > 0 { + for _, s := range m.Sections { + l = len(s) + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + } + l = len(m.CallAndParametersHash) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + if m.DispatchVersion != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.DispatchVersion)) + } + if len(m.Flags) > 0 { + for k, v := range m.Flags { + _ = k + _ = v + mapEntrySize := 1 + len(k) + protohelpers.SizeOfVarint(uint64(len(k))) + 1 + len(v) + protohelpers.SizeOfVarint(uint64(len(v))) + n += mapEntrySize + 1 + protohelpers.SizeOfVarint(uint64(mapEntrySize)) + } + } + n += len(m.unknownFields) + return n +} + +func (m *DocComment) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + l = len(m.Comment) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + n += len(m.unknownFields) + return n +} + +func (m *RelationMetadata) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Kind != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.Kind)) + } + n += len(m.unknownFields) + return n +} + +func (m *NamespaceAndRevision) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + l = len(m.NamespaceName) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + l = len(m.Revision) + if l > 0 { + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + n += len(m.unknownFields) + return n +} + +func (m *V1Alpha1Revision) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if len(m.NsRevisions) > 0 { + for _, e := range m.NsRevisions { + l = e.SizeVT() + n += 1 + l + protohelpers.SizeOfVarint(uint64(l)) + } + } + n += len(m.unknownFields) + return n +} + +func (m *DecodedCaveat) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedCaveat: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedCaveat: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Cel", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.KindOneof.(*DecodedCaveat_Cel); ok { + if unmarshal, ok := interface{}(oneof.Cel).(interface { + UnmarshalVT([]byte) error + }); ok { + if err := unmarshal.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + if err := proto.Unmarshal(dAtA[iNdEx:postIndex], oneof.Cel); err != nil { + return err + } + } + } else { + v := &v1alpha1.CheckedExpr{} + if unmarshal, ok := interface{}(v).(interface { + UnmarshalVT([]byte) error + }); ok { + if err := unmarshal.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + if err := proto.Unmarshal(dAtA[iNdEx:postIndex], v); err != nil { + return err + } + } + m.KindOneof = &DecodedCaveat_Cel{Cel: v} + } + iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Name = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZookie_V1Zookie) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZookie_V1Zookie: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZookie_V1Zookie: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + m.Revision = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.Revision |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZookie_V2Zookie) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZookie_V2Zookie: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZookie_V2Zookie: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Revision = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZookie) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZookie: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZookie: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field Version", wireType) + } + m.Version = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.Version |= uint32(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field V1", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.VersionOneof.(*DecodedZookie_V1); ok { + if err := oneof.V1.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + v := &DecodedZookie_V1Zookie{} + if err := v.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + m.VersionOneof = &DecodedZookie_V1{V1: v} + } + iNdEx = postIndex + case 3: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field V2", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.VersionOneof.(*DecodedZookie_V2); ok { + if err := oneof.V2.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + v := &DecodedZookie_V2Zookie{} + if err := v.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + m.VersionOneof = &DecodedZookie_V2{V2: v} + } + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZedToken_V1Zookie) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZedToken_V1Zookie: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZedToken_V1Zookie: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + m.Revision = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.Revision |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZedToken_V1ZedToken) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZedToken_V1ZedToken: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZedToken_V1ZedToken: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Revision = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedZedToken) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedZedToken: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedZedToken: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field DeprecatedV1Zookie", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.VersionOneof.(*DecodedZedToken_DeprecatedV1Zookie); ok { + if err := oneof.DeprecatedV1Zookie.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + v := &DecodedZedToken_V1Zookie{} + if err := v.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + m.VersionOneof = &DecodedZedToken_DeprecatedV1Zookie{DeprecatedV1Zookie: v} + } + iNdEx = postIndex + case 3: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field V1", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.VersionOneof.(*DecodedZedToken_V1); ok { + if err := oneof.V1.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + v := &DecodedZedToken_V1ZedToken{} + if err := v.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + m.VersionOneof = &DecodedZedToken_V1{V1: v} + } + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DecodedCursor) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DecodedCursor: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DecodedCursor: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field V1", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if oneof, ok := m.VersionOneof.(*DecodedCursor_V1); ok { + if err := oneof.V1.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + } else { + v := &V1Cursor{} + if err := v.UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + m.VersionOneof = &DecodedCursor_V1{V1: v} + } + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *V1Cursor) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: V1Cursor: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: V1Cursor: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Revision = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Sections", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Sections = append(m.Sections, string(dAtA[iNdEx:postIndex])) + iNdEx = postIndex + case 3: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field CallAndParametersHash", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.CallAndParametersHash = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 4: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field DispatchVersion", wireType) + } + m.DispatchVersion = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.DispatchVersion |= uint32(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 5: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Flags", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + if m.Flags == nil { + m.Flags = make(map[string]string) + } + var mapkey string + var mapvalue string + for iNdEx < postIndex { + entryPreIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + if fieldNum == 1 { + var stringLenmapkey uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLenmapkey |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLenmapkey := int(stringLenmapkey) + if intStringLenmapkey < 0 { + return protohelpers.ErrInvalidLength + } + postStringIndexmapkey := iNdEx + intStringLenmapkey + if postStringIndexmapkey < 0 { + return protohelpers.ErrInvalidLength + } + if postStringIndexmapkey > l { + return io.ErrUnexpectedEOF + } + mapkey = string(dAtA[iNdEx:postStringIndexmapkey]) + iNdEx = postStringIndexmapkey + } else if fieldNum == 2 { + var stringLenmapvalue uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLenmapvalue |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLenmapvalue := int(stringLenmapvalue) + if intStringLenmapvalue < 0 { + return protohelpers.ErrInvalidLength + } + postStringIndexmapvalue := iNdEx + intStringLenmapvalue + if postStringIndexmapvalue < 0 { + return protohelpers.ErrInvalidLength + } + if postStringIndexmapvalue > l { + return io.ErrUnexpectedEOF + } + mapvalue = string(dAtA[iNdEx:postStringIndexmapvalue]) + iNdEx = postStringIndexmapvalue + } else { + iNdEx = entryPreIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > postIndex { + return io.ErrUnexpectedEOF + } + iNdEx += skippy + } + } + m.Flags[mapkey] = mapvalue + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *DocComment) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: DocComment: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: DocComment: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Comment", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Comment = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *RelationMetadata) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: RelationMetadata: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: RelationMetadata: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field Kind", wireType) + } + m.Kind = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.Kind |= RelationMetadata_RelationKind(b&0x7F) << shift + if b < 0x80 { + break + } + } + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *NamespaceAndRevision) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: NamespaceAndRevision: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: NamespaceAndRevision: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field NamespaceName", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.NamespaceName = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 2: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + intStringLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Revision = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} +func (m *V1Alpha1Revision) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: V1Alpha1Revision: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: V1Alpha1Revision: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field NsRevisions", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + msglen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.NsRevisions = append(m.NsRevisions, &NamespaceAndRevision{}) + if err := m.NsRevisions[len(m.NsRevisions)-1].UnmarshalVT(dAtA[iNdEx:postIndex]); err != nil { + return err + } + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.go new file mode 100644 index 0000000..71525dc --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.go @@ -0,0 +1,204 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.34.2 +// protoc (unknown) +// source: impl/v1/pgrevision.proto + +package implv1 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +// * +// PostgresRevision is a compact binary encoding of a postgres snapshot as +// described in the offial documentation here: +// https://www.postgresql.org/docs/current/functions-info.html#FUNCTIONS-PG-SNAPSHOT-PARTS +// +// We use relative offsets for xmax and the xips to reduce the number of bytes +// required for binary encoding using the protobuf varint datatype: +// https://protobuf.dev/programming-guides/encoding/#varints +type PostgresRevision struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Xmin uint64 `protobuf:"varint,1,opt,name=xmin,proto3" json:"xmin,omitempty"` + RelativeXmax int64 `protobuf:"varint,2,opt,name=relative_xmax,json=relativeXmax,proto3" json:"relative_xmax,omitempty"` + RelativeXips []int64 `protobuf:"varint,3,rep,packed,name=relative_xips,json=relativeXips,proto3" json:"relative_xips,omitempty"` + // these are optional fields that are only present in strategic places that + // need the information, but otherwise is omitted to reduce the overhead + // of loading it from the DB and keeping it around in memory + OptionalTxid uint64 `protobuf:"varint,4,opt,name=optional_txid,json=optionalTxid,proto3" json:"optional_txid,omitempty"` + OptionalTimestamp uint64 `protobuf:"varint,5,opt,name=optional_timestamp,json=optionalTimestamp,proto3" json:"optional_timestamp,omitempty"` +} + +func (x *PostgresRevision) Reset() { + *x = PostgresRevision{} + if protoimpl.UnsafeEnabled { + mi := &file_impl_v1_pgrevision_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PostgresRevision) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PostgresRevision) ProtoMessage() {} + +func (x *PostgresRevision) ProtoReflect() protoreflect.Message { + mi := &file_impl_v1_pgrevision_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PostgresRevision.ProtoReflect.Descriptor instead. +func (*PostgresRevision) Descriptor() ([]byte, []int) { + return file_impl_v1_pgrevision_proto_rawDescGZIP(), []int{0} +} + +func (x *PostgresRevision) GetXmin() uint64 { + if x != nil { + return x.Xmin + } + return 0 +} + +func (x *PostgresRevision) GetRelativeXmax() int64 { + if x != nil { + return x.RelativeXmax + } + return 0 +} + +func (x *PostgresRevision) GetRelativeXips() []int64 { + if x != nil { + return x.RelativeXips + } + return nil +} + +func (x *PostgresRevision) GetOptionalTxid() uint64 { + if x != nil { + return x.OptionalTxid + } + return 0 +} + +func (x *PostgresRevision) GetOptionalTimestamp() uint64 { + if x != nil { + return x.OptionalTimestamp + } + return 0 +} + +var File_impl_v1_pgrevision_proto protoreflect.FileDescriptor + +var file_impl_v1_pgrevision_proto_rawDesc = []byte{ + 0x0a, 0x18, 0x69, 0x6d, 0x70, 0x6c, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x67, 0x72, 0x65, 0x76, 0x69, + 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x07, 0x69, 0x6d, 0x70, 0x6c, + 0x2e, 0x76, 0x31, 0x22, 0xc4, 0x01, 0x0a, 0x10, 0x50, 0x6f, 0x73, 0x74, 0x67, 0x72, 0x65, 0x73, + 0x52, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x78, 0x6d, 0x69, 0x6e, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x04, 0x78, 0x6d, 0x69, 0x6e, 0x12, 0x23, 0x0a, 0x0d, + 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x76, 0x65, 0x5f, 0x78, 0x6d, 0x61, 0x78, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x03, 0x52, 0x0c, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x76, 0x65, 0x58, 0x6d, 0x61, + 0x78, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, 0x76, 0x65, 0x5f, 0x78, 0x69, + 0x70, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x03, 0x52, 0x0c, 0x72, 0x65, 0x6c, 0x61, 0x74, 0x69, + 0x76, 0x65, 0x58, 0x69, 0x70, 0x73, 0x12, 0x23, 0x0a, 0x0d, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, + 0x61, 0x6c, 0x5f, 0x74, 0x78, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6f, + 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x54, 0x78, 0x69, 0x64, 0x12, 0x2d, 0x0a, 0x12, 0x6f, + 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x61, 0x6c, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, + 0x70, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x11, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x61, + 0x6c, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x90, 0x01, 0x0a, 0x0b, 0x63, + 0x6f, 0x6d, 0x2e, 0x69, 0x6d, 0x70, 0x6c, 0x2e, 0x76, 0x31, 0x42, 0x0f, 0x50, 0x67, 0x72, 0x65, + 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x33, 0x67, + 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x7a, 0x65, + 0x64, 0x2f, 0x73, 0x70, 0x69, 0x63, 0x65, 0x64, 0x62, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, + 0x6f, 0x74, 0x6f, 0x2f, 0x69, 0x6d, 0x70, 0x6c, 0x2f, 0x76, 0x31, 0x3b, 0x69, 0x6d, 0x70, 0x6c, + 0x76, 0x31, 0xa2, 0x02, 0x03, 0x49, 0x58, 0x58, 0xaa, 0x02, 0x07, 0x49, 0x6d, 0x70, 0x6c, 0x2e, + 0x56, 0x31, 0xca, 0x02, 0x07, 0x49, 0x6d, 0x70, 0x6c, 0x5c, 0x56, 0x31, 0xe2, 0x02, 0x13, 0x49, + 0x6d, 0x70, 0x6c, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, + 0x74, 0x61, 0xea, 0x02, 0x08, 0x49, 0x6d, 0x70, 0x6c, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_impl_v1_pgrevision_proto_rawDescOnce sync.Once + file_impl_v1_pgrevision_proto_rawDescData = file_impl_v1_pgrevision_proto_rawDesc +) + +func file_impl_v1_pgrevision_proto_rawDescGZIP() []byte { + file_impl_v1_pgrevision_proto_rawDescOnce.Do(func() { + file_impl_v1_pgrevision_proto_rawDescData = protoimpl.X.CompressGZIP(file_impl_v1_pgrevision_proto_rawDescData) + }) + return file_impl_v1_pgrevision_proto_rawDescData +} + +var file_impl_v1_pgrevision_proto_msgTypes = make([]protoimpl.MessageInfo, 1) +var file_impl_v1_pgrevision_proto_goTypes = []any{ + (*PostgresRevision)(nil), // 0: impl.v1.PostgresRevision +} +var file_impl_v1_pgrevision_proto_depIdxs = []int32{ + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] is the sub-list for method input_type + 0, // [0:0] is the sub-list for extension type_name + 0, // [0:0] is the sub-list for extension extendee + 0, // [0:0] is the sub-list for field type_name +} + +func init() { file_impl_v1_pgrevision_proto_init() } +func file_impl_v1_pgrevision_proto_init() { + if File_impl_v1_pgrevision_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_impl_v1_pgrevision_proto_msgTypes[0].Exporter = func(v any, i int) any { + switch v := v.(*PostgresRevision); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_impl_v1_pgrevision_proto_rawDesc, + NumEnums: 0, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_impl_v1_pgrevision_proto_goTypes, + DependencyIndexes: file_impl_v1_pgrevision_proto_depIdxs, + MessageInfos: file_impl_v1_pgrevision_proto_msgTypes, + }.Build() + File_impl_v1_pgrevision_proto = out.File + file_impl_v1_pgrevision_proto_rawDesc = nil + file_impl_v1_pgrevision_proto_goTypes = nil + file_impl_v1_pgrevision_proto_depIdxs = nil +} diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.validate.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.validate.go new file mode 100644 index 0000000..db12ba4 --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision.pb.validate.go @@ -0,0 +1,144 @@ +// Code generated by protoc-gen-validate. DO NOT EDIT. +// source: impl/v1/pgrevision.proto + +package implv1 + +import ( + "bytes" + "errors" + "fmt" + "net" + "net/mail" + "net/url" + "regexp" + "sort" + "strings" + "time" + "unicode/utf8" + + "google.golang.org/protobuf/types/known/anypb" +) + +// ensure the imports are used +var ( + _ = bytes.MinRead + _ = errors.New("") + _ = fmt.Print + _ = utf8.UTFMax + _ = (*regexp.Regexp)(nil) + _ = (*strings.Reader)(nil) + _ = net.IPv4len + _ = time.Duration(0) + _ = (*url.URL)(nil) + _ = (*mail.Address)(nil) + _ = anypb.Any{} + _ = sort.Sort +) + +// Validate checks the field values on PostgresRevision with the rules defined +// in the proto definition for this message. If any rules are violated, the +// first error encountered is returned, or nil if there are no violations. +func (m *PostgresRevision) Validate() error { + return m.validate(false) +} + +// ValidateAll checks the field values on PostgresRevision with the rules +// defined in the proto definition for this message. If any rules are +// violated, the result is a list of violation errors wrapped in +// PostgresRevisionMultiError, or nil if none found. +func (m *PostgresRevision) ValidateAll() error { + return m.validate(true) +} + +func (m *PostgresRevision) validate(all bool) error { + if m == nil { + return nil + } + + var errors []error + + // no validation rules for Xmin + + // no validation rules for RelativeXmax + + // no validation rules for OptionalTxid + + // no validation rules for OptionalTimestamp + + if len(errors) > 0 { + return PostgresRevisionMultiError(errors) + } + + return nil +} + +// PostgresRevisionMultiError is an error wrapping multiple validation errors +// returned by PostgresRevision.ValidateAll() if the designated constraints +// aren't met. +type PostgresRevisionMultiError []error + +// Error returns a concatenation of all the error messages it wraps. +func (m PostgresRevisionMultiError) Error() string { + var msgs []string + for _, err := range m { + msgs = append(msgs, err.Error()) + } + return strings.Join(msgs, "; ") +} + +// AllErrors returns a list of validation violation errors. +func (m PostgresRevisionMultiError) AllErrors() []error { return m } + +// PostgresRevisionValidationError is the validation error returned by +// PostgresRevision.Validate if the designated constraints aren't met. +type PostgresRevisionValidationError struct { + field string + reason string + cause error + key bool +} + +// Field function returns field value. +func (e PostgresRevisionValidationError) Field() string { return e.field } + +// Reason function returns reason value. +func (e PostgresRevisionValidationError) Reason() string { return e.reason } + +// Cause function returns cause value. +func (e PostgresRevisionValidationError) Cause() error { return e.cause } + +// Key function returns key value. +func (e PostgresRevisionValidationError) Key() bool { return e.key } + +// ErrorName returns error name. +func (e PostgresRevisionValidationError) ErrorName() string { return "PostgresRevisionValidationError" } + +// Error satisfies the builtin error interface +func (e PostgresRevisionValidationError) Error() string { + cause := "" + if e.cause != nil { + cause = fmt.Sprintf(" | caused by: %v", e.cause) + } + + key := "" + if e.key { + key = "key for " + } + + return fmt.Sprintf( + "invalid %sPostgresRevision.%s: %s%s", + key, + e.field, + e.reason, + cause) +} + +var _ error = PostgresRevisionValidationError{} + +var _ interface { + Field() string + Reason() string + Key() bool + Cause() error + ErrorName() string +} = PostgresRevisionValidationError{} diff --git a/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision_vtproto.pb.go b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision_vtproto.pb.go new file mode 100644 index 0000000..c7a9dff --- /dev/null +++ b/vendor/github.com/authzed/spicedb/pkg/proto/impl/v1/pgrevision_vtproto.pb.go @@ -0,0 +1,389 @@ +// Code generated by protoc-gen-go-vtproto. DO NOT EDIT. +// protoc-gen-go-vtproto version: v0.6.1-0.20240409071808-615f978279ca +// source: impl/v1/pgrevision.proto + +package implv1 + +import ( + fmt "fmt" + protohelpers "github.com/planetscale/vtprotobuf/protohelpers" + proto "google.golang.org/protobuf/proto" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + io "io" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +func (m *PostgresRevision) CloneVT() *PostgresRevision { + if m == nil { + return (*PostgresRevision)(nil) + } + r := new(PostgresRevision) + r.Xmin = m.Xmin + r.RelativeXmax = m.RelativeXmax + r.OptionalTxid = m.OptionalTxid + r.OptionalTimestamp = m.OptionalTimestamp + if rhs := m.RelativeXips; rhs != nil { + tmpContainer := make([]int64, len(rhs)) + copy(tmpContainer, rhs) + r.RelativeXips = tmpContainer + } + if len(m.unknownFields) > 0 { + r.unknownFields = make([]byte, len(m.unknownFields)) + copy(r.unknownFields, m.unknownFields) + } + return r +} + +func (m *PostgresRevision) CloneMessageVT() proto.Message { + return m.CloneVT() +} + +func (this *PostgresRevision) EqualVT(that *PostgresRevision) bool { + if this == that { + return true + } else if this == nil || that == nil { + return false + } + if this.Xmin != that.Xmin { + return false + } + if this.RelativeXmax != that.RelativeXmax { + return false + } + if len(this.RelativeXips) != len(that.RelativeXips) { + return false + } + for i, vx := range this.RelativeXips { + vy := that.RelativeXips[i] + if vx != vy { + return false + } + } + if this.OptionalTxid != that.OptionalTxid { + return false + } + if this.OptionalTimestamp != that.OptionalTimestamp { + return false + } + return string(this.unknownFields) == string(that.unknownFields) +} + +func (this *PostgresRevision) EqualMessageVT(thatMsg proto.Message) bool { + that, ok := thatMsg.(*PostgresRevision) + if !ok { + return false + } + return this.EqualVT(that) +} +func (m *PostgresRevision) MarshalVT() (dAtA []byte, err error) { + if m == nil { + return nil, nil + } + size := m.SizeVT() + dAtA = make([]byte, size) + n, err := m.MarshalToSizedBufferVT(dAtA[:size]) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *PostgresRevision) MarshalToVT(dAtA []byte) (int, error) { + size := m.SizeVT() + return m.MarshalToSizedBufferVT(dAtA[:size]) +} + +func (m *PostgresRevision) MarshalToSizedBufferVT(dAtA []byte) (int, error) { + if m == nil { + return 0, nil + } + i := len(dAtA) + _ = i + var l int + _ = l + if m.unknownFields != nil { + i -= len(m.unknownFields) + copy(dAtA[i:], m.unknownFields) + } + if m.OptionalTimestamp != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.OptionalTimestamp)) + i-- + dAtA[i] = 0x28 + } + if m.OptionalTxid != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.OptionalTxid)) + i-- + dAtA[i] = 0x20 + } + if len(m.RelativeXips) > 0 { + var pksize2 int + for _, num := range m.RelativeXips { + pksize2 += protohelpers.SizeOfVarint(uint64(num)) + } + i -= pksize2 + j1 := i + for _, num1 := range m.RelativeXips { + num := uint64(num1) + for num >= 1<<7 { + dAtA[j1] = uint8(uint64(num)&0x7f | 0x80) + num >>= 7 + j1++ + } + dAtA[j1] = uint8(num) + j1++ + } + i = protohelpers.EncodeVarint(dAtA, i, uint64(pksize2)) + i-- + dAtA[i] = 0x1a + } + if m.RelativeXmax != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.RelativeXmax)) + i-- + dAtA[i] = 0x10 + } + if m.Xmin != 0 { + i = protohelpers.EncodeVarint(dAtA, i, uint64(m.Xmin)) + i-- + dAtA[i] = 0x8 + } + return len(dAtA) - i, nil +} + +func (m *PostgresRevision) SizeVT() (n int) { + if m == nil { + return 0 + } + var l int + _ = l + if m.Xmin != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.Xmin)) + } + if m.RelativeXmax != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.RelativeXmax)) + } + if len(m.RelativeXips) > 0 { + l = 0 + for _, e := range m.RelativeXips { + l += protohelpers.SizeOfVarint(uint64(e)) + } + n += 1 + protohelpers.SizeOfVarint(uint64(l)) + l + } + if m.OptionalTxid != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.OptionalTxid)) + } + if m.OptionalTimestamp != 0 { + n += 1 + protohelpers.SizeOfVarint(uint64(m.OptionalTimestamp)) + } + n += len(m.unknownFields) + return n +} + +func (m *PostgresRevision) UnmarshalVT(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: PostgresRevision: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: PostgresRevision: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field Xmin", wireType) + } + m.Xmin = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.Xmin |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 2: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field RelativeXmax", wireType) + } + m.RelativeXmax = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.RelativeXmax |= int64(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 3: + if wireType == 0 { + var v int64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + v |= int64(b&0x7F) << shift + if b < 0x80 { + break + } + } + m.RelativeXips = append(m.RelativeXips, v) + } else if wireType == 2 { + var packedLen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + packedLen |= int(b&0x7F) << shift + if b < 0x80 { + break + } + } + if packedLen < 0 { + return protohelpers.ErrInvalidLength + } + postIndex := iNdEx + packedLen + if postIndex < 0 { + return protohelpers.ErrInvalidLength + } + if postIndex > l { + return io.ErrUnexpectedEOF + } + var elementCount int + var count int + for _, integer := range dAtA[iNdEx:postIndex] { + if integer < 128 { + count++ + } + } + elementCount = count + if elementCount != 0 && len(m.RelativeXips) == 0 { + m.RelativeXips = make([]int64, 0, elementCount) + } + for iNdEx < postIndex { + var v int64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + v |= int64(b&0x7F) << shift + if b < 0x80 { + break + } + } + m.RelativeXips = append(m.RelativeXips, v) + } + } else { + return fmt.Errorf("proto: wrong wireType = %d for field RelativeXips", wireType) + } + case 4: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field OptionalTxid", wireType) + } + m.OptionalTxid = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.OptionalTxid |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + case 5: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field OptionalTimestamp", wireType) + } + m.OptionalTimestamp = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return protohelpers.ErrIntOverflow + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.OptionalTimestamp |= uint64(b&0x7F) << shift + if b < 0x80 { + break + } + } + default: + iNdEx = preIndex + skippy, err := protohelpers.Skip(dAtA[iNdEx:]) + if err != nil { + return err + } + if (skippy < 0) || (iNdEx+skippy) < 0 { + return protohelpers.ErrInvalidLength + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} |