proto

May 27, 2024

Changes in this version

+ const DBController_DeleteCache_FullMethodName

type DBControllerClient

+ DeleteCache func(ctx context.Context, in *CacheRequest, opts ...grpc.CallOption) (*proto.DefaultResponse, error)

type DBControllerServer

+ DeleteCache func(context.Context, *CacheRequest) (*proto.DefaultResponse, error)

type UnimplementedDBControllerServer

+ func (UnimplementedDBControllerServer) DeleteCache(context.Context, *CacheRequest) (*proto.DefaultResponse, error)

May 26, 2024

Changes in this version

type IngestMetadata

+ Error *string

+ func (x *IngestMetadata) GetError() string

May 26, 2024

Changes in this version

type IngestItem

+ Error *string

+ func (x *IngestItem) GetError() string

May 26, 2024

Changes in this version

type Item

+ Error string

+ func (x *Item) GetError() string

May 26, 2024

Changes in this version

type IngestMetadata

+ FullMetadata string

+ func (x *IngestMetadata) GetFullMetadata() string

May 26, 2024

Changes in this version

+ const DBController_GetItemMetadata_FullMethodName

type DBControllerClient

+ GetItemMetadata func(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)

type DBControllerServer

+ GetItemMetadata func(context.Context, *ItemIdentifier) (*wrapperspb.StringValue, error)

type UnimplementedDBControllerServer

+ func (UnimplementedDBControllerServer) GetItemMetadata(context.Context, *ItemIdentifier) (*wrapperspb.StringValue, error)

May 26, 2024

Changes in this version

+ const DBController_InsertCache_FullMethodName

type DBControllerClient

+ InsertCache func(ctx context.Context, in *Cache, opts ...grpc.CallOption) (*proto.DefaultResponse, error)

type DBControllerServer

+ InsertCache func(context.Context, *Cache) (*proto.DefaultResponse, error)

type UnimplementedDBControllerServer

+ func (UnimplementedDBControllerServer) InsertCache(context.Context, *Cache) (*proto.DefaultResponse, error)

May 26, 2024

Changes in this version

type CacheMetadata

+ Storage *Storage

+ func (x *CacheMetadata) GetStorage() *Storage

May 24, 2024

Changes in this version

+ const DBController_GetCache_FullMethodName

+ type CacheRequest struct

+ Action string

+ Identifier *ItemIdentifier

+ Params string

+ func (*CacheRequest) Descriptor() ([]byte, []int)

+ func (*CacheRequest) ProtoMessage()

+ func (x *CacheRequest) GetAction() string

+ func (x *CacheRequest) GetIdentifier() *ItemIdentifier

+ func (x *CacheRequest) GetParams() string

+ func (x *CacheRequest) ProtoReflect() protoreflect.Message

+ func (x *CacheRequest) Reset()

+ func (x *CacheRequest) String() string

type DBControllerClient

+ GetCache func(ctx context.Context, in *CacheRequest, opts ...grpc.CallOption) (*Cache, error)

type DBControllerServer

+ GetCache func(context.Context, *CacheRequest) (*Cache, error)

type UnimplementedDBControllerServer

+ func (UnimplementedDBControllerServer) GetCache(context.Context, *CacheRequest) (*Cache, error)

May 22, 2024

Changes in this version

+ const DBController_SetCache_FullMethodName

+ type CollectionsResponse struct

+ Collections []*Collection

+ Page *proto.PageResponse

+ func (*CollectionsResponse) Descriptor() ([]byte, []int)

+ func (*CollectionsResponse) ProtoMessage()

+ func (x *CollectionsResponse) GetCollections() []*Collection

+ func (x *CollectionsResponse) GetPage() *proto.PageResponse

+ func (x *CollectionsResponse) ProtoReflect() protoreflect.Message

+ func (x *CollectionsResponse) Reset()

+ func (x *CollectionsResponse) String() string

type DBControllerClient

+ SetCache func(ctx context.Context, in *Cache, opts ...grpc.CallOption) (*proto.DefaultResponse, error)

type DBControllerServer

+ SetCache func(context.Context, *Cache) (*proto.DefaultResponse, error)

+ type DBController_GetCollectionsClient interface

+ Recv func() (*Collection, error)

+ type DBController_GetCollectionsServer interface

+ Send func(*Collection) error

type UnimplementedDBControllerServer

+ func (UnimplementedDBControllerServer) SetCache(context.Context, *Cache) (*proto.DefaultResponse, error)

May 14, 2024

Changes in this version

+ const DBController_CreateItem_FullMethodName

+ const DBController_DeleteItem_FullMethodName

+ const DBController_ExistsItem_FullMethodName

+ const DBController_GetCollection_FullMethodName

+ const DBController_GetCollections_FullMethodName

+ const DBController_GetIngestItem_FullMethodName

+ const DBController_GetItem_FullMethodName

+ const DBController_GetStorage_FullMethodName

+ const DBController_Ping_FullMethodName

+ const DBController_SetIngestItem_FullMethodName

+ var DBController_ServiceDesc = grpc.ServiceDesc

+ var File_cache_proto protoreflect.FileDescriptor

+ var File_collection_proto protoreflect.FileDescriptor

+ var File_dbcontroller_proto protoreflect.FileDescriptor

+ var File_defaultResponse_proto protoreflect.FileDescriptor

+ var File_item_proto protoreflect.FileDescriptor

+ var File_pageToken_proto protoreflect.FileDescriptor

+ var File_storage_proto protoreflect.FileDescriptor

+ var IngestType_name = map[int32]string

+ var IngestType_value = map[string]int32

+ var ResultStatus_name = map[int32]string

+ var ResultStatus_value = map[string]int32

+ func RegisterDBControllerServer(s grpc.ServiceRegistrar, srv DBControllerServer)

+ type Cache struct

+ Identifier *ItemIdentifier

+ Metadata *CacheMetadata

+ func (*Cache) Descriptor() ([]byte, []int)

+ func (*Cache) ProtoMessage()

+ func (x *Cache) GetIdentifier() *ItemIdentifier

+ func (x *Cache) GetMetadata() *CacheMetadata

+ func (x *Cache) ProtoReflect() protoreflect.Message

+ func (x *Cache) Reset()

+ func (x *Cache) String() string

+ type CacheMetadata struct

+ Action string

+ Duration int64

+ Height int64

+ MimeType string

+ Params string

+ Path string

+ Size int64

+ StorageName *string

+ Width int64

+ func (*CacheMetadata) Descriptor() ([]byte, []int)

+ func (*CacheMetadata) ProtoMessage()

+ func (x *CacheMetadata) GetAction() string

+ func (x *CacheMetadata) GetDuration() int64

+ func (x *CacheMetadata) GetHeight() int64

+ func (x *CacheMetadata) GetMimeType() string

+ func (x *CacheMetadata) GetParams() string

+ func (x *CacheMetadata) GetPath() string

+ func (x *CacheMetadata) GetSize() int64

+ func (x *CacheMetadata) GetStorageName() string

+ func (x *CacheMetadata) GetWidth() int64

+ func (x *CacheMetadata) ProtoReflect() protoreflect.Message

+ func (x *CacheMetadata) Reset()

+ func (x *CacheMetadata) String() string

+ type Collection struct

+ Description string

+ Jwtkey string

+ Name string

+ Public string

+ Secret string

+ SignaturePrefix string

+ Storage *Storage

+ func (*Collection) Descriptor() ([]byte, []int)

+ func (*Collection) ProtoMessage()

+ func (x *Collection) GetDescription() string

+ func (x *Collection) GetJwtkey() string

+ func (x *Collection) GetName() string

+ func (x *Collection) GetPublic() string

+ func (x *Collection) GetSecret() string

+ func (x *Collection) GetSignaturePrefix() string

+ func (x *Collection) GetStorage() *Storage

+ func (x *Collection) ProtoReflect() protoreflect.Message

+ func (x *Collection) Reset()

+ func (x *Collection) String() string

+ type CollectionIdentifier struct

+ Collection string

+ func (*CollectionIdentifier) Descriptor() ([]byte, []int)

+ func (*CollectionIdentifier) ProtoMessage()

+ func (x *CollectionIdentifier) GetCollection() string

+ func (x *CollectionIdentifier) ProtoReflect() protoreflect.Message

+ func (x *CollectionIdentifier) Reset()

+ func (x *CollectionIdentifier) String() string

+ type Collections struct

+ Collections []*Collection

+ NextPageToken *PageToken

+ func (*Collections) Descriptor() ([]byte, []int)

+ func (*Collections) ProtoMessage()

+ func (x *Collections) GetCollections() []*Collection

+ func (x *Collections) GetNextPageToken() *PageToken

+ func (x *Collections) ProtoReflect() protoreflect.Message

+ func (x *Collections) Reset()

+ func (x *Collections) String() string

+ type DBControllerClient interface

+ CreateItem func(ctx context.Context, in *NewItem, opts ...grpc.CallOption) (*DefaultResponse, error)

+ DeleteItem func(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*DefaultResponse, error)

+ ExistsItem func(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*DefaultResponse, error)

+ GetCollection func(ctx context.Context, in *CollectionIdentifier, opts ...grpc.CallOption) (*Collection, error)

+ GetCollections func(ctx context.Context, in *PageToken, opts ...grpc.CallOption) (*Collections, error)

+ GetIngestItem func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IngestItem, error)

+ GetItem func(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*Item, error)

+ GetStorage func(ctx context.Context, in *StorageIdentifier, opts ...grpc.CallOption) (*Storage, error)

+ Ping func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DefaultResponse, error)

+ SetIngestItem func(ctx context.Context, in *IngestMetadata, opts ...grpc.CallOption) (*DefaultResponse, error)

+ func NewDBControllerClient(cc grpc.ClientConnInterface) DBControllerClient

+ type DBControllerServer interface

+ CreateItem func(context.Context, *NewItem) (*DefaultResponse, error)

+ DeleteItem func(context.Context, *ItemIdentifier) (*DefaultResponse, error)

+ ExistsItem func(context.Context, *ItemIdentifier) (*DefaultResponse, error)

+ GetCollection func(context.Context, *CollectionIdentifier) (*Collection, error)

+ GetCollections func(context.Context, *PageToken) (*Collections, error)

+ GetIngestItem func(context.Context, *emptypb.Empty) (*IngestItem, error)

+ GetItem func(context.Context, *ItemIdentifier) (*Item, error)

+ GetStorage func(context.Context, *StorageIdentifier) (*Storage, error)

+ Ping func(context.Context, *emptypb.Empty) (*DefaultResponse, error)

+ SetIngestItem func(context.Context, *IngestMetadata) (*DefaultResponse, error)

+ type DefaultResponse struct

+ Data *anypb.Any

+ Message string

+ Status ResultStatus

+ func (*DefaultResponse) Descriptor() ([]byte, []int)

+ func (*DefaultResponse) ProtoMessage()

+ func (x *DefaultResponse) GetData() *anypb.Any

+ func (x *DefaultResponse) GetMessage() string

+ func (x *DefaultResponse) GetStatus() ResultStatus

+ func (x *DefaultResponse) ProtoReflect() protoreflect.Message

+ func (x *DefaultResponse) Reset()

+ func (x *DefaultResponse) String() string

+ type IngestItem struct

+ Collection *Collection

+ Identifier *ItemIdentifier

+ IngestType IngestType

+ Urn string

+ func (*IngestItem) Descriptor() ([]byte, []int)

+ func (*IngestItem) ProtoMessage()

+ func (x *IngestItem) GetCollection() *Collection

+ func (x *IngestItem) GetIdentifier() *ItemIdentifier

+ func (x *IngestItem) GetIngestType() IngestType

+ func (x *IngestItem) GetUrn() string

+ func (x *IngestItem) ProtoReflect() protoreflect.Message

+ func (x *IngestItem) Reset()

+ func (x *IngestItem) String() string

+ type IngestMetadata struct

+ CacheMetadata *CacheMetadata

+ Item *ItemIdentifier

+ ItemMetadata *ItemMetadata

+ Status string

+ func (*IngestMetadata) Descriptor() ([]byte, []int)

+ func (*IngestMetadata) ProtoMessage()

+ func (x *IngestMetadata) GetCacheMetadata() *CacheMetadata

+ func (x *IngestMetadata) GetItem() *ItemIdentifier

+ func (x *IngestMetadata) GetItemMetadata() *ItemMetadata

+ func (x *IngestMetadata) GetStatus() string

+ func (x *IngestMetadata) ProtoReflect() protoreflect.Message

+ func (x *IngestMetadata) Reset()

+ func (x *IngestMetadata) String() string

+ type IngestType int32

+ const IngestType_COPY

+ const IngestType_KEEP

+ const IngestType_MOVE

+ func (IngestType) Descriptor() protoreflect.EnumDescriptor

+ func (IngestType) EnumDescriptor() ([]byte, []int)

+ func (IngestType) Type() protoreflect.EnumType

+ func (x IngestType) Enum() *IngestType

+ func (x IngestType) Number() protoreflect.EnumNumber

+ func (x IngestType) String() string

+ type Item struct

+ Created *timestamppb.Timestamp

+ Disabled bool

+ Identifier *ItemIdentifier

+ Metadata *ItemMetadata

+ Parent *ItemIdentifier

+ Public bool

+ PublicActions []byte

+ Status string

+ Updated *timestamppb.Timestamp

+ Urn string

+ func (*Item) Descriptor() ([]byte, []int)

+ func (*Item) ProtoMessage()

+ func (x *Item) GetCreated() *timestamppb.Timestamp

+ func (x *Item) GetDisabled() bool

+ func (x *Item) GetIdentifier() *ItemIdentifier

+ func (x *Item) GetMetadata() *ItemMetadata

+ func (x *Item) GetParent() *ItemIdentifier

+ func (x *Item) GetPublic() bool

+ func (x *Item) GetPublicActions() []byte

+ func (x *Item) GetStatus() string

+ func (x *Item) GetUpdated() *timestamppb.Timestamp

+ func (x *Item) GetUrn() string

+ func (x *Item) ProtoReflect() protoreflect.Message

+ func (x *Item) Reset()

+ func (x *Item) String() string

+ type ItemIdentifier struct

+ Collection string

+ Signature string

+ func (*ItemIdentifier) Descriptor() ([]byte, []int)

+ func (*ItemIdentifier) ProtoMessage()

+ func (x *ItemIdentifier) GetCollection() string

+ func (x *ItemIdentifier) GetSignature() string

+ func (x *ItemIdentifier) ProtoReflect() protoreflect.Message

+ func (x *ItemIdentifier) Reset()

+ func (x *ItemIdentifier) String() string

+ type ItemMetadata struct

+ Error *string

+ Metadata []byte

+ Mimetype *string

+ Objecttype *string

+ Sha512 *string

+ Subtype *string

+ Type *string

+ func (*ItemMetadata) Descriptor() ([]byte, []int)

+ func (*ItemMetadata) ProtoMessage()

+ func (x *ItemMetadata) GetError() string

+ func (x *ItemMetadata) GetMetadata() []byte

+ func (x *ItemMetadata) GetMimetype() string

+ func (x *ItemMetadata) GetObjecttype() string

+ func (x *ItemMetadata) GetSha512() string

+ func (x *ItemMetadata) GetSubtype() string

+ func (x *ItemMetadata) GetType() string

+ func (x *ItemMetadata) ProtoReflect() protoreflect.Message

+ func (x *ItemMetadata) Reset()

+ func (x *ItemMetadata) String() string

+ type NewItem struct

+ Identifier *ItemIdentifier

+ IngestType *IngestType

+ Parent *ItemIdentifier

+ Public *bool

+ PublicActions []byte

+ Urn string

+ func (*NewItem) Descriptor() ([]byte, []int)

+ func (*NewItem) ProtoMessage()

+ func (x *NewItem) GetIdentifier() *ItemIdentifier

+ func (x *NewItem) GetIngestType() IngestType

+ func (x *NewItem) GetParent() *ItemIdentifier

+ func (x *NewItem) GetPublic() bool

+ func (x *NewItem) GetPublicActions() []byte

+ func (x *NewItem) GetUrn() string

+ func (x *NewItem) ProtoReflect() protoreflect.Message

+ func (x *NewItem) Reset()

+ func (x *NewItem) String() string

+ type PageToken struct

+ Data string

+ func (*PageToken) Descriptor() ([]byte, []int)

+ func (*PageToken) ProtoMessage()

+ func (x *PageToken) GetData() string

+ func (x *PageToken) ProtoReflect() protoreflect.Message

+ func (x *PageToken) Reset()

+ func (x *PageToken) String() string

+ type ResultStatus int32

+ const ResultStatus_Error

+ const ResultStatus_NotFound

+ const ResultStatus_OK

+ const ResultStatus_Warning

+ func (ResultStatus) Descriptor() protoreflect.EnumDescriptor

+ func (ResultStatus) EnumDescriptor() ([]byte, []int)

+ func (ResultStatus) Type() protoreflect.EnumType

+ func (x ResultStatus) Enum() *ResultStatus

+ func (x ResultStatus) Number() protoreflect.EnumNumber

+ func (x ResultStatus) String() string

+ type Storage struct

+ Datadir string

+ Filebase string

+ Name string

+ Subitemdir string

+ Tempdir string

+ func (*Storage) Descriptor() ([]byte, []int)

+ func (*Storage) ProtoMessage()

+ func (x *Storage) GetDatadir() string

+ func (x *Storage) GetFilebase() string

+ func (x *Storage) GetName() string

+ func (x *Storage) GetSubitemdir() string

+ func (x *Storage) GetTempdir() string

+ func (x *Storage) ProtoReflect() protoreflect.Message

+ func (x *Storage) Reset()

+ func (x *Storage) String() string

+ type StorageIdentifier struct

+ Name string

+ func (*StorageIdentifier) Descriptor() ([]byte, []int)

+ func (*StorageIdentifier) ProtoMessage()

+ func (x *StorageIdentifier) GetName() string

+ func (x *StorageIdentifier) ProtoReflect() protoreflect.Message

+ func (x *StorageIdentifier) Reset()

+ func (x *StorageIdentifier) String() string

+ type UnimplementedDBControllerServer struct

+ func (UnimplementedDBControllerServer) CreateItem(context.Context, *NewItem) (*DefaultResponse, error)

+ func (UnimplementedDBControllerServer) DeleteItem(context.Context, *ItemIdentifier) (*DefaultResponse, error)

+ func (UnimplementedDBControllerServer) ExistsItem(context.Context, *ItemIdentifier) (*DefaultResponse, error)

+ func (UnimplementedDBControllerServer) GetCollection(context.Context, *CollectionIdentifier) (*Collection, error)

+ func (UnimplementedDBControllerServer) GetCollections(context.Context, *PageToken) (*Collections, error)

+ func (UnimplementedDBControllerServer) GetIngestItem(context.Context, *emptypb.Empty) (*IngestItem, error)

+ func (UnimplementedDBControllerServer) GetItem(context.Context, *ItemIdentifier) (*Item, error)

+ func (UnimplementedDBControllerServer) GetStorage(context.Context, *StorageIdentifier) (*Storage, error)

+ func (UnimplementedDBControllerServer) Ping(context.Context, *emptypb.Empty) (*DefaultResponse, error)

+ func (UnimplementedDBControllerServer) SetIngestItem(context.Context, *IngestMetadata) (*DefaultResponse, error)

+ type UnsafeDBControllerServer interface