publishapi

package
v0.0.0-...-4fd112e Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2025 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrUnexpected   = errGroup.Register(errors.New("unexpected error"), uint64(ErrCodes_Unexpected))
	ErrNotFound     = errGroup.Register(errors.New("not found"), uint64(ErrCodes_NotFound))
	ErrAccessDenied = errGroup.Register(errors.New("access denied"), uint64(ErrCodes_AccessDenied))
	ErrUriNotUnique = errGroup.Register(errors.New("uri already taken"), uint64(ErrCodes_UriNotUnique))
)
View Source
var (
	ErrCodes_name = map[int32]string{
		0:    "Unexpected",
		1:    "NotFound",
		2:    "AccessDenied",
		3:    "UriNotUnique",
		1100: "ErrorOffset",
	}
	ErrCodes_value = map[string]int32{
		"Unexpected":   0,
		"NotFound":     1,
		"AccessDenied": 2,
		"UriNotUnique": 3,
		"ErrorOffset":  1100,
	}
)

Enum value maps for ErrCodes.

View Source
var (
	PublishStatus_name = map[int32]string{
		0: "PublishStatusCreated",
		1: "PublishStatusPublished",
	}
	PublishStatus_value = map[string]int32{
		"PublishStatusCreated":   0,
		"PublishStatusPublished": 1,
	}
)

Enum value maps for PublishStatus.

View Source
var File_publishclient_publishapi_protos_publisher_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterWebPublisher

func DRPCRegisterWebPublisher(mux drpc.Mux, impl DRPCWebPublisherServer) error

Types

type DRPCWebPublisherClient

type DRPCWebPublisherClient interface {
	DRPCConn() drpc.Conn

	ResolveUri(ctx context.Context, in *ResolveUriRequest) (*ResolveUriResponse, error)
	GetPublishStatus(ctx context.Context, in *GetPublishStatusRequest) (*GetPublishStatusResponse, error)
	Publish(ctx context.Context, in *PublishRequest) (*PublishResponse, error)
	UnPublish(ctx context.Context, in *UnPublishRequest) (*Ok, error)
	ListPublishes(ctx context.Context, in *ListPublishesRequest) (*ListPublishesResponse, error)
}

func NewDRPCWebPublisherClient

func NewDRPCWebPublisherClient(cc drpc.Conn) DRPCWebPublisherClient

type DRPCWebPublisherDescription

type DRPCWebPublisherDescription struct{}

func (DRPCWebPublisherDescription) Method

func (DRPCWebPublisherDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCWebPublisherDescription) NumMethods

func (DRPCWebPublisherDescription) NumMethods() int

type DRPCWebPublisherUnimplementedServer

type DRPCWebPublisherUnimplementedServer struct{}

func (*DRPCWebPublisherUnimplementedServer) GetPublishStatus

func (*DRPCWebPublisherUnimplementedServer) ListPublishes

func (*DRPCWebPublisherUnimplementedServer) Publish

func (*DRPCWebPublisherUnimplementedServer) ResolveUri

func (*DRPCWebPublisherUnimplementedServer) UnPublish

type DRPCWebPublisher_GetPublishStatusStream

type DRPCWebPublisher_GetPublishStatusStream interface {
	drpc.Stream
	SendAndClose(*GetPublishStatusResponse) error
}

type DRPCWebPublisher_ListPublishesStream

type DRPCWebPublisher_ListPublishesStream interface {
	drpc.Stream
	SendAndClose(*ListPublishesResponse) error
}

type DRPCWebPublisher_PublishStream

type DRPCWebPublisher_PublishStream interface {
	drpc.Stream
	SendAndClose(*PublishResponse) error
}

type DRPCWebPublisher_ResolveUriStream

type DRPCWebPublisher_ResolveUriStream interface {
	drpc.Stream
	SendAndClose(*ResolveUriResponse) error
}

type DRPCWebPublisher_UnPublishStream

type DRPCWebPublisher_UnPublishStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type ErrCodes

type ErrCodes int32
const (
	ErrCodes_Unexpected   ErrCodes = 0
	ErrCodes_NotFound     ErrCodes = 1
	ErrCodes_AccessDenied ErrCodes = 2
	ErrCodes_UriNotUnique ErrCodes = 3
	ErrCodes_ErrorOffset  ErrCodes = 1100
)

func (ErrCodes) Descriptor

func (ErrCodes) Descriptor() protoreflect.EnumDescriptor

func (ErrCodes) Enum

func (x ErrCodes) Enum() *ErrCodes

func (ErrCodes) EnumDescriptor deprecated

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

Deprecated: Use ErrCodes.Descriptor instead.

func (ErrCodes) Number

func (x ErrCodes) Number() protoreflect.EnumNumber

func (ErrCodes) String

func (x ErrCodes) String() string

func (ErrCodes) Type

type GetPublishStatusRequest

type GetPublishStatusRequest struct {
	SpaceId  string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPublishStatusRequest) Descriptor deprecated

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

Deprecated: Use GetPublishStatusRequest.ProtoReflect.Descriptor instead.

func (*GetPublishStatusRequest) GetObjectId

func (x *GetPublishStatusRequest) GetObjectId() string

func (*GetPublishStatusRequest) GetSpaceId

func (x *GetPublishStatusRequest) GetSpaceId() string

func (*GetPublishStatusRequest) MarshalToSizedBufferVT

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

func (*GetPublishStatusRequest) MarshalToVT

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

func (*GetPublishStatusRequest) MarshalVT

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

func (*GetPublishStatusRequest) ProtoMessage

func (*GetPublishStatusRequest) ProtoMessage()

func (*GetPublishStatusRequest) ProtoReflect

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

func (*GetPublishStatusRequest) Reset

func (x *GetPublishStatusRequest) Reset()

func (*GetPublishStatusRequest) SizeVT

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

func (*GetPublishStatusRequest) String

func (x *GetPublishStatusRequest) String() string

func (*GetPublishStatusRequest) UnmarshalVT

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

type GetPublishStatusResponse

type GetPublishStatusResponse struct {
	Publish *Publish `protobuf:"bytes,1,opt,name=publish,proto3" json:"publish,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPublishStatusResponse) Descriptor deprecated

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

Deprecated: Use GetPublishStatusResponse.ProtoReflect.Descriptor instead.

func (*GetPublishStatusResponse) GetPublish

func (x *GetPublishStatusResponse) GetPublish() *Publish

func (*GetPublishStatusResponse) MarshalToSizedBufferVT

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

func (*GetPublishStatusResponse) MarshalToVT

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

func (*GetPublishStatusResponse) MarshalVT

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

func (*GetPublishStatusResponse) ProtoMessage

func (*GetPublishStatusResponse) ProtoMessage()

func (*GetPublishStatusResponse) ProtoReflect

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

func (*GetPublishStatusResponse) Reset

func (x *GetPublishStatusResponse) Reset()

func (*GetPublishStatusResponse) SizeVT

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

func (*GetPublishStatusResponse) String

func (x *GetPublishStatusResponse) String() string

func (*GetPublishStatusResponse) UnmarshalVT

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

type ListPublishesRequest

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

func (*ListPublishesRequest) Descriptor deprecated

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

Deprecated: Use ListPublishesRequest.ProtoReflect.Descriptor instead.

func (*ListPublishesRequest) GetSpaceId

func (x *ListPublishesRequest) GetSpaceId() string

func (*ListPublishesRequest) MarshalToSizedBufferVT

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

func (*ListPublishesRequest) MarshalToVT

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

func (*ListPublishesRequest) MarshalVT

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

func (*ListPublishesRequest) ProtoMessage

func (*ListPublishesRequest) ProtoMessage()

func (*ListPublishesRequest) ProtoReflect

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

func (*ListPublishesRequest) Reset

func (x *ListPublishesRequest) Reset()

func (*ListPublishesRequest) SizeVT

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

func (*ListPublishesRequest) String

func (x *ListPublishesRequest) String() string

func (*ListPublishesRequest) UnmarshalVT

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

type ListPublishesResponse

type ListPublishesResponse struct {
	Publishes []*Publish `protobuf:"bytes,1,rep,name=publishes,proto3" json:"publishes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPublishesResponse) Descriptor deprecated

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

Deprecated: Use ListPublishesResponse.ProtoReflect.Descriptor instead.

func (*ListPublishesResponse) GetPublishes

func (x *ListPublishesResponse) GetPublishes() []*Publish

func (*ListPublishesResponse) MarshalToSizedBufferVT

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

func (*ListPublishesResponse) MarshalToVT

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

func (*ListPublishesResponse) MarshalVT

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

func (*ListPublishesResponse) ProtoMessage

func (*ListPublishesResponse) ProtoMessage()

func (*ListPublishesResponse) ProtoReflect

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

func (*ListPublishesResponse) Reset

func (x *ListPublishesResponse) Reset()

func (*ListPublishesResponse) SizeVT

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

func (*ListPublishesResponse) String

func (x *ListPublishesResponse) String() string

func (*ListPublishesResponse) UnmarshalVT

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

type Ok

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

func (*Ok) Descriptor deprecated

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

Deprecated: Use Ok.ProtoReflect.Descriptor instead.

func (*Ok) MarshalToSizedBufferVT

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

func (*Ok) MarshalToVT

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

func (*Ok) MarshalVT

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

func (*Ok) ProtoMessage

func (*Ok) ProtoMessage()

func (*Ok) ProtoReflect

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

func (*Ok) Reset

func (x *Ok) Reset()

func (*Ok) SizeVT

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

func (*Ok) String

func (x *Ok) String() string

func (*Ok) UnmarshalVT

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

type Publish

type Publish struct {
	SpaceId   string        `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	ObjectId  string        `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
	Uri       string        `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Status    PublishStatus `protobuf:"varint,4,opt,name=status,proto3,enum=client.PublishStatus" json:"status,omitempty"`
	Version   string        `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Timestamp int64         `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Size      int64         `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*Publish) Descriptor deprecated

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

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) GetObjectId

func (x *Publish) GetObjectId() string

func (*Publish) GetSize

func (x *Publish) GetSize() int64

func (*Publish) GetSpaceId

func (x *Publish) GetSpaceId() string

func (*Publish) GetStatus

func (x *Publish) GetStatus() PublishStatus

func (*Publish) GetTimestamp

func (x *Publish) GetTimestamp() int64

func (*Publish) GetUri

func (x *Publish) GetUri() string

func (*Publish) GetVersion

func (x *Publish) GetVersion() string

func (*Publish) MarshalToSizedBufferVT

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

func (*Publish) MarshalToVT

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

func (*Publish) MarshalVT

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

func (*Publish) ProtoMessage

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect

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

func (*Publish) Reset

func (x *Publish) Reset()

func (*Publish) SizeVT

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

func (*Publish) String

func (x *Publish) String() string

func (*Publish) UnmarshalVT

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

type PublishRequest

type PublishRequest struct {
	SpaceId  string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
	Uri      string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Version  string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetObjectId

func (x *PublishRequest) GetObjectId() string

func (*PublishRequest) GetSpaceId

func (x *PublishRequest) GetSpaceId() string

func (*PublishRequest) GetUri

func (x *PublishRequest) GetUri() string

func (*PublishRequest) GetVersion

func (x *PublishRequest) GetVersion() string

func (*PublishRequest) MarshalToSizedBufferVT

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

func (*PublishRequest) MarshalToVT

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

func (*PublishRequest) MarshalVT

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

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) SizeVT

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

func (*PublishRequest) String

func (x *PublishRequest) String() string

func (*PublishRequest) UnmarshalVT

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

type PublishResponse

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

func (*PublishResponse) Descriptor deprecated

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetUploadUrl

func (x *PublishResponse) GetUploadUrl() string

func (*PublishResponse) MarshalToSizedBufferVT

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

func (*PublishResponse) MarshalToVT

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

func (*PublishResponse) MarshalVT

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

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

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

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) SizeVT

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

func (*PublishResponse) String

func (x *PublishResponse) String() string

func (*PublishResponse) UnmarshalVT

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

type PublishStatus

type PublishStatus int32
const (
	// PublishStatusCreated means publish is created but not uploaded yet
	PublishStatus_PublishStatusCreated PublishStatus = 0
	// PublishStatusCreated means publish is active
	PublishStatus_PublishStatusPublished PublishStatus = 1
)

func (PublishStatus) Descriptor

func (PublishStatus) Enum

func (x PublishStatus) Enum() *PublishStatus

func (PublishStatus) EnumDescriptor deprecated

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

Deprecated: Use PublishStatus.Descriptor instead.

func (PublishStatus) Number

func (PublishStatus) String

func (x PublishStatus) String() string

func (PublishStatus) Type

type ResolveUriRequest

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

func (*ResolveUriRequest) Descriptor deprecated

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

Deprecated: Use ResolveUriRequest.ProtoReflect.Descriptor instead.

func (*ResolveUriRequest) GetUri

func (x *ResolveUriRequest) GetUri() string

func (*ResolveUriRequest) MarshalToSizedBufferVT

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

func (*ResolveUriRequest) MarshalToVT

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

func (*ResolveUriRequest) MarshalVT

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

func (*ResolveUriRequest) ProtoMessage

func (*ResolveUriRequest) ProtoMessage()

func (*ResolveUriRequest) ProtoReflect

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

func (*ResolveUriRequest) Reset

func (x *ResolveUriRequest) Reset()

func (*ResolveUriRequest) SizeVT

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

func (*ResolveUriRequest) String

func (x *ResolveUriRequest) String() string

func (*ResolveUriRequest) UnmarshalVT

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

type ResolveUriResponse

type ResolveUriResponse struct {
	Publish *Publish `protobuf:"bytes,1,opt,name=publish,proto3" json:"publish,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveUriResponse) Descriptor deprecated

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

Deprecated: Use ResolveUriResponse.ProtoReflect.Descriptor instead.

func (*ResolveUriResponse) GetPublish

func (x *ResolveUriResponse) GetPublish() *Publish

func (*ResolveUriResponse) MarshalToSizedBufferVT

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

func (*ResolveUriResponse) MarshalToVT

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

func (*ResolveUriResponse) MarshalVT

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

func (*ResolveUriResponse) ProtoMessage

func (*ResolveUriResponse) ProtoMessage()

func (*ResolveUriResponse) ProtoReflect

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

func (*ResolveUriResponse) Reset

func (x *ResolveUriResponse) Reset()

func (*ResolveUriResponse) SizeVT

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

func (*ResolveUriResponse) String

func (x *ResolveUriResponse) String() string

func (*ResolveUriResponse) UnmarshalVT

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

type UnPublishRequest

type UnPublishRequest struct {
	SpaceId  string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
	// contains filtered or unexported fields
}

func (*UnPublishRequest) Descriptor deprecated

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

Deprecated: Use UnPublishRequest.ProtoReflect.Descriptor instead.

func (*UnPublishRequest) GetObjectId

func (x *UnPublishRequest) GetObjectId() string

func (*UnPublishRequest) GetSpaceId

func (x *UnPublishRequest) GetSpaceId() string

func (*UnPublishRequest) MarshalToSizedBufferVT

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

func (*UnPublishRequest) MarshalToVT

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

func (*UnPublishRequest) MarshalVT

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

func (*UnPublishRequest) ProtoMessage

func (*UnPublishRequest) ProtoMessage()

func (*UnPublishRequest) ProtoReflect

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

func (*UnPublishRequest) Reset

func (x *UnPublishRequest) Reset()

func (*UnPublishRequest) SizeVT

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

func (*UnPublishRequest) String

func (x *UnPublishRequest) String() string

func (*UnPublishRequest) UnmarshalVT

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL