proto

package
v2.0.46 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2024 License: Apache-2.0 Imports: 12 Imported by: 25

Documentation

Index

Constants

View Source 
const (
	Action_Ping_FullMethodName      = "/mediaserverproto.Action/Ping"
	Action_GetParams_FullMethodName = "/mediaserverproto.Action/GetParams"
	Action_Action_FullMethodName    = "/mediaserverproto.Action/Action"
)
View Source 
const (
	ActionDispatcher_Ping_FullMethodName             = "/mediaserverproto.ActionDispatcher/Ping"
	ActionDispatcher_AddController_FullMethodName    = "/mediaserverproto.ActionDispatcher/AddController"
	ActionDispatcher_RemoveController_FullMethodName = "/mediaserverproto.ActionDispatcher/RemoveController"
	ActionDispatcher_GetActions_FullMethodName       = "/mediaserverproto.ActionDispatcher/GetActions"
)
View Source 
const (
	Database_Ping_FullMethodName                  = "/mediaserverproto.Database/Ping"
	Database_GetItem_FullMethodName               = "/mediaserverproto.Database/GetItem"
	Database_GetChildItems_FullMethodName         = "/mediaserverproto.Database/GetChildItems"
	Database_GetItemMetadata_FullMethodName       = "/mediaserverproto.Database/GetItemMetadata"
	Database_CreateItem_FullMethodName            = "/mediaserverproto.Database/CreateItem"
	Database_DeleteItem_FullMethodName            = "/mediaserverproto.Database/DeleteItem"
	Database_GetDerivateIngestItem_FullMethodName = "/mediaserverproto.Database/GetDerivateIngestItem"
	Database_GetIngestItem_FullMethodName         = "/mediaserverproto.Database/GetIngestItem"
	Database_SetIngestItem_FullMethodName         = "/mediaserverproto.Database/SetIngestItem"
	Database_ExistsItem_FullMethodName            = "/mediaserverproto.Database/ExistsItem"
	Database_GetCache_FullMethodName              = "/mediaserverproto.Database/GetCache"
	Database_GetCaches_FullMethodName             = "/mediaserverproto.Database/GetCaches"
	Database_DeleteCache_FullMethodName           = "/mediaserverproto.Database/DeleteCache"
	Database_InsertCache_FullMethodName           = "/mediaserverproto.Database/InsertCache"
	Database_GetStorage_FullMethodName            = "/mediaserverproto.Database/GetStorage"
	Database_GetCollection_FullMethodName         = "/mediaserverproto.Database/GetCollection"
	Database_GetCollections_FullMethodName        = "/mediaserverproto.Database/GetCollections"
)
View Source 
const (
	Deleter_Ping_FullMethodName             = "/mediaserverproto.Deleter/Ping"
	Deleter_DeleteItem_FullMethodName       = "/mediaserverproto.Deleter/DeleteItem"
	Deleter_DeleteItemCaches_FullMethodName = "/mediaserverproto.Deleter/DeleteItemCaches"
	Deleter_DeleteCache_FullMethodName      = "/mediaserverproto.Deleter/DeleteCache"
)

Variables

View Source 
var (
	IngestType_name = map[int32]string{
		0: "KEEP",
		1: "COPY",
		2: "MOVE",
	}
	IngestType_value = map[string]int32{
		"KEEP": 0,
		"COPY": 1,
		"MOVE": 2,
	}
)

Enum value maps for IngestType.

View Source 
var ActionDispatcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserverproto.ActionDispatcher",
	HandlerType: (*ActionDispatcherServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ActionDispatcher_Ping_Handler,
		},
		{
			MethodName: "AddController",
			Handler:    _ActionDispatcher_AddController_Handler,
		},
		{
			MethodName: "RemoveController",
			Handler:    _ActionDispatcher_RemoveController_Handler,
		},
		{
			MethodName: "GetActions",
			Handler:    _ActionDispatcher_GetActions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpcAction.proto",
}

ActionDispatcher_ServiceDesc is the grpc.ServiceDesc for ActionDispatcher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Action_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserverproto.Action",
	HandlerType: (*ActionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Action_Ping_Handler,
		},
		{
			MethodName: "GetParams",
			Handler:    _Action_GetParams_Handler,
		},
		{
			MethodName: "Action",
			Handler:    _Action_Action_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpcAction.proto",
}

Action_ServiceDesc is the grpc.ServiceDesc for Action service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Database_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserverproto.Database",
	HandlerType: (*DatabaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Database_Ping_Handler,
		},
		{
			MethodName: "GetItem",
			Handler:    _Database_GetItem_Handler,
		},
		{
			MethodName: "GetChildItems",
			Handler:    _Database_GetChildItems_Handler,
		},
		{
			MethodName: "GetItemMetadata",
			Handler:    _Database_GetItemMetadata_Handler,
		},
		{
			MethodName: "CreateItem",
			Handler:    _Database_CreateItem_Handler,
		},
		{
			MethodName: "DeleteItem",
			Handler:    _Database_DeleteItem_Handler,
		},
		{
			MethodName: "GetDerivateIngestItem",
			Handler:    _Database_GetDerivateIngestItem_Handler,
		},
		{
			MethodName: "GetIngestItem",
			Handler:    _Database_GetIngestItem_Handler,
		},
		{
			MethodName: "SetIngestItem",
			Handler:    _Database_SetIngestItem_Handler,
		},
		{
			MethodName: "ExistsItem",
			Handler:    _Database_ExistsItem_Handler,
		},
		{
			MethodName: "GetCache",
			Handler:    _Database_GetCache_Handler,
		},
		{
			MethodName: "GetCaches",
			Handler:    _Database_GetCaches_Handler,
		},
		{
			MethodName: "DeleteCache",
			Handler:    _Database_DeleteCache_Handler,
		},
		{
			MethodName: "InsertCache",
			Handler:    _Database_InsertCache_Handler,
		},
		{
			MethodName: "GetStorage",
			Handler:    _Database_GetStorage_Handler,
		},
		{
			MethodName: "GetCollection",
			Handler:    _Database_GetCollection_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetCollections",
			Handler:       _Database_GetCollections_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpcDatabase.proto",
}

Database_ServiceDesc is the grpc.ServiceDesc for Database service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Deleter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserverproto.Deleter",
	HandlerType: (*DeleterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Deleter_Ping_Handler,
		},
		{
			MethodName: "DeleteItem",
			Handler:    _Deleter_DeleteItem_Handler,
		},
		{
			MethodName: "DeleteItemCaches",
			Handler:    _Deleter_DeleteItemCaches_Handler,
		},
		{
			MethodName: "DeleteCache",
			Handler:    _Deleter_DeleteCache_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpcDeleter.proto",
}

Deleter_ServiceDesc is the grpc.ServiceDesc for Deleter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_action_proto protoreflect.FileDescriptor
View Source 
var File_cache_proto protoreflect.FileDescriptor
View Source 
var File_collection_proto protoreflect.FileDescriptor
View Source 
var File_item_proto protoreflect.FileDescriptor
View Source 
var File_rpcAction_proto protoreflect.FileDescriptor
View Source 
var File_rpcDatabase_proto protoreflect.FileDescriptor
View Source 
var File_rpcDeleter_proto protoreflect.FileDescriptor
View Source 
var File_storage_proto protoreflect.FileDescriptor

Functions

func RegisterActionDispatcherServer 

func RegisterActionDispatcherServer(s grpc.ServiceRegistrar, srv ActionDispatcherServer)

func RegisterActionServer 

func RegisterActionServer(s grpc.ServiceRegistrar, srv ActionServer)

func RegisterDatabaseServer 

func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)

func RegisterDeleterServer 

func RegisterDeleterServer(s grpc.ServiceRegistrar, srv DeleterServer)

Types

type ActionClient 

type ActionClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetParams(ctx context.Context, in *ParamsParam, opts ...grpc.CallOption) (*proto.StringList, error)
	Action(ctx context.Context, in *ActionParam, opts ...grpc.CallOption) (*Cache, error)
}

ActionClient is the client API for Action service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewActionClient 

func NewActionClient(cc grpc.ClientConnInterface) ActionClient

type ActionDispatcherClient 

type ActionDispatcherClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	AddController(ctx context.Context, in *ActionDispatcherParam, opts ...grpc.CallOption) (*ActionDispatcherDefaultResponse, error)
	RemoveController(ctx context.Context, in *ActionDispatcherParam, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetActions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ActionMap, error)
}

ActionDispatcherClient is the client API for ActionDispatcher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewActionDispatcherClient 

func NewActionDispatcherClient(cc grpc.ClientConnInterface) ActionDispatcherClient

type ActionDispatcherDefaultResponse added in v2.0.26 

type ActionDispatcherDefaultResponse struct {
	Response     *proto.DefaultResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	NextCallWait int64                  `protobuf:"varint,4,opt,name=nextCallWait,proto3" json:"nextCallWait,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDispatcherDefaultResponse) Descriptor deprecated added in v2.0.26 

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

Deprecated: Use ActionDispatcherDefaultResponse.ProtoReflect.Descriptor instead.

func (*ActionDispatcherDefaultResponse) GetNextCallWait added in v2.0.26 

func (x *ActionDispatcherDefaultResponse) GetNextCallWait() int64

func (*ActionDispatcherDefaultResponse) GetResponse added in v2.0.26 

func (x *ActionDispatcherDefaultResponse) GetResponse() *proto.DefaultResponse

func (*ActionDispatcherDefaultResponse) ProtoMessage added in v2.0.26 

func (*ActionDispatcherDefaultResponse) ProtoMessage()

func (*ActionDispatcherDefaultResponse) ProtoReflect added in v2.0.26 

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

func (*ActionDispatcherDefaultResponse) Reset added in v2.0.26 

func (x *ActionDispatcherDefaultResponse) Reset()

func (*ActionDispatcherDefaultResponse) String added in v2.0.26 

func (x *ActionDispatcherDefaultResponse) String() string

type ActionDispatcherParam 

type ActionDispatcherParam struct {
	Domains     []string                  `protobuf:"bytes,1,rep,name=domains,proto3" json:"domains,omitempty"`
	Name        string                    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Concurrency uint32                    `protobuf:"varint,3,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Actions     map[string]*StringListMap `` /* 155-byte string literal not displayed */
	QueueSize   uint32                    `protobuf:"varint,5,opt,name=queueSize,proto3" json:"queueSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDispatcherParam) Descriptor deprecated 

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

Deprecated: Use ActionDispatcherParam.ProtoReflect.Descriptor instead.

func (*ActionDispatcherParam) GetActions added in v2.0.25 

func (x *ActionDispatcherParam) GetActions() map[string]*StringListMap

func (*ActionDispatcherParam) GetConcurrency 

func (x *ActionDispatcherParam) GetConcurrency() uint32

func (*ActionDispatcherParam) GetDomains added in v2.0.39 

func (x *ActionDispatcherParam) GetDomains() []string

func (*ActionDispatcherParam) GetName added in v2.0.38 

func (x *ActionDispatcherParam) GetName() string

func (*ActionDispatcherParam) GetQueueSize added in v2.0.36 

func (x *ActionDispatcherParam) GetQueueSize() uint32

func (*ActionDispatcherParam) ProtoMessage 

func (*ActionDispatcherParam) ProtoMessage()

func (*ActionDispatcherParam) ProtoReflect 

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

func (*ActionDispatcherParam) Reset 

func (x *ActionDispatcherParam) Reset()

func (*ActionDispatcherParam) String 

func (x *ActionDispatcherParam) String() string

type ActionDispatcherServer 

type ActionDispatcherServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	AddController(context.Context, *ActionDispatcherParam) (*ActionDispatcherDefaultResponse, error)
	RemoveController(context.Context, *ActionDispatcherParam) (*proto.DefaultResponse, error)
	GetActions(context.Context, *emptypb.Empty) (*ActionMap, error)
	// contains filtered or unexported methods
}

ActionDispatcherServer is the server API for ActionDispatcher service. All implementations must embed UnimplementedActionDispatcherServer for forward compatibility

type ActionMap added in v2.0.26 

type ActionMap struct {
	Actions map[string]*StringListMap `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ActionMap) Descriptor deprecated added in v2.0.26 

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

Deprecated: Use ActionMap.ProtoReflect.Descriptor instead.

func (*ActionMap) GetActions added in v2.0.26 

func (x *ActionMap) GetActions() map[string]*StringListMap

func (*ActionMap) ProtoMessage added in v2.0.26 

func (*ActionMap) ProtoMessage()

func (*ActionMap) ProtoReflect added in v2.0.26 

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

func (*ActionMap) Reset added in v2.0.26 

func (x *ActionMap) Reset()

func (*ActionMap) String added in v2.0.26 

func (x *ActionMap) String() string

type ActionParam 

type ActionParam struct {
	Item    *Item             `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Action  string            `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Params  map[string]string `` /* 153-byte string literal not displayed */
	Storage *Storage          `protobuf:"bytes,4,opt,name=storage,proto3" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionParam) Descriptor deprecated 

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

Deprecated: Use ActionParam.ProtoReflect.Descriptor instead.

func (*ActionParam) GetAction 

func (x *ActionParam) GetAction() string

func (*ActionParam) GetItem 

func (x *ActionParam) GetItem() *Item

func (*ActionParam) GetParams 

func (x *ActionParam) GetParams() map[string]string

func (*ActionParam) GetStorage 

func (x *ActionParam) GetStorage() *Storage

func (*ActionParam) ProtoMessage 

func (*ActionParam) ProtoMessage()

func (*ActionParam) ProtoReflect 

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

func (*ActionParam) Reset 

func (x *ActionParam) Reset()

func (*ActionParam) String 

func (x *ActionParam) String() string

type ActionServer 

type ActionServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	GetParams(context.Context, *ParamsParam) (*proto.StringList, error)
	Action(context.Context, *ActionParam) (*Cache, error)
	// contains filtered or unexported methods
}

ActionServer is the server API for Action service. All implementations must embed UnimplementedActionServer for forward compatibility

type Cache 

type Cache struct {
	Identifier *ItemIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Metadata   *CacheMetadata  `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Cache) Descriptor deprecated 

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

Deprecated: Use Cache.ProtoReflect.Descriptor instead.

func (*Cache) GetIdentifier 

func (x *Cache) GetIdentifier() *ItemIdentifier

func (*Cache) GetMetadata 

func (x *Cache) GetMetadata() *CacheMetadata

func (*Cache) ProtoMessage 

func (*Cache) ProtoMessage()

func (*Cache) ProtoReflect 

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

func (*Cache) Reset 

func (x *Cache) Reset()

func (*Cache) String 

func (x *Cache) String() string

type CacheMetadata 

type CacheMetadata struct {
	Action   string   `protobuf:"bytes,2,opt,name=Action,proto3" json:"Action,omitempty"`
	Params   string   `protobuf:"bytes,3,opt,name=Params,proto3" json:"Params,omitempty"`
	Width    int64    `protobuf:"varint,4,opt,name=Width,proto3" json:"Width,omitempty"`
	Height   int64    `protobuf:"varint,5,opt,name=Height,proto3" json:"Height,omitempty"`
	Duration int64    `protobuf:"varint,6,opt,name=Duration,proto3" json:"Duration,omitempty"`
	Size     int64    `protobuf:"varint,7,opt,name=Size,proto3" json:"Size,omitempty"`
	MimeType string   `protobuf:"bytes,8,opt,name=MimeType,proto3" json:"MimeType,omitempty"`
	Path     string   `protobuf:"bytes,9,opt,name=Path,proto3" json:"Path,omitempty"`
	Storage  *Storage `protobuf:"bytes,10,opt,name=Storage,proto3,oneof" json:"Storage,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheMetadata) Descriptor deprecated 

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

Deprecated: Use CacheMetadata.ProtoReflect.Descriptor instead.

func (*CacheMetadata) GetAction 

func (x *CacheMetadata) GetAction() string

func (*CacheMetadata) GetDuration 

func (x *CacheMetadata) GetDuration() int64

func (*CacheMetadata) GetHeight 

func (x *CacheMetadata) GetHeight() int64

func (*CacheMetadata) GetMimeType 

func (x *CacheMetadata) GetMimeType() string

func (*CacheMetadata) GetParams 

func (x *CacheMetadata) GetParams() string

func (*CacheMetadata) GetPath 

func (x *CacheMetadata) GetPath() string

func (*CacheMetadata) GetSize 

func (x *CacheMetadata) GetSize() int64

func (*CacheMetadata) GetStorage 

func (x *CacheMetadata) GetStorage() *Storage

func (*CacheMetadata) GetWidth 

func (x *CacheMetadata) GetWidth() int64

func (*CacheMetadata) ProtoMessage 

func (*CacheMetadata) ProtoMessage()

func (*CacheMetadata) ProtoReflect 

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

func (*CacheMetadata) Reset 

func (x *CacheMetadata) Reset()

func (*CacheMetadata) String 

func (x *CacheMetadata) String() string

type CacheRequest 

type CacheRequest struct {
	Identifier *ItemIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Action     string          `protobuf:"bytes,2,opt,name=Action,proto3" json:"Action,omitempty"`
	Params     string          `protobuf:"bytes,3,opt,name=Params,proto3" json:"Params,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheRequest) Descriptor deprecated 

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

Deprecated: Use CacheRequest.ProtoReflect.Descriptor instead.

func (*CacheRequest) GetAction 

func (x *CacheRequest) GetAction() string

func (*CacheRequest) GetIdentifier 

func (x *CacheRequest) GetIdentifier() *ItemIdentifier

func (*CacheRequest) GetParams 

func (x *CacheRequest) GetParams() string

func (*CacheRequest) ProtoMessage 

func (*CacheRequest) ProtoMessage()

func (*CacheRequest) ProtoReflect 

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

func (*CacheRequest) Reset 

func (x *CacheRequest) Reset()

func (*CacheRequest) String 

func (x *CacheRequest) String() string

type CachesRequest added in v2.0.27 

type CachesRequest struct {
	Identifier  *ItemIdentifier    `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	PageRequest *proto.PageRequest `protobuf:"bytes,2,opt,name=pageRequest,proto3" json:"pageRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*CachesRequest) Descriptor deprecated added in v2.0.27 

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

Deprecated: Use CachesRequest.ProtoReflect.Descriptor instead.

func (*CachesRequest) GetIdentifier added in v2.0.27 

func (x *CachesRequest) GetIdentifier() *ItemIdentifier

func (*CachesRequest) GetPageRequest added in v2.0.27 

func (x *CachesRequest) GetPageRequest() *proto.PageRequest

func (*CachesRequest) ProtoMessage added in v2.0.27 

func (*CachesRequest) ProtoMessage()

func (*CachesRequest) ProtoReflect added in v2.0.27 

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

func (*CachesRequest) Reset added in v2.0.27 

func (x *CachesRequest) Reset()

func (*CachesRequest) String added in v2.0.27 

func (x *CachesRequest) String() string

type CachesResult added in v2.0.27 

type CachesResult struct {
	Caches       []*Cache            `protobuf:"bytes,1,rep,name=caches,proto3" json:"caches,omitempty"`
	PageResponse *proto.PageResponse `protobuf:"bytes,2,opt,name=pageResponse,proto3" json:"pageResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*CachesResult) Descriptor deprecated added in v2.0.27 

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

Deprecated: Use CachesResult.ProtoReflect.Descriptor instead.

func (*CachesResult) GetCaches added in v2.0.27 

func (x *CachesResult) GetCaches() []*Cache

func (*CachesResult) GetPageResponse added in v2.0.27 

func (x *CachesResult) GetPageResponse() *proto.PageResponse

func (*CachesResult) ProtoMessage added in v2.0.27 

func (*CachesResult) ProtoMessage()

func (*CachesResult) ProtoReflect added in v2.0.27 

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

func (*CachesResult) Reset added in v2.0.27 

func (x *CachesResult) Reset()

func (*CachesResult) String added in v2.0.27 

func (x *CachesResult) String() string

type Collection 

type Collection struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description     string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	SignaturePrefix string   `protobuf:"bytes,3,opt,name=signature_prefix,json=signaturePrefix,proto3" json:"signature_prefix,omitempty"`
	Secret          string   `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Public          string   `protobuf:"bytes,5,opt,name=public,proto3" json:"public,omitempty"`
	Jwtkey          string   `protobuf:"bytes,6,opt,name=jwtkey,proto3" json:"jwtkey,omitempty"`
	Storage         *Storage `protobuf:"bytes,7,opt,name=storage,proto3" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

func (*Collection) Descriptor deprecated 

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

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetDescription 

func (x *Collection) GetDescription() string

func (*Collection) GetJwtkey 

func (x *Collection) GetJwtkey() string

func (*Collection) GetName 

func (x *Collection) GetName() string

func (*Collection) GetPublic 

func (x *Collection) GetPublic() string

func (*Collection) GetSecret 

func (x *Collection) GetSecret() string

func (*Collection) GetSignaturePrefix 

func (x *Collection) GetSignaturePrefix() string

func (*Collection) GetStorage 

func (x *Collection) GetStorage() *Storage

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect 

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

func (*Collection) Reset 

func (x *Collection) Reset()

func (*Collection) String 

func (x *Collection) String() string

type CollectionIdentifier 

type CollectionIdentifier struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionIdentifier) Descriptor deprecated 

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

Deprecated: Use CollectionIdentifier.ProtoReflect.Descriptor instead.

func (*CollectionIdentifier) GetCollection 

func (x *CollectionIdentifier) GetCollection() string

func (*CollectionIdentifier) ProtoMessage 

func (*CollectionIdentifier) ProtoMessage()

func (*CollectionIdentifier) ProtoReflect 

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

func (*CollectionIdentifier) Reset 

func (x *CollectionIdentifier) Reset()

func (*CollectionIdentifier) String 

func (x *CollectionIdentifier) String() string

type CollectionsResponse 

type CollectionsResponse struct {
	Collections []*Collection       `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
	Page        *proto.PageResponse `protobuf:"bytes,2,opt,name=Page,proto3" json:"Page,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionsResponse) Descriptor deprecated 

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

Deprecated: Use CollectionsResponse.ProtoReflect.Descriptor instead.

func (*CollectionsResponse) GetCollections 

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

func (*CollectionsResponse) GetPage 

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

func (*CollectionsResponse) ProtoMessage 

func (*CollectionsResponse) ProtoMessage()

func (*CollectionsResponse) ProtoReflect 

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

func (*CollectionsResponse) Reset 

func (x *CollectionsResponse) Reset()

func (*CollectionsResponse) String 

func (x *CollectionsResponse) String() string

type DatabaseClient 

type DatabaseClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetItem(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*Item, error)
	GetChildItems(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*ItemsResult, error)
	GetItemMetadata(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	CreateItem(ctx context.Context, in *NewItem, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	DeleteItem(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetDerivateIngestItem(ctx context.Context, in *DerivatIngestRequest, opts ...grpc.CallOption) (*DerivatIngestResponse, error)
	GetIngestItem(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IngestItem, error)
	SetIngestItem(ctx context.Context, in *IngestMetadata, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	ExistsItem(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetCache(ctx context.Context, in *CacheRequest, opts ...grpc.CallOption) (*Cache, error)
	GetCaches(ctx context.Context, in *CachesRequest, opts ...grpc.CallOption) (*CachesResult, error)
	DeleteCache(ctx context.Context, in *CacheRequest, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	InsertCache(ctx context.Context, in *Cache, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetStorage(ctx context.Context, in *StorageIdentifier, opts ...grpc.CallOption) (*Storage, error)
	GetCollection(ctx context.Context, in *CollectionIdentifier, opts ...grpc.CallOption) (*Collection, error)
	GetCollections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Database_GetCollectionsClient, error)
}

DatabaseClient is the client API for Database service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatabaseClient 

func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient

type DatabaseServer 

type DatabaseServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	GetItem(context.Context, *ItemIdentifier) (*Item, error)
	GetChildItems(context.Context, *ItemsRequest) (*ItemsResult, error)
	GetItemMetadata(context.Context, *ItemIdentifier) (*wrapperspb.StringValue, error)
	CreateItem(context.Context, *NewItem) (*proto.DefaultResponse, error)
	DeleteItem(context.Context, *ItemIdentifier) (*proto.DefaultResponse, error)
	GetDerivateIngestItem(context.Context, *DerivatIngestRequest) (*DerivatIngestResponse, error)
	GetIngestItem(context.Context, *emptypb.Empty) (*IngestItem, error)
	SetIngestItem(context.Context, *IngestMetadata) (*proto.DefaultResponse, error)
	ExistsItem(context.Context, *ItemIdentifier) (*proto.DefaultResponse, error)
	GetCache(context.Context, *CacheRequest) (*Cache, error)
	GetCaches(context.Context, *CachesRequest) (*CachesResult, error)
	DeleteCache(context.Context, *CacheRequest) (*proto.DefaultResponse, error)
	InsertCache(context.Context, *Cache) (*proto.DefaultResponse, error)
	GetStorage(context.Context, *StorageIdentifier) (*Storage, error)
	GetCollection(context.Context, *CollectionIdentifier) (*Collection, error)
	GetCollections(*emptypb.Empty, Database_GetCollectionsServer) error
	// contains filtered or unexported methods
}

DatabaseServer is the server API for Database service. All implementations must embed UnimplementedDatabaseServer for forward compatibility

type Database_GetCollectionsClient 

type Database_GetCollectionsClient interface {
	Recv() (*Collection, error)
	grpc.ClientStream
}

type Database_GetCollectionsServer 

type Database_GetCollectionsServer interface {
	Send(*Collection) error
	grpc.ServerStream
}

type DeleterClient 

type DeleterClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	DeleteItem(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	DeleteItemCaches(ctx context.Context, in *ItemIdentifier, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	DeleteCache(ctx context.Context, in *CacheRequest, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
}

DeleterClient is the client API for Deleter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDeleterClient 

func NewDeleterClient(cc grpc.ClientConnInterface) DeleterClient

type DeleterServer 

type DeleterServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	DeleteItem(context.Context, *ItemIdentifier) (*proto.DefaultResponse, error)
	DeleteItemCaches(context.Context, *ItemIdentifier) (*proto.DefaultResponse, error)
	DeleteCache(context.Context, *CacheRequest) (*proto.DefaultResponse, error)
	// contains filtered or unexported methods
}

DeleterServer is the server API for Deleter service. All implementations must embed UnimplementedDeleterServer for forward compatibility

type DerivatIngestRequest added in v2.0.29 

type DerivatIngestRequest struct {
	Type    string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Subtype string   `protobuf:"bytes,2,opt,name=subtype,proto3" json:"subtype,omitempty"`
	Suffix  []string `protobuf:"bytes,3,rep,name=suffix,proto3" json:"suffix,omitempty"`
	// contains filtered or unexported fields
}

func (*DerivatIngestRequest) Descriptor deprecated added in v2.0.29 

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

Deprecated: Use DerivatIngestRequest.ProtoReflect.Descriptor instead.

func (*DerivatIngestRequest) GetSubtype added in v2.0.30 

func (x *DerivatIngestRequest) GetSubtype() string

func (*DerivatIngestRequest) GetSuffix added in v2.0.29 

func (x *DerivatIngestRequest) GetSuffix() []string

func (*DerivatIngestRequest) GetType added in v2.0.30 

func (x *DerivatIngestRequest) GetType() string

func (*DerivatIngestRequest) ProtoMessage added in v2.0.29 

func (*DerivatIngestRequest) ProtoMessage()

func (*DerivatIngestRequest) ProtoReflect added in v2.0.29 

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

func (*DerivatIngestRequest) Reset added in v2.0.29 

func (x *DerivatIngestRequest) Reset()

func (*DerivatIngestRequest) String added in v2.0.29 

func (x *DerivatIngestRequest) String() string

type DerivatIngestResponse added in v2.0.29 

type DerivatIngestResponse struct {
	Item    *Item    `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Missing []string `protobuf:"bytes,2,rep,name=missing,proto3" json:"missing,omitempty"`
	// contains filtered or unexported fields
}

func (*DerivatIngestResponse) Descriptor deprecated added in v2.0.29 

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

Deprecated: Use DerivatIngestResponse.ProtoReflect.Descriptor instead.

func (*DerivatIngestResponse) GetItem added in v2.0.29 

func (x *DerivatIngestResponse) GetItem() *Item

func (*DerivatIngestResponse) GetMissing added in v2.0.29 

func (x *DerivatIngestResponse) GetMissing() []string

func (*DerivatIngestResponse) ProtoMessage added in v2.0.29 

func (*DerivatIngestResponse) ProtoMessage()

func (*DerivatIngestResponse) ProtoReflect added in v2.0.29 

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

func (*DerivatIngestResponse) Reset added in v2.0.29 

func (x *DerivatIngestResponse) Reset()

func (*DerivatIngestResponse) String added in v2.0.29 

func (x *DerivatIngestResponse) String() string

type IngestItem 

type IngestItem struct {
	Identifier *ItemIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Urn        string          `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	IngestType IngestType      `protobuf:"varint,4,opt,name=ingestType,proto3,enum=mediaserverproto.IngestType" json:"ingestType,omitempty"`
	Collection *Collection     `protobuf:"bytes,5,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestItem) Descriptor deprecated 

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

Deprecated: Use IngestItem.ProtoReflect.Descriptor instead.

func (*IngestItem) GetCollection 

func (x *IngestItem) GetCollection() *Collection

func (*IngestItem) GetIdentifier 

func (x *IngestItem) GetIdentifier() *ItemIdentifier

func (*IngestItem) GetIngestType 

func (x *IngestItem) GetIngestType() IngestType

func (*IngestItem) GetUrn 

func (x *IngestItem) GetUrn() string

func (*IngestItem) ProtoMessage 

func (*IngestItem) ProtoMessage()

func (*IngestItem) ProtoReflect 

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

func (*IngestItem) Reset 

func (x *IngestItem) Reset()

func (*IngestItem) String 

func (x *IngestItem) String() string

type IngestMetadata 

type IngestMetadata struct {
	Item          *ItemIdentifier `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Status        string          `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	ItemMetadata  *ItemMetadata   `protobuf:"bytes,3,opt,name=itemMetadata,proto3" json:"itemMetadata,omitempty"`
	CacheMetadata *CacheMetadata  `protobuf:"bytes,4,opt,name=cacheMetadata,proto3" json:"cacheMetadata,omitempty"`
	FullMetadata  string          `protobuf:"bytes,5,opt,name=fullMetadata,proto3" json:"fullMetadata,omitempty"`
	Error         *string         `protobuf:"bytes,6,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestMetadata) Descriptor deprecated 

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

Deprecated: Use IngestMetadata.ProtoReflect.Descriptor instead.

func (*IngestMetadata) GetCacheMetadata 

func (x *IngestMetadata) GetCacheMetadata() *CacheMetadata

func (*IngestMetadata) GetError 

func (x *IngestMetadata) GetError() string

func (*IngestMetadata) GetFullMetadata 

func (x *IngestMetadata) GetFullMetadata() string

func (*IngestMetadata) GetItem 

func (x *IngestMetadata) GetItem() *ItemIdentifier

func (*IngestMetadata) GetItemMetadata 

func (x *IngestMetadata) GetItemMetadata() *ItemMetadata

func (*IngestMetadata) GetStatus 

func (x *IngestMetadata) GetStatus() string

func (*IngestMetadata) ProtoMessage 

func (*IngestMetadata) ProtoMessage()

func (*IngestMetadata) ProtoReflect 

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

func (*IngestMetadata) Reset 

func (x *IngestMetadata) Reset()

func (*IngestMetadata) String 

func (x *IngestMetadata) String() string

type IngestType 

type IngestType int32
const (
	IngestType_KEEP IngestType = 0
	IngestType_COPY IngestType = 1
	IngestType_MOVE IngestType = 2
)

func (IngestType) Descriptor 

func (IngestType) Descriptor() protoreflect.EnumDescriptor

func (IngestType) Enum 

func (x IngestType) Enum() *IngestType

func (IngestType) EnumDescriptor deprecated 

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

Deprecated: Use IngestType.Descriptor instead.

func (IngestType) Number 

func (x IngestType) Number() protoreflect.EnumNumber

func (IngestType) String 

func (x IngestType) String() string

func (IngestType) Type 

func (IngestType) Type() protoreflect.EnumType

type Item 

type Item struct {
	Identifier    *ItemIdentifier        `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Urn           string                 `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	Error         *string                `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Created       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	Updated       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated,proto3" json:"updated,omitempty"`
	Disabled      bool                   `protobuf:"varint,6,opt,name=disabled,proto3" json:"disabled,omitempty"`
	Public        bool                   `protobuf:"varint,7,opt,name=public,proto3" json:"public,omitempty"`
	PublicActions []string               `protobuf:"bytes,8,rep,name=publicActions,proto3" json:"publicActions,omitempty"`
	Status        string                 `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	Metadata      *ItemMetadata          `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Parent        *ItemIdentifier        `protobuf:"bytes,11,opt,name=parent,proto3,oneof" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*Item) Descriptor deprecated 

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetCreated 

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

func (*Item) GetDisabled 

func (x *Item) GetDisabled() bool

func (*Item) GetError 

func (x *Item) GetError() string

func (*Item) GetIdentifier 

func (x *Item) GetIdentifier() *ItemIdentifier

func (*Item) GetMetadata 

func (x *Item) GetMetadata() *ItemMetadata

func (*Item) GetParent 

func (x *Item) GetParent() *ItemIdentifier

func (*Item) GetPublic 

func (x *Item) GetPublic() bool

func (*Item) GetPublicActions 

func (x *Item) GetPublicActions() []string

func (*Item) GetStatus 

func (x *Item) GetStatus() string

func (*Item) GetUpdated 

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

func (*Item) GetUrn 

func (x *Item) GetUrn() string

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect 

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

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) String 

func (x *Item) String() string

type ItemIdentifier 

type ItemIdentifier struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Signature  string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ItemIdentifier) Descriptor deprecated 

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

Deprecated: Use ItemIdentifier.ProtoReflect.Descriptor instead.

func (*ItemIdentifier) GetCollection 

func (x *ItemIdentifier) GetCollection() string

func (*ItemIdentifier) GetSignature 

func (x *ItemIdentifier) GetSignature() string

func (*ItemIdentifier) ProtoMessage 

func (*ItemIdentifier) ProtoMessage()

func (*ItemIdentifier) ProtoReflect 

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

func (*ItemIdentifier) Reset 

func (x *ItemIdentifier) Reset()

func (*ItemIdentifier) String 

func (x *ItemIdentifier) String() string

type ItemMetadata 

type ItemMetadata struct {
	Type       *string `protobuf:"bytes,3,opt,name=type,proto3,oneof" json:"type,omitempty"`
	Subtype    *string `protobuf:"bytes,4,opt,name=subtype,proto3,oneof" json:"subtype,omitempty"`
	Objecttype *string `protobuf:"bytes,5,opt,name=objecttype,proto3,oneof" json:"objecttype,omitempty"`
	Mimetype   *string `protobuf:"bytes,6,opt,name=mimetype,proto3,oneof" json:"mimetype,omitempty"`
	Sha512     *string `protobuf:"bytes,8,opt,name=sha512,proto3,oneof" json:"sha512,omitempty"`
	// contains filtered or unexported fields
}

func (*ItemMetadata) Descriptor deprecated 

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

Deprecated: Use ItemMetadata.ProtoReflect.Descriptor instead.

func (*ItemMetadata) GetMimetype 

func (x *ItemMetadata) GetMimetype() string

func (*ItemMetadata) GetObjecttype 

func (x *ItemMetadata) GetObjecttype() string

func (*ItemMetadata) GetSha512 

func (x *ItemMetadata) GetSha512() string

func (*ItemMetadata) GetSubtype 

func (x *ItemMetadata) GetSubtype() string

func (*ItemMetadata) GetType 

func (x *ItemMetadata) GetType() string

func (*ItemMetadata) ProtoMessage 

func (*ItemMetadata) ProtoMessage()

func (*ItemMetadata) ProtoReflect 

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

func (*ItemMetadata) Reset 

func (x *ItemMetadata) Reset()

func (*ItemMetadata) String 

func (x *ItemMetadata) String() string

type ItemsRequest added in v2.0.28 

type ItemsRequest struct {
	Identifier  *ItemIdentifier    `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	PageRequest *proto.PageRequest `protobuf:"bytes,2,opt,name=pageRequest,proto3" json:"pageRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*ItemsRequest) Descriptor deprecated added in v2.0.28 

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

Deprecated: Use ItemsRequest.ProtoReflect.Descriptor instead.

func (*ItemsRequest) GetIdentifier added in v2.0.28 

func (x *ItemsRequest) GetIdentifier() *ItemIdentifier

func (*ItemsRequest) GetPageRequest added in v2.0.28 

func (x *ItemsRequest) GetPageRequest() *proto.PageRequest

func (*ItemsRequest) ProtoMessage added in v2.0.28 

func (*ItemsRequest) ProtoMessage()

func (*ItemsRequest) ProtoReflect added in v2.0.28 

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

func (*ItemsRequest) Reset added in v2.0.28 

func (x *ItemsRequest) Reset()

func (*ItemsRequest) String added in v2.0.28 

func (x *ItemsRequest) String() string

type ItemsResult added in v2.0.28 

type ItemsResult struct {
	Items        []*Item             `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	PageResponse *proto.PageResponse `protobuf:"bytes,2,opt,name=pageResponse,proto3" json:"pageResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*ItemsResult) Descriptor deprecated added in v2.0.28 

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

Deprecated: Use ItemsResult.ProtoReflect.Descriptor instead.

func (*ItemsResult) GetItems added in v2.0.28 

func (x *ItemsResult) GetItems() []*Item

func (*ItemsResult) GetPageResponse added in v2.0.28 

func (x *ItemsResult) GetPageResponse() *proto.PageResponse

func (*ItemsResult) ProtoMessage added in v2.0.28 

func (*ItemsResult) ProtoMessage()

func (*ItemsResult) ProtoReflect added in v2.0.28 

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

func (*ItemsResult) Reset added in v2.0.28 

func (x *ItemsResult) Reset()

func (*ItemsResult) String added in v2.0.28 

func (x *ItemsResult) String() string

type NewItem 

type NewItem struct {
	Identifier    *ItemIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Urn           string          `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	Public        *bool           `protobuf:"varint,3,opt,name=public,proto3,oneof" json:"public,omitempty"`
	Parent        *ItemIdentifier `protobuf:"bytes,4,opt,name=parent,proto3,oneof" json:"parent,omitempty"`
	PublicActions []byte          `protobuf:"bytes,5,opt,name=publicActions,proto3,oneof" json:"publicActions,omitempty"`
	IngestType    *IngestType     `protobuf:"varint,6,opt,name=ingestType,proto3,enum=mediaserverproto.IngestType,oneof" json:"ingestType,omitempty"`
	// contains filtered or unexported fields
}

func (*NewItem) Descriptor deprecated 

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

Deprecated: Use NewItem.ProtoReflect.Descriptor instead.

func (*NewItem) GetIdentifier 

func (x *NewItem) GetIdentifier() *ItemIdentifier

func (*NewItem) GetIngestType 

func (x *NewItem) GetIngestType() IngestType

func (*NewItem) GetParent 

func (x *NewItem) GetParent() *ItemIdentifier

func (*NewItem) GetPublic 

func (x *NewItem) GetPublic() bool

func (*NewItem) GetPublicActions 

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

func (*NewItem) GetUrn 

func (x *NewItem) GetUrn() string

func (*NewItem) ProtoMessage 

func (*NewItem) ProtoMessage()

func (*NewItem) ProtoReflect 

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

func (*NewItem) Reset 

func (x *NewItem) Reset()

func (*NewItem) String 

func (x *NewItem) String() string

type ParamsParam 

type ParamsParam struct {
	Type   string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ParamsParam) Descriptor deprecated 

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

Deprecated: Use ParamsParam.ProtoReflect.Descriptor instead.

func (*ParamsParam) GetAction 

func (x *ParamsParam) GetAction() string

func (*ParamsParam) GetType 

func (x *ParamsParam) GetType() string

func (*ParamsParam) ProtoMessage 

func (*ParamsParam) ProtoMessage()

func (*ParamsParam) ProtoReflect 

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

func (*ParamsParam) Reset 

func (x *ParamsParam) Reset()

func (*ParamsParam) String 

func (x *ParamsParam) String() string

type Storage 

type Storage struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Filebase   string `protobuf:"bytes,2,opt,name=filebase,proto3" json:"filebase,omitempty"`
	Datadir    string `protobuf:"bytes,3,opt,name=datadir,proto3" json:"datadir,omitempty"`
	Subitemdir string `protobuf:"bytes,4,opt,name=subitemdir,proto3" json:"subitemdir,omitempty"`
	Tempdir    string `protobuf:"bytes,5,opt,name=tempdir,proto3" json:"tempdir,omitempty"`
	// contains filtered or unexported fields
}

func (*Storage) Descriptor deprecated 

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

Deprecated: Use Storage.ProtoReflect.Descriptor instead.

func (*Storage) GetDatadir 

func (x *Storage) GetDatadir() string

func (*Storage) GetFilebase 

func (x *Storage) GetFilebase() string

func (*Storage) GetName 

func (x *Storage) GetName() string

func (*Storage) GetSubitemdir 

func (x *Storage) GetSubitemdir() string

func (*Storage) GetTempdir 

func (x *Storage) GetTempdir() string

func (*Storage) ProtoMessage 

func (*Storage) ProtoMessage()

func (*Storage) ProtoReflect 

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

func (*Storage) Reset 

func (x *Storage) Reset()

func (*Storage) String 

func (x *Storage) String() string

type StorageIdentifier 

type StorageIdentifier struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageIdentifier) Descriptor deprecated 

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

Deprecated: Use StorageIdentifier.ProtoReflect.Descriptor instead.

func (*StorageIdentifier) GetName 

func (x *StorageIdentifier) GetName() string

func (*StorageIdentifier) ProtoMessage 

func (*StorageIdentifier) ProtoMessage()

func (*StorageIdentifier) ProtoReflect 

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

func (*StorageIdentifier) Reset 

func (x *StorageIdentifier) Reset()

func (*StorageIdentifier) String 

func (x *StorageIdentifier) String() string

type StringListMap added in v2.0.40 

type StringListMap struct {
	Values map[string]*proto.StringList `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StringListMap) Descriptor deprecated added in v2.0.40 

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

Deprecated: Use StringListMap.ProtoReflect.Descriptor instead.

func (*StringListMap) GetValues added in v2.0.40 

func (x *StringListMap) GetValues() map[string]*proto.StringList

func (*StringListMap) ProtoMessage added in v2.0.40 

func (*StringListMap) ProtoMessage()

func (*StringListMap) ProtoReflect added in v2.0.40 

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

func (*StringListMap) Reset added in v2.0.40 

func (x *StringListMap) Reset()

func (*StringListMap) String added in v2.0.40 

func (x *StringListMap) String() string

type UnimplementedActionDispatcherServer 

type UnimplementedActionDispatcherServer struct {
}

UnimplementedActionDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedActionDispatcherServer) AddController 

func (UnimplementedActionDispatcherServer) AddController(context.Context, *ActionDispatcherParam) (*ActionDispatcherDefaultResponse, error)

func (UnimplementedActionDispatcherServer) GetActions added in v2.0.26 

func (UnimplementedActionDispatcherServer) GetActions(context.Context, *emptypb.Empty) (*ActionMap, error)

func (UnimplementedActionDispatcherServer) Ping 

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

func (UnimplementedActionDispatcherServer) RemoveController 

func (UnimplementedActionDispatcherServer) RemoveController(context.Context, *ActionDispatcherParam) (*proto.DefaultResponse, error)

type UnimplementedActionServer 

type UnimplementedActionServer struct {
}

UnimplementedActionServer must be embedded to have forward compatible implementations.

func (UnimplementedActionServer) Action 

func (UnimplementedActionServer) Action(context.Context, *ActionParam) (*Cache, error)

func (UnimplementedActionServer) GetParams 

func (UnimplementedActionServer) GetParams(context.Context, *ParamsParam) (*proto.StringList, error)

func (UnimplementedActionServer) Ping 

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

type UnimplementedDatabaseServer 

type UnimplementedDatabaseServer struct {
}

UnimplementedDatabaseServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServer) CreateItem 

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

func (UnimplementedDatabaseServer) DeleteCache 

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

func (UnimplementedDatabaseServer) DeleteItem 

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

func (UnimplementedDatabaseServer) ExistsItem 

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

func (UnimplementedDatabaseServer) GetCache 

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

func (UnimplementedDatabaseServer) GetCaches added in v2.0.27 

func (UnimplementedDatabaseServer) GetCaches(context.Context, *CachesRequest) (*CachesResult, error)

func (UnimplementedDatabaseServer) GetChildItems added in v2.0.28 

func (UnimplementedDatabaseServer) GetChildItems(context.Context, *ItemsRequest) (*ItemsResult, error)

func (UnimplementedDatabaseServer) GetCollection 

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

func (UnimplementedDatabaseServer) GetCollections 

func (UnimplementedDatabaseServer) GetCollections(*emptypb.Empty, Database_GetCollectionsServer) error

func (UnimplementedDatabaseServer) GetDerivateIngestItem added in v2.0.29 

func (UnimplementedDatabaseServer) GetDerivateIngestItem(context.Context, *DerivatIngestRequest) (*DerivatIngestResponse, error)

func (UnimplementedDatabaseServer) GetIngestItem 

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

func (UnimplementedDatabaseServer) GetItem 

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

func (UnimplementedDatabaseServer) GetItemMetadata 

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

func (UnimplementedDatabaseServer) GetStorage 

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

func (UnimplementedDatabaseServer) InsertCache 

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

func (UnimplementedDatabaseServer) Ping 

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

func (UnimplementedDatabaseServer) SetIngestItem 

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

type UnimplementedDeleterServer 

type UnimplementedDeleterServer struct {
}

UnimplementedDeleterServer must be embedded to have forward compatible implementations.

func (UnimplementedDeleterServer) DeleteCache 

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

func (UnimplementedDeleterServer) DeleteItem 

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

func (UnimplementedDeleterServer) DeleteItemCaches 

func (UnimplementedDeleterServer) DeleteItemCaches(context.Context, *ItemIdentifier) (*proto.DefaultResponse, error)

func (UnimplementedDeleterServer) Ping 

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

type UnsafeActionDispatcherServer 

type UnsafeActionDispatcherServer interface {
	// contains filtered or unexported methods
}

UnsafeActionDispatcherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionDispatcherServer will result in compilation errors.

type UnsafeActionServer 

type UnsafeActionServer interface {
	// contains filtered or unexported methods
}

UnsafeActionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionServer will result in compilation errors.

type UnsafeDatabaseServer 

type UnsafeDatabaseServer interface {
	// contains filtered or unexported methods
}

UnsafeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseServer will result in compilation errors.

type UnsafeDeleterServer 

type UnsafeDeleterServer interface {
	// contains filtered or unexported methods
}

UnsafeDeleterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeleterServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.