Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type Content
- func (*Content) Descriptor() ([]byte, []int)deprecated
- func (x *Content) GetCurator() []byte
- func (x *Content) GetId() uint64
- func (x *Content) GetMetadata() string
- func (*Content) ProtoMessage()
- func (x *Content) ProtoReflect() protoreflect.Message
- func (x *Content) Reset()
- func (x *Content) String() string
- type ContentCuratorIndexKey
- type ContentIdIndexKey
- type ContentIndexKey
- type ContentIterator
- type ContentPrimaryKey
- type ContentTable
- type EventCreate
- type EventDelete
- type EventUpdateCurator
- type EventUpdateMetadata
- func (*EventUpdateMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *EventUpdateMetadata) GetId() uint64
- func (*EventUpdateMetadata) ProtoMessage()
- func (x *EventUpdateMetadata) ProtoReflect() protoreflect.Message
- func (x *EventUpdateMetadata) Reset()
- func (x *EventUpdateMetadata) String() string
- type MsgClient
- type MsgCreate
- type MsgCreateResponse
- type MsgDelete
- type MsgDeleteResponse
- type MsgServer
- type MsgUpdateCurator
- func (*MsgUpdateCurator) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateCurator) GetCurator() string
- func (x *MsgUpdateCurator) GetId() uint64
- func (x *MsgUpdateCurator) GetNewCurator() string
- func (*MsgUpdateCurator) ProtoMessage()
- func (x *MsgUpdateCurator) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateCurator) Reset()
- func (x *MsgUpdateCurator) String() string
- type MsgUpdateCuratorResponse
- func (*MsgUpdateCuratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateCuratorResponse) GetId() uint64
- func (*MsgUpdateCuratorResponse) ProtoMessage()
- func (x *MsgUpdateCuratorResponse) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateCuratorResponse) Reset()
- func (x *MsgUpdateCuratorResponse) String() string
- type MsgUpdateMetadata
- func (*MsgUpdateMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateMetadata) GetCurator() string
- func (x *MsgUpdateMetadata) GetId() uint64
- func (x *MsgUpdateMetadata) GetNewMetadata() string
- func (*MsgUpdateMetadata) ProtoMessage()
- func (x *MsgUpdateMetadata) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateMetadata) Reset()
- func (x *MsgUpdateMetadata) String() string
- type MsgUpdateMetadataResponse
- func (*MsgUpdateMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateMetadataResponse) GetId() uint64
- func (*MsgUpdateMetadataResponse) ProtoMessage()
- func (x *MsgUpdateMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateMetadataResponse) Reset()
- func (x *MsgUpdateMetadataResponse) String() string
- type QueryClient
- type QueryContentRequest
- func (*QueryContentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentRequest) GetId() uint64
- func (*QueryContentRequest) ProtoMessage()
- func (x *QueryContentRequest) ProtoReflect() protoreflect.Message
- func (x *QueryContentRequest) Reset()
- func (x *QueryContentRequest) String() string
- type QueryContentResponse
- func (*QueryContentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentResponse) GetCurator() string
- func (x *QueryContentResponse) GetId() uint64
- func (x *QueryContentResponse) GetMetadata() string
- func (*QueryContentResponse) ProtoMessage()
- func (x *QueryContentResponse) ProtoReflect() protoreflect.Message
- func (x *QueryContentResponse) Reset()
- func (x *QueryContentResponse) String() string
- type QueryContentsByCuratorRequest
- func (*QueryContentsByCuratorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsByCuratorRequest) GetCurator() string
- func (x *QueryContentsByCuratorRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryContentsByCuratorRequest) ProtoMessage()
- func (x *QueryContentsByCuratorRequest) ProtoReflect() protoreflect.Message
- func (x *QueryContentsByCuratorRequest) Reset()
- func (x *QueryContentsByCuratorRequest) String() string
- type QueryContentsByCuratorResponse
- func (*QueryContentsByCuratorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsByCuratorResponse) GetContents() []*QueryContentsByCuratorResponse_Content
- func (x *QueryContentsByCuratorResponse) GetCurator() string
- func (x *QueryContentsByCuratorResponse) GetPagination() *v1beta1.PageResponse
- func (*QueryContentsByCuratorResponse) ProtoMessage()
- func (x *QueryContentsByCuratorResponse) ProtoReflect() protoreflect.Message
- func (x *QueryContentsByCuratorResponse) Reset()
- func (x *QueryContentsByCuratorResponse) String() string
- type QueryContentsByCuratorResponse_Content
- func (*QueryContentsByCuratorResponse_Content) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsByCuratorResponse_Content) GetId() uint64
- func (x *QueryContentsByCuratorResponse_Content) GetMetadata() string
- func (*QueryContentsByCuratorResponse_Content) ProtoMessage()
- func (x *QueryContentsByCuratorResponse_Content) ProtoReflect() protoreflect.Message
- func (x *QueryContentsByCuratorResponse_Content) Reset()
- func (x *QueryContentsByCuratorResponse_Content) String() string
- type QueryContentsRequest
- func (*QueryContentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryContentsRequest) ProtoMessage()
- func (x *QueryContentsRequest) ProtoReflect() protoreflect.Message
- func (x *QueryContentsRequest) Reset()
- func (x *QueryContentsRequest) String() string
- type QueryContentsResponse
- func (*QueryContentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsResponse) GetContents() []*QueryContentsResponse_Content
- func (x *QueryContentsResponse) GetPagination() *v1beta1.PageResponse
- func (*QueryContentsResponse) ProtoMessage()
- func (x *QueryContentsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryContentsResponse) Reset()
- func (x *QueryContentsResponse) String() string
- type QueryContentsResponse_Content
- func (*QueryContentsResponse_Content) Descriptor() ([]byte, []int)deprecated
- func (x *QueryContentsResponse_Content) GetCurator() string
- func (x *QueryContentsResponse_Content) GetId() uint64
- func (x *QueryContentsResponse_Content) GetMetadata() string
- func (*QueryContentsResponse_Content) ProtoMessage()
- func (x *QueryContentsResponse_Content) ProtoReflect() protoreflect.Message
- func (x *QueryContentsResponse_Content) Reset()
- func (x *QueryContentsResponse_Content) String() string
- type QueryServer
- type StateStore
- type UnimplementedMsgServer
- func (UnimplementedMsgServer) Create(context.Context, *MsgCreate) (*MsgCreateResponse, error)
- func (UnimplementedMsgServer) Delete(context.Context, *MsgDelete) (*MsgDeleteResponse, error)
- func (UnimplementedMsgServer) UpdateCurator(context.Context, *MsgUpdateCurator) (*MsgUpdateCuratorResponse, error)
- func (UnimplementedMsgServer) UpdateMetadata(context.Context, *MsgUpdateMetadata) (*MsgUpdateMetadataResponse, error)
- type UnimplementedQueryServer
- func (UnimplementedQueryServer) Content(context.Context, *QueryContentRequest) (*QueryContentResponse, error)
- func (UnimplementedQueryServer) Contents(context.Context, *QueryContentsRequest) (*QueryContentsResponse, error)
- func (UnimplementedQueryServer) ContentsByCurator(context.Context, *QueryContentsByCuratorRequest) (*QueryContentsByCuratorResponse, error)
- type UnsafeMsgServer
- type UnsafeQueryServer
Constants ¶
const ( Msg_Create_FullMethodName = "/chora.content.v1.Msg/Create" Msg_Delete_FullMethodName = "/chora.content.v1.Msg/Delete" Msg_UpdateCurator_FullMethodName = "/chora.content.v1.Msg/UpdateCurator" Msg_UpdateMetadata_FullMethodName = "/chora.content.v1.Msg/UpdateMetadata" )
const ( Query_Content_FullMethodName = "/chora.content.v1.Query/Content" Query_Contents_FullMethodName = "/chora.content.v1.Query/Contents" Query_ContentsByCurator_FullMethodName = "/chora.content.v1.Query/ContentsByCurator" )
Variables ¶
var File_chora_content_v1_doc_proto protoreflect.FileDescriptor
var File_chora_content_v1_events_proto protoreflect.FileDescriptor
var File_chora_content_v1_msg_proto protoreflect.FileDescriptor
var File_chora_content_v1_query_proto protoreflect.FileDescriptor
var File_chora_content_v1_state_proto protoreflect.FileDescriptor
var Msg_ServiceDesc = grpc.ServiceDesc{ ServiceName: "chora.content.v1.Msg", HandlerType: (*MsgServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Msg_Create_Handler, }, { MethodName: "Delete", Handler: _Msg_Delete_Handler, }, { MethodName: "UpdateCurator", Handler: _Msg_UpdateCurator_Handler, }, { MethodName: "UpdateMetadata", Handler: _Msg_UpdateMetadata_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "chora/content/v1/msg.proto", }
Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "chora.content.v1.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Content", Handler: _Query_Content_Handler, }, { MethodName: "Contents", Handler: _Query_Contents_Handler, }, { MethodName: "ContentsByCurator", Handler: _Query_ContentsByCurator_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "chora/content/v1/query.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMsgServer ¶
func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type Content ¶
type Content struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator []byte `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // metadata is the metadata of the content. Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
Content defines the table and properties of a content.
func (*Content) Descriptor
deprecated
func (*Content) GetCurator ¶
func (*Content) GetMetadata ¶
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type ContentCuratorIndexKey ¶
type ContentCuratorIndexKey struct {
// contains filtered or unexported fields
}
func (ContentCuratorIndexKey) WithCurator ¶
func (this ContentCuratorIndexKey) WithCurator(curator []byte) ContentCuratorIndexKey
type ContentIdIndexKey ¶
type ContentIdIndexKey struct {
// contains filtered or unexported fields
}
func (ContentIdIndexKey) WithId ¶
func (this ContentIdIndexKey) WithId(id uint64) ContentIdIndexKey
type ContentIndexKey ¶
type ContentIndexKey interface {
// contains filtered or unexported methods
}
type ContentIterator ¶
func (ContentIterator) Value ¶
func (i ContentIterator) Value() (*Content, error)
type ContentTable ¶
type ContentTable interface { Insert(ctx context.Context, content *Content) error InsertReturningId(ctx context.Context, content *Content) (uint64, error) LastInsertedSequence(ctx context.Context) (uint64, error) Update(ctx context.Context, content *Content) error Save(ctx context.Context, content *Content) error Delete(ctx context.Context, content *Content) error Has(ctx context.Context, id uint64) (found bool, err error) // Get returns nil and an error which responds true to ormerrors.IsNotFound() if the record was not found. Get(ctx context.Context, id uint64) (*Content, error) List(ctx context.Context, prefixKey ContentIndexKey, opts ...ormlist.Option) (ContentIterator, error) ListRange(ctx context.Context, from, to ContentIndexKey, opts ...ormlist.Option) (ContentIterator, error) DeleteBy(ctx context.Context, prefixKey ContentIndexKey) error DeleteRange(ctx context.Context, from, to ContentIndexKey) error // contains filtered or unexported methods }
func NewContentTable ¶
func NewContentTable(db ormtable.Schema) (ContentTable, error)
type EventCreate ¶
type EventCreate struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
EventCreate is an event emitted when content is created.
func (*EventCreate) Descriptor
deprecated
func (*EventCreate) Descriptor() ([]byte, []int)
Deprecated: Use EventCreate.ProtoReflect.Descriptor instead.
func (*EventCreate) GetId ¶
func (x *EventCreate) GetId() uint64
func (*EventCreate) ProtoMessage ¶
func (*EventCreate) ProtoMessage()
func (*EventCreate) ProtoReflect ¶
func (x *EventCreate) ProtoReflect() protoreflect.Message
func (*EventCreate) Reset ¶
func (x *EventCreate) Reset()
func (*EventCreate) String ¶
func (x *EventCreate) String() string
type EventDelete ¶
type EventDelete struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
EventDelete is an event emitted when content is deleted.
func (*EventDelete) Descriptor
deprecated
func (*EventDelete) Descriptor() ([]byte, []int)
Deprecated: Use EventDelete.ProtoReflect.Descriptor instead.
func (*EventDelete) GetId ¶
func (x *EventDelete) GetId() uint64
func (*EventDelete) ProtoMessage ¶
func (*EventDelete) ProtoMessage()
func (*EventDelete) ProtoReflect ¶
func (x *EventDelete) ProtoReflect() protoreflect.Message
func (*EventDelete) Reset ¶
func (x *EventDelete) Reset()
func (*EventDelete) String ¶
func (x *EventDelete) String() string
type EventUpdateCurator ¶
type EventUpdateCurator struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
EventUpdateCurator is an event emitted when content curator is updated.
func (*EventUpdateCurator) Descriptor
deprecated
func (*EventUpdateCurator) Descriptor() ([]byte, []int)
Deprecated: Use EventUpdateCurator.ProtoReflect.Descriptor instead.
func (*EventUpdateCurator) GetId ¶
func (x *EventUpdateCurator) GetId() uint64
func (*EventUpdateCurator) ProtoMessage ¶
func (*EventUpdateCurator) ProtoMessage()
func (*EventUpdateCurator) ProtoReflect ¶
func (x *EventUpdateCurator) ProtoReflect() protoreflect.Message
func (*EventUpdateCurator) Reset ¶
func (x *EventUpdateCurator) Reset()
func (*EventUpdateCurator) String ¶
func (x *EventUpdateCurator) String() string
type EventUpdateMetadata ¶
type EventUpdateMetadata struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
EventUpdateMetadata is an event emitted when content metadata is updated.
func (*EventUpdateMetadata) Descriptor
deprecated
func (*EventUpdateMetadata) Descriptor() ([]byte, []int)
Deprecated: Use EventUpdateMetadata.ProtoReflect.Descriptor instead.
func (*EventUpdateMetadata) GetId ¶
func (x *EventUpdateMetadata) GetId() uint64
func (*EventUpdateMetadata) ProtoMessage ¶
func (*EventUpdateMetadata) ProtoMessage()
func (*EventUpdateMetadata) ProtoReflect ¶
func (x *EventUpdateMetadata) ProtoReflect() protoreflect.Message
func (*EventUpdateMetadata) Reset ¶
func (x *EventUpdateMetadata) Reset()
func (*EventUpdateMetadata) String ¶
func (x *EventUpdateMetadata) String() string
type MsgClient ¶
type MsgClient interface { // Create creates content. Create(ctx context.Context, in *MsgCreate, opts ...grpc.CallOption) (*MsgCreateResponse, error) // Delete deletes content. Delete(ctx context.Context, in *MsgDelete, opts ...grpc.CallOption) (*MsgDeleteResponse, error) // UpdateCurator updates the curator of content. UpdateCurator(ctx context.Context, in *MsgUpdateCurator, opts ...grpc.CallOption) (*MsgUpdateCuratorResponse, error) // UpdateMetadata updates the metadata of content. UpdateMetadata(ctx context.Context, in *MsgUpdateMetadata, opts ...grpc.CallOption) (*MsgUpdateMetadataResponse, error) }
MsgClient is the client API for Msg 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 NewMsgClient ¶
func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
type MsgCreate ¶
type MsgCreate struct { // curator is the address of the content curator. Curator string `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"` // metadata is the metadata of the content. Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
MsgCreate is the Msg/Create request type.
func (*MsgCreate) Descriptor
deprecated
func (*MsgCreate) GetCurator ¶
func (*MsgCreate) GetMetadata ¶
func (*MsgCreate) ProtoMessage ¶
func (*MsgCreate) ProtoMessage()
func (*MsgCreate) ProtoReflect ¶
func (x *MsgCreate) ProtoReflect() protoreflect.Message
type MsgCreateResponse ¶
type MsgCreateResponse struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
MsgCreateResponse is the Msg/Create response type.
func (*MsgCreateResponse) Descriptor
deprecated
func (*MsgCreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgCreateResponse.ProtoReflect.Descriptor instead.
func (*MsgCreateResponse) GetId ¶
func (x *MsgCreateResponse) GetId() uint64
func (*MsgCreateResponse) ProtoMessage ¶
func (*MsgCreateResponse) ProtoMessage()
func (*MsgCreateResponse) ProtoReflect ¶
func (x *MsgCreateResponse) ProtoReflect() protoreflect.Message
func (*MsgCreateResponse) Reset ¶
func (x *MsgCreateResponse) Reset()
func (*MsgCreateResponse) String ¶
func (x *MsgCreateResponse) String() string
type MsgDelete ¶
type MsgDelete struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // contains filtered or unexported fields }
MsgDelete is the Msg/Delete request type.
func (*MsgDelete) Descriptor
deprecated
func (*MsgDelete) GetCurator ¶
func (*MsgDelete) ProtoMessage ¶
func (*MsgDelete) ProtoMessage()
func (*MsgDelete) ProtoReflect ¶
func (x *MsgDelete) ProtoReflect() protoreflect.Message
type MsgDeleteResponse ¶
type MsgDeleteResponse struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
MsgDeleteResponse is the Msg/Delete response type.
func (*MsgDeleteResponse) Descriptor
deprecated
func (*MsgDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgDeleteResponse.ProtoReflect.Descriptor instead.
func (*MsgDeleteResponse) GetId ¶
func (x *MsgDeleteResponse) GetId() uint64
func (*MsgDeleteResponse) ProtoMessage ¶
func (*MsgDeleteResponse) ProtoMessage()
func (*MsgDeleteResponse) ProtoReflect ¶
func (x *MsgDeleteResponse) ProtoReflect() protoreflect.Message
func (*MsgDeleteResponse) Reset ¶
func (x *MsgDeleteResponse) Reset()
func (*MsgDeleteResponse) String ¶
func (x *MsgDeleteResponse) String() string
type MsgServer ¶
type MsgServer interface { // Create creates content. Create(context.Context, *MsgCreate) (*MsgCreateResponse, error) // Delete deletes content. Delete(context.Context, *MsgDelete) (*MsgDeleteResponse, error) // UpdateCurator updates the curator of content. UpdateCurator(context.Context, *MsgUpdateCurator) (*MsgUpdateCuratorResponse, error) // UpdateMetadata updates the metadata of content. UpdateMetadata(context.Context, *MsgUpdateMetadata) (*MsgUpdateMetadataResponse, error) // contains filtered or unexported methods }
MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility
type MsgUpdateCurator ¶
type MsgUpdateCurator struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // new_curator is the address of the new curator. NewCurator string `protobuf:"bytes,3,opt,name=new_curator,json=newCurator,proto3" json:"new_curator,omitempty"` // contains filtered or unexported fields }
MsgUpdateCurator is the Msg/UpdateCurator request type.
func (*MsgUpdateCurator) Descriptor
deprecated
func (*MsgUpdateCurator) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateCurator.ProtoReflect.Descriptor instead.
func (*MsgUpdateCurator) GetCurator ¶
func (x *MsgUpdateCurator) GetCurator() string
func (*MsgUpdateCurator) GetId ¶
func (x *MsgUpdateCurator) GetId() uint64
func (*MsgUpdateCurator) GetNewCurator ¶
func (x *MsgUpdateCurator) GetNewCurator() string
func (*MsgUpdateCurator) ProtoMessage ¶
func (*MsgUpdateCurator) ProtoMessage()
func (*MsgUpdateCurator) ProtoReflect ¶
func (x *MsgUpdateCurator) ProtoReflect() protoreflect.Message
func (*MsgUpdateCurator) Reset ¶
func (x *MsgUpdateCurator) Reset()
func (*MsgUpdateCurator) String ¶
func (x *MsgUpdateCurator) String() string
type MsgUpdateCuratorResponse ¶
type MsgUpdateCuratorResponse struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
MsgUpdateCuratorResponse is the Msg/UpdateCurator response type.
func (*MsgUpdateCuratorResponse) Descriptor
deprecated
func (*MsgUpdateCuratorResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateCuratorResponse.ProtoReflect.Descriptor instead.
func (*MsgUpdateCuratorResponse) GetId ¶
func (x *MsgUpdateCuratorResponse) GetId() uint64
func (*MsgUpdateCuratorResponse) ProtoMessage ¶
func (*MsgUpdateCuratorResponse) ProtoMessage()
func (*MsgUpdateCuratorResponse) ProtoReflect ¶
func (x *MsgUpdateCuratorResponse) ProtoReflect() protoreflect.Message
func (*MsgUpdateCuratorResponse) Reset ¶
func (x *MsgUpdateCuratorResponse) Reset()
func (*MsgUpdateCuratorResponse) String ¶
func (x *MsgUpdateCuratorResponse) String() string
type MsgUpdateMetadata ¶
type MsgUpdateMetadata struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // new_metadata is the new metadata of the content. NewMetadata string `protobuf:"bytes,3,opt,name=new_metadata,json=newMetadata,proto3" json:"new_metadata,omitempty"` // contains filtered or unexported fields }
MsgUpdateMetadata is the Msg/UpdateMetadata request type.
func (*MsgUpdateMetadata) Descriptor
deprecated
func (*MsgUpdateMetadata) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateMetadata.ProtoReflect.Descriptor instead.
func (*MsgUpdateMetadata) GetCurator ¶
func (x *MsgUpdateMetadata) GetCurator() string
func (*MsgUpdateMetadata) GetId ¶
func (x *MsgUpdateMetadata) GetId() uint64
func (*MsgUpdateMetadata) GetNewMetadata ¶
func (x *MsgUpdateMetadata) GetNewMetadata() string
func (*MsgUpdateMetadata) ProtoMessage ¶
func (*MsgUpdateMetadata) ProtoMessage()
func (*MsgUpdateMetadata) ProtoReflect ¶
func (x *MsgUpdateMetadata) ProtoReflect() protoreflect.Message
func (*MsgUpdateMetadata) Reset ¶
func (x *MsgUpdateMetadata) Reset()
func (*MsgUpdateMetadata) String ¶
func (x *MsgUpdateMetadata) String() string
type MsgUpdateMetadataResponse ¶
type MsgUpdateMetadataResponse struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
MsgUpdateMetadataResponse is the Msg/UpdateMetadata response type.
func (*MsgUpdateMetadataResponse) Descriptor
deprecated
func (*MsgUpdateMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateMetadataResponse.ProtoReflect.Descriptor instead.
func (*MsgUpdateMetadataResponse) GetId ¶
func (x *MsgUpdateMetadataResponse) GetId() uint64
func (*MsgUpdateMetadataResponse) ProtoMessage ¶
func (*MsgUpdateMetadataResponse) ProtoMessage()
func (*MsgUpdateMetadataResponse) ProtoReflect ¶
func (x *MsgUpdateMetadataResponse) ProtoReflect() protoreflect.Message
func (*MsgUpdateMetadataResponse) Reset ¶
func (x *MsgUpdateMetadataResponse) Reset()
func (*MsgUpdateMetadataResponse) String ¶
func (x *MsgUpdateMetadataResponse) String() string
type QueryClient ¶
type QueryClient interface { // Content queries a content by id. Content(ctx context.Context, in *QueryContentRequest, opts ...grpc.CallOption) (*QueryContentResponse, error) // Contents queries all contents. Contents(ctx context.Context, in *QueryContentsRequest, opts ...grpc.CallOption) (*QueryContentsResponse, error) // ContentsByCurator queries contents by curator. ContentsByCurator(ctx context.Context, in *QueryContentsByCuratorRequest, opts ...grpc.CallOption) (*QueryContentsByCuratorResponse, error) }
QueryClient is the client API for Query 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 NewQueryClient ¶
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryContentRequest ¶
type QueryContentRequest struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
QueryContentRequest is the Query/Content request type.
func (*QueryContentRequest) Descriptor
deprecated
func (*QueryContentRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentRequest.ProtoReflect.Descriptor instead.
func (*QueryContentRequest) GetId ¶
func (x *QueryContentRequest) GetId() uint64
func (*QueryContentRequest) ProtoMessage ¶
func (*QueryContentRequest) ProtoMessage()
func (*QueryContentRequest) ProtoReflect ¶
func (x *QueryContentRequest) ProtoReflect() protoreflect.Message
func (*QueryContentRequest) Reset ¶
func (x *QueryContentRequest) Reset()
func (*QueryContentRequest) String ¶
func (x *QueryContentRequest) String() string
type QueryContentResponse ¶
type QueryContentResponse struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // metadata is the metadata of the content. Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
QueryContentResponse is the Query/Content response type.
func (*QueryContentResponse) Descriptor
deprecated
func (*QueryContentResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentResponse.ProtoReflect.Descriptor instead.
func (*QueryContentResponse) GetCurator ¶
func (x *QueryContentResponse) GetCurator() string
func (*QueryContentResponse) GetId ¶
func (x *QueryContentResponse) GetId() uint64
func (*QueryContentResponse) GetMetadata ¶
func (x *QueryContentResponse) GetMetadata() string
func (*QueryContentResponse) ProtoMessage ¶
func (*QueryContentResponse) ProtoMessage()
func (*QueryContentResponse) ProtoReflect ¶
func (x *QueryContentResponse) ProtoReflect() protoreflect.Message
func (*QueryContentResponse) Reset ¶
func (x *QueryContentResponse) Reset()
func (*QueryContentResponse) String ¶
func (x *QueryContentResponse) String() string
type QueryContentsByCuratorRequest ¶
type QueryContentsByCuratorRequest struct { // curator is the address of the content curator. Curator string `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"` // pagination is the optional pagination of the request. Pagination *v1beta1.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
QueryContentsByCuratorRequest is the Query/ContentsByCurator request type.
func (*QueryContentsByCuratorRequest) Descriptor
deprecated
func (*QueryContentsByCuratorRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsByCuratorRequest.ProtoReflect.Descriptor instead.
func (*QueryContentsByCuratorRequest) GetCurator ¶
func (x *QueryContentsByCuratorRequest) GetCurator() string
func (*QueryContentsByCuratorRequest) GetPagination ¶
func (x *QueryContentsByCuratorRequest) GetPagination() *v1beta1.PageRequest
func (*QueryContentsByCuratorRequest) ProtoMessage ¶
func (*QueryContentsByCuratorRequest) ProtoMessage()
func (*QueryContentsByCuratorRequest) ProtoReflect ¶
func (x *QueryContentsByCuratorRequest) ProtoReflect() protoreflect.Message
func (*QueryContentsByCuratorRequest) Reset ¶
func (x *QueryContentsByCuratorRequest) Reset()
func (*QueryContentsByCuratorRequest) String ¶
func (x *QueryContentsByCuratorRequest) String() string
type QueryContentsByCuratorResponse ¶
type QueryContentsByCuratorResponse struct { // curator is the address of the content curator. Curator string `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"` // contents is the list of contents managed by the curator. Contents []*QueryContentsByCuratorResponse_Content `protobuf:"bytes,2,rep,name=contents,proto3" json:"contents,omitempty"` // pagination is the pagination of the response. Pagination *v1beta1.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
QueryContentsByCuratorResponse is the Query/ContentsByCurator response type.
func (*QueryContentsByCuratorResponse) Descriptor
deprecated
func (*QueryContentsByCuratorResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsByCuratorResponse.ProtoReflect.Descriptor instead.
func (*QueryContentsByCuratorResponse) GetContents ¶
func (x *QueryContentsByCuratorResponse) GetContents() []*QueryContentsByCuratorResponse_Content
func (*QueryContentsByCuratorResponse) GetCurator ¶
func (x *QueryContentsByCuratorResponse) GetCurator() string
func (*QueryContentsByCuratorResponse) GetPagination ¶
func (x *QueryContentsByCuratorResponse) GetPagination() *v1beta1.PageResponse
func (*QueryContentsByCuratorResponse) ProtoMessage ¶
func (*QueryContentsByCuratorResponse) ProtoMessage()
func (*QueryContentsByCuratorResponse) ProtoReflect ¶
func (x *QueryContentsByCuratorResponse) ProtoReflect() protoreflect.Message
func (*QueryContentsByCuratorResponse) Reset ¶
func (x *QueryContentsByCuratorResponse) Reset()
func (*QueryContentsByCuratorResponse) String ¶
func (x *QueryContentsByCuratorResponse) String() string
type QueryContentsByCuratorResponse_Content ¶
type QueryContentsByCuratorResponse_Content struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // metadata is the metadata of the content. Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
Content is the content properties.
func (*QueryContentsByCuratorResponse_Content) Descriptor
deprecated
func (*QueryContentsByCuratorResponse_Content) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsByCuratorResponse_Content.ProtoReflect.Descriptor instead.
func (*QueryContentsByCuratorResponse_Content) GetId ¶
func (x *QueryContentsByCuratorResponse_Content) GetId() uint64
func (*QueryContentsByCuratorResponse_Content) GetMetadata ¶
func (x *QueryContentsByCuratorResponse_Content) GetMetadata() string
func (*QueryContentsByCuratorResponse_Content) ProtoMessage ¶
func (*QueryContentsByCuratorResponse_Content) ProtoMessage()
func (*QueryContentsByCuratorResponse_Content) ProtoReflect ¶
func (x *QueryContentsByCuratorResponse_Content) ProtoReflect() protoreflect.Message
func (*QueryContentsByCuratorResponse_Content) Reset ¶
func (x *QueryContentsByCuratorResponse_Content) Reset()
func (*QueryContentsByCuratorResponse_Content) String ¶
func (x *QueryContentsByCuratorResponse_Content) String() string
type QueryContentsRequest ¶
type QueryContentsRequest struct { // pagination is the optional pagination of the request. Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
QueryContentsRequest is the Query/Contents request type.
func (*QueryContentsRequest) Descriptor
deprecated
func (*QueryContentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsRequest.ProtoReflect.Descriptor instead.
func (*QueryContentsRequest) GetPagination ¶
func (x *QueryContentsRequest) GetPagination() *v1beta1.PageRequest
func (*QueryContentsRequest) ProtoMessage ¶
func (*QueryContentsRequest) ProtoMessage()
func (*QueryContentsRequest) ProtoReflect ¶
func (x *QueryContentsRequest) ProtoReflect() protoreflect.Message
func (*QueryContentsRequest) Reset ¶
func (x *QueryContentsRequest) Reset()
func (*QueryContentsRequest) String ¶
func (x *QueryContentsRequest) String() string
type QueryContentsResponse ¶
type QueryContentsResponse struct { // contents is the list of contents. Contents []*QueryContentsResponse_Content `protobuf:"bytes,1,rep,name=contents,proto3" json:"contents,omitempty"` // pagination is the pagination of the response. Pagination *v1beta1.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
QueryContentsResponse is the Query/Contents response type.
func (*QueryContentsResponse) Descriptor
deprecated
func (*QueryContentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsResponse.ProtoReflect.Descriptor instead.
func (*QueryContentsResponse) GetContents ¶
func (x *QueryContentsResponse) GetContents() []*QueryContentsResponse_Content
func (*QueryContentsResponse) GetPagination ¶
func (x *QueryContentsResponse) GetPagination() *v1beta1.PageResponse
func (*QueryContentsResponse) ProtoMessage ¶
func (*QueryContentsResponse) ProtoMessage()
func (*QueryContentsResponse) ProtoReflect ¶
func (x *QueryContentsResponse) ProtoReflect() protoreflect.Message
func (*QueryContentsResponse) Reset ¶
func (x *QueryContentsResponse) Reset()
func (*QueryContentsResponse) String ¶
func (x *QueryContentsResponse) String() string
type QueryContentsResponse_Content ¶
type QueryContentsResponse_Content struct { // id is the unique identifier of the content. Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // curator is the address of the content curator. Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"` // metadata is the metadata of the content. Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
Content is the content properties.
func (*QueryContentsResponse_Content) Descriptor
deprecated
func (*QueryContentsResponse_Content) Descriptor() ([]byte, []int)
Deprecated: Use QueryContentsResponse_Content.ProtoReflect.Descriptor instead.
func (*QueryContentsResponse_Content) GetCurator ¶
func (x *QueryContentsResponse_Content) GetCurator() string
func (*QueryContentsResponse_Content) GetId ¶
func (x *QueryContentsResponse_Content) GetId() uint64
func (*QueryContentsResponse_Content) GetMetadata ¶
func (x *QueryContentsResponse_Content) GetMetadata() string
func (*QueryContentsResponse_Content) ProtoMessage ¶
func (*QueryContentsResponse_Content) ProtoMessage()
func (*QueryContentsResponse_Content) ProtoReflect ¶
func (x *QueryContentsResponse_Content) ProtoReflect() protoreflect.Message
func (*QueryContentsResponse_Content) Reset ¶
func (x *QueryContentsResponse_Content) Reset()
func (*QueryContentsResponse_Content) String ¶
func (x *QueryContentsResponse_Content) String() string
type QueryServer ¶
type QueryServer interface { // Content queries a content by id. Content(context.Context, *QueryContentRequest) (*QueryContentResponse, error) // Contents queries all contents. Contents(context.Context, *QueryContentsRequest) (*QueryContentsResponse, error) // ContentsByCurator queries contents by curator. ContentsByCurator(context.Context, *QueryContentsByCuratorRequest) (*QueryContentsByCuratorResponse, error) // contains filtered or unexported methods }
QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility
type StateStore ¶
type StateStore interface { ContentTable() ContentTable // contains filtered or unexported methods }
func NewStateStore ¶
func NewStateStore(db ormtable.Schema) (StateStore, error)
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer must be embedded to have forward compatible implementations.
func (UnimplementedMsgServer) Create ¶
func (UnimplementedMsgServer) Create(context.Context, *MsgCreate) (*MsgCreateResponse, error)
func (UnimplementedMsgServer) Delete ¶
func (UnimplementedMsgServer) Delete(context.Context, *MsgDelete) (*MsgDeleteResponse, error)
func (UnimplementedMsgServer) UpdateCurator ¶
func (UnimplementedMsgServer) UpdateCurator(context.Context, *MsgUpdateCurator) (*MsgUpdateCuratorResponse, error)
func (UnimplementedMsgServer) UpdateMetadata ¶
func (UnimplementedMsgServer) UpdateMetadata(context.Context, *MsgUpdateMetadata) (*MsgUpdateMetadataResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) Content ¶
func (UnimplementedQueryServer) Content(context.Context, *QueryContentRequest) (*QueryContentResponse, error)
func (UnimplementedQueryServer) Contents ¶
func (UnimplementedQueryServer) Contents(context.Context, *QueryContentsRequest) (*QueryContentsResponse, error)
func (UnimplementedQueryServer) ContentsByCurator ¶
func (UnimplementedQueryServer) ContentsByCurator(context.Context, *QueryContentsByCuratorRequest) (*QueryContentsByCuratorResponse, error)
type UnsafeMsgServer ¶
type UnsafeMsgServer interface {
// contains filtered or unexported methods
}
UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.
type UnsafeQueryServer ¶
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.