geonodev1

package
v0.0.0-...-dd98aab Latest Latest
Warning

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

 Go to latest Published: May 28, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

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

View Source 
const (
	Msg_Create_FullMethodName         = "/chora.geonode.v1.Msg/Create"
	Msg_UpdateCurator_FullMethodName  = "/chora.geonode.v1.Msg/UpdateCurator"
	Msg_UpdateMetadata_FullMethodName = "/chora.geonode.v1.Msg/UpdateMetadata"
)
View Source 
const (
	Query_Node_FullMethodName           = "/chora.geonode.v1.Query/Node"
	Query_Nodes_FullMethodName          = "/chora.geonode.v1.Query/Nodes"
	Query_NodesByCurator_FullMethodName = "/chora.geonode.v1.Query/NodesByCurator"
)

Variables

View Source 
var File_chora_geonode_v1_doc_proto protoreflect.FileDescriptor
View Source 
var File_chora_geonode_v1_events_proto protoreflect.FileDescriptor
View Source 
var File_chora_geonode_v1_msg_proto protoreflect.FileDescriptor
View Source 
var File_chora_geonode_v1_query_proto protoreflect.FileDescriptor
View Source 
var File_chora_geonode_v1_state_proto protoreflect.FileDescriptor
View Source 
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chora.geonode.v1.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Msg_Create_Handler,
		},
		{
			MethodName: "UpdateCurator",
			Handler:    _Msg_UpdateCurator_Handler,
		},
		{
			MethodName: "UpdateMetadata",
			Handler:    _Msg_UpdateMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chora/geonode/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)

View Source 
var Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chora.geonode.v1.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Node",
			Handler:    _Query_Node_Handler,
		},
		{
			MethodName: "Nodes",
			Handler:    _Query_Nodes_Handler,
		},
		{
			MethodName: "NodesByCurator",
			Handler:    _Query_NodesByCurator_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chora/geonode/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 EventCreate 

type EventCreate struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

EventCreate is an event emitted when a node 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 EventUpdateCurator 

type EventUpdateCurator struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

EventUpdateCurator is an event emitted when node 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 node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

EventUpdateMetadata is an event emitted when node 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 a node.
	Create(ctx context.Context, in *MsgCreate, opts ...grpc.CallOption) (*MsgCreateResponse, error)
	// UpdateCurator updates the curator of a node.
	UpdateCurator(ctx context.Context, in *MsgUpdateCurator, opts ...grpc.CallOption) (*MsgUpdateCuratorResponse, error)
	// UpdateMetadata updates the metadata of a node.
	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 node curator.
	Curator string `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"`
	// metadata is the metadata of the node.
	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) Descriptor() ([]byte, []int)

Deprecated: Use MsgCreate.ProtoReflect.Descriptor instead.

func (*MsgCreate) GetCurator 

func (x *MsgCreate) GetCurator() string

func (*MsgCreate) GetMetadata 

func (x *MsgCreate) GetMetadata() string

func (*MsgCreate) ProtoMessage 

func (*MsgCreate) ProtoMessage()

func (*MsgCreate) ProtoReflect 

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

func (*MsgCreate) Reset 

func (x *MsgCreate) Reset()

func (*MsgCreate) String 

func (x *MsgCreate) String() string

type MsgCreateResponse 

type MsgCreateResponse struct {

	// id is the unique identifier of the node.
	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 MsgServer 

type MsgServer interface {
	// Create creates a node.
	Create(context.Context, *MsgCreate) (*MsgCreateResponse, error)
	// UpdateCurator updates the curator of a node.
	UpdateCurator(context.Context, *MsgUpdateCurator) (*MsgUpdateCuratorResponse, error)
	// UpdateMetadata updates the metadata of a node.
	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 node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// curator is the address of the node 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 node.
	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 node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// curator is the address of the node curator.
	Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"`
	// new_metadata is the new metadata of the node.
	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 node.
	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 Node 

type Node struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// curator is the address of the node curator.
	Curator []byte `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"`
	// metadata is the metadata of the node.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Node defines the table and properties of a node.

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetCurator 

func (x *Node) GetCurator() []byte

func (*Node) GetId 

func (x *Node) GetId() uint64

func (*Node) GetMetadata 

func (x *Node) GetMetadata() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeCuratorIndexKey 

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

func (NodeCuratorIndexKey) WithCurator 

func (this NodeCuratorIndexKey) WithCurator(curator []byte) NodeCuratorIndexKey

type NodeIdIndexKey 

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

func (NodeIdIndexKey) WithId 

func (this NodeIdIndexKey) WithId(id uint64) NodeIdIndexKey

type NodeIndexKey 

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

type NodeIterator 

type NodeIterator struct {
	ormtable.Iterator
}

func (NodeIterator) Value 

func (i NodeIterator) Value() (*Node, error)

type NodePrimaryKey 

type NodePrimaryKey = NodeIdIndexKey

primary key starting index..

type NodeTable 

type NodeTable interface {
	Insert(ctx context.Context, node *Node) error
	InsertReturningId(ctx context.Context, node *Node) (uint64, error)
	LastInsertedSequence(ctx context.Context) (uint64, error)
	Update(ctx context.Context, node *Node) error
	Save(ctx context.Context, node *Node) error
	Delete(ctx context.Context, node *Node) 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) (*Node, error)
	List(ctx context.Context, prefixKey NodeIndexKey, opts ...ormlist.Option) (NodeIterator, error)
	ListRange(ctx context.Context, from, to NodeIndexKey, opts ...ormlist.Option) (NodeIterator, error)
	DeleteBy(ctx context.Context, prefixKey NodeIndexKey) error
	DeleteRange(ctx context.Context, from, to NodeIndexKey) error
	// contains filtered or unexported methods
}

func NewNodeTable 

func NewNodeTable(db ormtable.Schema) (NodeTable, error)

type QueryClient 

type QueryClient interface {
	// Node queries a node by id.
	Node(ctx context.Context, in *QueryNodeRequest, opts ...grpc.CallOption) (*QueryNodeResponse, error)
	// Nodes queries all nodes.
	Nodes(ctx context.Context, in *QueryNodesRequest, opts ...grpc.CallOption) (*QueryNodesResponse, error)
	// NodesByCurator queries nodes by curator.
	NodesByCurator(ctx context.Context, in *QueryNodesByCuratorRequest, opts ...grpc.CallOption) (*QueryNodesByCuratorResponse, 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 QueryNodeRequest 

type QueryNodeRequest struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

QueryNodeRequest is the Query/Node request type.

func (*QueryNodeRequest) Descriptor deprecated 

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

Deprecated: Use QueryNodeRequest.ProtoReflect.Descriptor instead.

func (*QueryNodeRequest) GetId 

func (x *QueryNodeRequest) GetId() uint64

func (*QueryNodeRequest) ProtoMessage 

func (*QueryNodeRequest) ProtoMessage()

func (*QueryNodeRequest) ProtoReflect 

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

func (*QueryNodeRequest) Reset 

func (x *QueryNodeRequest) Reset()

func (*QueryNodeRequest) String 

func (x *QueryNodeRequest) String() string

type QueryNodeResponse 

type QueryNodeResponse struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// curator is the address of the node curator.
	Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"`
	// metadata is the metadata of the node.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

QueryNodeResponse is the Query/Node response type.

func (*QueryNodeResponse) Descriptor deprecated 

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

Deprecated: Use QueryNodeResponse.ProtoReflect.Descriptor instead.

func (*QueryNodeResponse) GetCurator 

func (x *QueryNodeResponse) GetCurator() string

func (*QueryNodeResponse) GetId 

func (x *QueryNodeResponse) GetId() uint64

func (*QueryNodeResponse) GetMetadata 

func (x *QueryNodeResponse) GetMetadata() string

func (*QueryNodeResponse) ProtoMessage 

func (*QueryNodeResponse) ProtoMessage()

func (*QueryNodeResponse) ProtoReflect 

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

func (*QueryNodeResponse) Reset 

func (x *QueryNodeResponse) Reset()

func (*QueryNodeResponse) String 

func (x *QueryNodeResponse) String() string

type QueryNodesByCuratorRequest 

type QueryNodesByCuratorRequest struct {

	// curator is the address of the node 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
}

QueryNodesByCuratorRequest is the Query/NodesByCurator request type.

func (*QueryNodesByCuratorRequest) Descriptor deprecated 

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

Deprecated: Use QueryNodesByCuratorRequest.ProtoReflect.Descriptor instead.

func (*QueryNodesByCuratorRequest) GetCurator 

func (x *QueryNodesByCuratorRequest) GetCurator() string

func (*QueryNodesByCuratorRequest) GetPagination 

func (x *QueryNodesByCuratorRequest) GetPagination() *v1beta1.PageRequest

func (*QueryNodesByCuratorRequest) ProtoMessage 

func (*QueryNodesByCuratorRequest) ProtoMessage()

func (*QueryNodesByCuratorRequest) ProtoReflect 

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

func (*QueryNodesByCuratorRequest) Reset 

func (x *QueryNodesByCuratorRequest) Reset()

func (*QueryNodesByCuratorRequest) String 

func (x *QueryNodesByCuratorRequest) String() string

type QueryNodesByCuratorResponse 

type QueryNodesByCuratorResponse struct {

	// curator is the address of the node curator.
	Curator string `protobuf:"bytes,1,opt,name=curator,proto3" json:"curator,omitempty"`
	// nodes is the list of nodes managed by the curator.
	Nodes []*QueryNodesByCuratorResponse_Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,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
}

QueryNodesByCuratorResponse is the Query/NodesByCurator response type.

func (*QueryNodesByCuratorResponse) Descriptor deprecated 

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

Deprecated: Use QueryNodesByCuratorResponse.ProtoReflect.Descriptor instead.

func (*QueryNodesByCuratorResponse) GetCurator 

func (x *QueryNodesByCuratorResponse) GetCurator() string

func (*QueryNodesByCuratorResponse) GetNodes 

func (x *QueryNodesByCuratorResponse) GetNodes() []*QueryNodesByCuratorResponse_Node

func (*QueryNodesByCuratorResponse) GetPagination 

func (x *QueryNodesByCuratorResponse) GetPagination() *v1beta1.PageResponse

func (*QueryNodesByCuratorResponse) ProtoMessage 

func (*QueryNodesByCuratorResponse) ProtoMessage()

func (*QueryNodesByCuratorResponse) ProtoReflect 

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

func (*QueryNodesByCuratorResponse) Reset 

func (x *QueryNodesByCuratorResponse) Reset()

func (*QueryNodesByCuratorResponse) String 

func (x *QueryNodesByCuratorResponse) String() string

type QueryNodesByCuratorResponse_Node 

type QueryNodesByCuratorResponse_Node struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// metadata is the metadata of the node.
	Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Node is the node properties.

func (*QueryNodesByCuratorResponse_Node) Descriptor deprecated 

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

Deprecated: Use QueryNodesByCuratorResponse_Node.ProtoReflect.Descriptor instead.

func (*QueryNodesByCuratorResponse_Node) GetId 

func (x *QueryNodesByCuratorResponse_Node) GetId() uint64

func (*QueryNodesByCuratorResponse_Node) GetMetadata 

func (x *QueryNodesByCuratorResponse_Node) GetMetadata() string

func (*QueryNodesByCuratorResponse_Node) ProtoMessage 

func (*QueryNodesByCuratorResponse_Node) ProtoMessage()

func (*QueryNodesByCuratorResponse_Node) ProtoReflect 

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

func (*QueryNodesByCuratorResponse_Node) Reset 

func (x *QueryNodesByCuratorResponse_Node) Reset()

func (*QueryNodesByCuratorResponse_Node) String 

func (x *QueryNodesByCuratorResponse_Node) String() string

type QueryNodesRequest 

type QueryNodesRequest 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
}

QueryNodesRequest is the Query/Nodes request type.

func (*QueryNodesRequest) Descriptor deprecated 

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

Deprecated: Use QueryNodesRequest.ProtoReflect.Descriptor instead.

func (*QueryNodesRequest) GetPagination 

func (x *QueryNodesRequest) GetPagination() *v1beta1.PageRequest

func (*QueryNodesRequest) ProtoMessage 

func (*QueryNodesRequest) ProtoMessage()

func (*QueryNodesRequest) ProtoReflect 

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

func (*QueryNodesRequest) Reset 

func (x *QueryNodesRequest) Reset()

func (*QueryNodesRequest) String 

func (x *QueryNodesRequest) String() string

type QueryNodesResponse 

type QueryNodesResponse struct {

	// nodes is the list of nodes.
	Nodes []*QueryNodesResponse_Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// pagination is the pagination of the response.
	Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

QueryNodesResponse is the Query/Nodes response type.

func (*QueryNodesResponse) Descriptor deprecated 

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

Deprecated: Use QueryNodesResponse.ProtoReflect.Descriptor instead.

func (*QueryNodesResponse) GetNodes 

func (x *QueryNodesResponse) GetNodes() []*QueryNodesResponse_Node

func (*QueryNodesResponse) GetPagination 

func (x *QueryNodesResponse) GetPagination() *v1beta1.PageResponse

func (*QueryNodesResponse) ProtoMessage 

func (*QueryNodesResponse) ProtoMessage()

func (*QueryNodesResponse) ProtoReflect 

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

func (*QueryNodesResponse) Reset 

func (x *QueryNodesResponse) Reset()

func (*QueryNodesResponse) String 

func (x *QueryNodesResponse) String() string

type QueryNodesResponse_Node 

type QueryNodesResponse_Node struct {

	// id is the unique identifier of the node.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// curator is the address of the node curator.
	Curator string `protobuf:"bytes,2,opt,name=curator,proto3" json:"curator,omitempty"`
	// metadata is the metadata of the node.
	Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Node is the node properties.

func (*QueryNodesResponse_Node) Descriptor deprecated 

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

Deprecated: Use QueryNodesResponse_Node.ProtoReflect.Descriptor instead.

func (*QueryNodesResponse_Node) GetCurator 

func (x *QueryNodesResponse_Node) GetCurator() string

func (*QueryNodesResponse_Node) GetId 

func (x *QueryNodesResponse_Node) GetId() uint64

func (*QueryNodesResponse_Node) GetMetadata 

func (x *QueryNodesResponse_Node) GetMetadata() string

func (*QueryNodesResponse_Node) ProtoMessage 

func (*QueryNodesResponse_Node) ProtoMessage()

func (*QueryNodesResponse_Node) ProtoReflect 

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

func (*QueryNodesResponse_Node) Reset 

func (x *QueryNodesResponse_Node) Reset()

func (*QueryNodesResponse_Node) String 

func (x *QueryNodesResponse_Node) String() string

type QueryServer 

type QueryServer interface {
	// Node queries a node by id.
	Node(context.Context, *QueryNodeRequest) (*QueryNodeResponse, error)
	// Nodes queries all nodes.
	Nodes(context.Context, *QueryNodesRequest) (*QueryNodesResponse, error)
	// NodesByCurator queries nodes by curator.
	NodesByCurator(context.Context, *QueryNodesByCuratorRequest) (*QueryNodesByCuratorResponse, 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 {
	NodeTable() NodeTable
	// 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) 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) Node 

func (UnimplementedQueryServer) Node(context.Context, *QueryNodeRequest) (*QueryNodeResponse, error)

func (UnimplementedQueryServer) Nodes 

func (UnimplementedQueryServer) Nodes(context.Context, *QueryNodesRequest) (*QueryNodesResponse, error)

func (UnimplementedQueryServer) NodesByCurator 

func (UnimplementedQueryServer) NodesByCurator(context.Context, *QueryNodesByCuratorRequest) (*QueryNodesByCuratorResponse, 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.

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.