types

package
v1.0.0-develop.4 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2022 License: Apache-2.0 Imports: 25 Imported by: 3

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "resource"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName
)
View Source 
const (
	ResourceHeaderKey = "resource-header:"
	ResourceDataKey   = "resource-data:"
	ResourceCountKey  = "resource-count:"
)
View Source 
const (
	QueryGetResource            = "get-resource"
	QueryGetCollectionResources = "get-collection-resources"
	QueryGetAllResourceVersions = "get-all-resource-versions"
)

Variables

View Source 
var (
	ErrBadRequest      = sdkerrors.Register(ModuleName, 2000, "bad request")
	ErrResourceExists  = sdkerrors.Register(ModuleName, 2200, "Resoure exists")
	ErrBasicValidation = sdkerrors.Register(ModuleName, 2205, "basic validation failed")
	ErrInternal        = sdkerrors.Register(ModuleName, 2500, "internal error")
)

x/resource module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthResource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResource = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func KeyPrefix 

func KeyPrefix(p string) []byte

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidMsgCreateResourcePayload 

func ValidMsgCreateResourcePayload() *cheqdtypes.CustomErrorRule

Types

type GenesisState 

type GenesisState struct {
	ResourceList []*Resource `protobuf:"bytes,1,rep,name=resourceList,proto3" json:"resourceList,omitempty"`
}

GenesisState defines the cheqd module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetResourceList 

func (m *GenesisState) GetResourceList() []*Resource

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type MsgClient 

type MsgClient interface {
	CreateResource(ctx context.Context, in *MsgCreateResource, opts ...grpc.CallOption) (*MsgCreateResourceResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateResource 

type MsgCreateResource struct {
	Payload    *MsgCreateResourcePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Signatures []*types.SignInfo         `protobuf:"bytes,2,rep,name=signatures,proto3" json:"signatures,omitempty"`
}

this line is used by starport scaffolding # proto/tx/message

func NewMsgCreateResource 

func NewMsgCreateResource(payload *MsgCreateResourcePayload, signatures []*cheqd_types.SignInfo) *MsgCreateResource

func (*MsgCreateResource) Descriptor 

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

func (*MsgCreateResource) GetPayload 

func (m *MsgCreateResource) GetPayload() *MsgCreateResourcePayload

func (*MsgCreateResource) GetSignBytes 

func (msg *MsgCreateResource) GetSignBytes() []byte

func (*MsgCreateResource) GetSignatures 

func (m *MsgCreateResource) GetSignatures() []*types.SignInfo

func (*MsgCreateResource) GetSigners 

func (msg *MsgCreateResource) GetSigners() []sdk.AccAddress

func (*MsgCreateResource) Marshal 

func (m *MsgCreateResource) Marshal() (dAtA []byte, err error)

func (*MsgCreateResource) MarshalTo 

func (m *MsgCreateResource) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateResource) MarshalToSizedBuffer 

func (m *MsgCreateResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateResource) ProtoMessage 

func (*MsgCreateResource) ProtoMessage()

func (*MsgCreateResource) Reset 

func (m *MsgCreateResource) Reset()

func (*MsgCreateResource) Route 

func (msg *MsgCreateResource) Route() string

func (*MsgCreateResource) Size 

func (m *MsgCreateResource) Size() (n int)

func (*MsgCreateResource) String 

func (m *MsgCreateResource) String() string

func (*MsgCreateResource) Type 

func (msg *MsgCreateResource) Type() string

func (*MsgCreateResource) Unmarshal 

func (m *MsgCreateResource) Unmarshal(dAtA []byte) error

func (MsgCreateResource) Validate 

func (msg MsgCreateResource) Validate(allowedNamespaces []string) error

func (*MsgCreateResource) ValidateBasic 

func (msg *MsgCreateResource) ValidateBasic() error

func (*MsgCreateResource) XXX_DiscardUnknown 

func (m *MsgCreateResource) XXX_DiscardUnknown()

func (*MsgCreateResource) XXX_Marshal 

func (m *MsgCreateResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateResource) XXX_Merge 

func (m *MsgCreateResource) XXX_Merge(src proto.Message)

func (*MsgCreateResource) XXX_Size 

func (m *MsgCreateResource) XXX_Size() int

func (*MsgCreateResource) XXX_Unmarshal 

func (m *MsgCreateResource) XXX_Unmarshal(b []byte) error

type MsgCreateResourcePayload 

type MsgCreateResourcePayload struct {
	CollectionId string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Id           string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name         string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ResourceType string `protobuf:"bytes,4,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Data         []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
}

func (*MsgCreateResourcePayload) Descriptor 

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

func (*MsgCreateResourcePayload) GetCollectionId 

func (m *MsgCreateResourcePayload) GetCollectionId() string

func (*MsgCreateResourcePayload) GetData 

func (m *MsgCreateResourcePayload) GetData() []byte

func (*MsgCreateResourcePayload) GetId 

func (m *MsgCreateResourcePayload) GetId() string

func (*MsgCreateResourcePayload) GetName 

func (m *MsgCreateResourcePayload) GetName() string

func (*MsgCreateResourcePayload) GetResourceType 

func (m *MsgCreateResourcePayload) GetResourceType() string

func (*MsgCreateResourcePayload) GetSignBytes 

func (msg *MsgCreateResourcePayload) GetSignBytes() []byte

func (*MsgCreateResourcePayload) Marshal 

func (m *MsgCreateResourcePayload) Marshal() (dAtA []byte, err error)

func (*MsgCreateResourcePayload) MarshalTo 

func (m *MsgCreateResourcePayload) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateResourcePayload) MarshalToSizedBuffer 

func (m *MsgCreateResourcePayload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateResourcePayload) ProtoMessage 

func (*MsgCreateResourcePayload) ProtoMessage()

func (*MsgCreateResourcePayload) Reset 

func (m *MsgCreateResourcePayload) Reset()

func (*MsgCreateResourcePayload) Size 

func (m *MsgCreateResourcePayload) Size() (n int)

func (*MsgCreateResourcePayload) String 

func (m *MsgCreateResourcePayload) String() string

func (*MsgCreateResourcePayload) ToResource 

func (msg *MsgCreateResourcePayload) ToResource() Resource

func (*MsgCreateResourcePayload) Unmarshal 

func (m *MsgCreateResourcePayload) Unmarshal(dAtA []byte) error

func (MsgCreateResourcePayload) Validate 

func (msg MsgCreateResourcePayload) Validate() error

func (*MsgCreateResourcePayload) XXX_DiscardUnknown 

func (m *MsgCreateResourcePayload) XXX_DiscardUnknown()

func (*MsgCreateResourcePayload) XXX_Marshal 

func (m *MsgCreateResourcePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateResourcePayload) XXX_Merge 

func (m *MsgCreateResourcePayload) XXX_Merge(src proto.Message)

func (*MsgCreateResourcePayload) XXX_Size 

func (m *MsgCreateResourcePayload) XXX_Size() int

func (*MsgCreateResourcePayload) XXX_Unmarshal 

func (m *MsgCreateResourcePayload) XXX_Unmarshal(b []byte) error

type MsgCreateResourceResponse 

type MsgCreateResourceResponse struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
}

func (*MsgCreateResourceResponse) Descriptor 

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

func (*MsgCreateResourceResponse) GetResource 

func (m *MsgCreateResourceResponse) GetResource() *Resource

func (*MsgCreateResourceResponse) Marshal 

func (m *MsgCreateResourceResponse) Marshal() (dAtA []byte, err error)

func (*MsgCreateResourceResponse) MarshalTo 

func (m *MsgCreateResourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateResourceResponse) MarshalToSizedBuffer 

func (m *MsgCreateResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateResourceResponse) ProtoMessage 

func (*MsgCreateResourceResponse) ProtoMessage()

func (*MsgCreateResourceResponse) Reset 

func (m *MsgCreateResourceResponse) Reset()

func (*MsgCreateResourceResponse) Size 

func (m *MsgCreateResourceResponse) Size() (n int)

func (*MsgCreateResourceResponse) String 

func (m *MsgCreateResourceResponse) String() string

func (*MsgCreateResourceResponse) Unmarshal 

func (m *MsgCreateResourceResponse) Unmarshal(dAtA []byte) error

func (*MsgCreateResourceResponse) XXX_DiscardUnknown 

func (m *MsgCreateResourceResponse) XXX_DiscardUnknown()

func (*MsgCreateResourceResponse) XXX_Marshal 

func (m *MsgCreateResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateResourceResponse) XXX_Merge 

func (m *MsgCreateResourceResponse) XXX_Merge(src proto.Message)

func (*MsgCreateResourceResponse) XXX_Size 

func (m *MsgCreateResourceResponse) XXX_Size() int

func (*MsgCreateResourceResponse) XXX_Unmarshal 

func (m *MsgCreateResourceResponse) XXX_Unmarshal(b []byte) error

type MsgServer 

type MsgServer interface {
	CreateResource(context.Context, *MsgCreateResource) (*MsgCreateResourceResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient 

type QueryClient interface {
	Resource(ctx context.Context, in *QueryGetResourceRequest, opts ...grpc.CallOption) (*QueryGetResourceResponse, error)
	CollectionResources(ctx context.Context, in *QueryGetCollectionResourcesRequest, opts ...grpc.CallOption) (*QueryGetCollectionResourcesResponse, error)
	AllResourceVersions(ctx context.Context, in *QueryGetAllResourceVersionsRequest, opts ...grpc.CallOption) (*QueryGetAllResourceVersionsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryGetAllResourceVersionsRequest 

type QueryGetAllResourceVersionsRequest struct {
	CollectionId string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ResourceType string `protobuf:"bytes,3,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
}

func (*QueryGetAllResourceVersionsRequest) Descriptor 

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

func (*QueryGetAllResourceVersionsRequest) GetCollectionId 

func (m *QueryGetAllResourceVersionsRequest) GetCollectionId() string

func (*QueryGetAllResourceVersionsRequest) GetName 

func (m *QueryGetAllResourceVersionsRequest) GetName() string

func (*QueryGetAllResourceVersionsRequest) GetResourceType 

func (m *QueryGetAllResourceVersionsRequest) GetResourceType() string

func (*QueryGetAllResourceVersionsRequest) Marshal 

func (m *QueryGetAllResourceVersionsRequest) Marshal() (dAtA []byte, err error)

func (*QueryGetAllResourceVersionsRequest) MarshalTo 

func (m *QueryGetAllResourceVersionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetAllResourceVersionsRequest) MarshalToSizedBuffer 

func (m *QueryGetAllResourceVersionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetAllResourceVersionsRequest) ProtoMessage 

func (*QueryGetAllResourceVersionsRequest) ProtoMessage()

func (*QueryGetAllResourceVersionsRequest) Reset 

func (m *QueryGetAllResourceVersionsRequest) Reset()

func (*QueryGetAllResourceVersionsRequest) Size 

func (m *QueryGetAllResourceVersionsRequest) Size() (n int)

func (*QueryGetAllResourceVersionsRequest) String 

func (m *QueryGetAllResourceVersionsRequest) String() string

func (*QueryGetAllResourceVersionsRequest) Unmarshal 

func (m *QueryGetAllResourceVersionsRequest) Unmarshal(dAtA []byte) error

func (*QueryGetAllResourceVersionsRequest) XXX_DiscardUnknown 

func (m *QueryGetAllResourceVersionsRequest) XXX_DiscardUnknown()

func (*QueryGetAllResourceVersionsRequest) XXX_Marshal 

func (m *QueryGetAllResourceVersionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetAllResourceVersionsRequest) XXX_Merge 

func (m *QueryGetAllResourceVersionsRequest) XXX_Merge(src proto.Message)

func (*QueryGetAllResourceVersionsRequest) XXX_Size 

func (m *QueryGetAllResourceVersionsRequest) XXX_Size() int

func (*QueryGetAllResourceVersionsRequest) XXX_Unmarshal 

func (m *QueryGetAllResourceVersionsRequest) XXX_Unmarshal(b []byte) error

type QueryGetAllResourceVersionsResponse 

type QueryGetAllResourceVersionsResponse struct {
	Resources []*ResourceHeader `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
}

func (*QueryGetAllResourceVersionsResponse) Descriptor 

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

func (*QueryGetAllResourceVersionsResponse) GetResources 

func (m *QueryGetAllResourceVersionsResponse) GetResources() []*ResourceHeader

func (*QueryGetAllResourceVersionsResponse) Marshal 

func (m *QueryGetAllResourceVersionsResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetAllResourceVersionsResponse) MarshalTo 

func (m *QueryGetAllResourceVersionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetAllResourceVersionsResponse) MarshalToSizedBuffer 

func (m *QueryGetAllResourceVersionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetAllResourceVersionsResponse) ProtoMessage 

func (*QueryGetAllResourceVersionsResponse) ProtoMessage()

func (*QueryGetAllResourceVersionsResponse) Reset 

func (m *QueryGetAllResourceVersionsResponse) Reset()

func (*QueryGetAllResourceVersionsResponse) Size 

func (m *QueryGetAllResourceVersionsResponse) Size() (n int)

func (*QueryGetAllResourceVersionsResponse) String 

func (m *QueryGetAllResourceVersionsResponse) String() string

func (*QueryGetAllResourceVersionsResponse) Unmarshal 

func (m *QueryGetAllResourceVersionsResponse) Unmarshal(dAtA []byte) error

func (*QueryGetAllResourceVersionsResponse) XXX_DiscardUnknown 

func (m *QueryGetAllResourceVersionsResponse) XXX_DiscardUnknown()

func (*QueryGetAllResourceVersionsResponse) XXX_Marshal 

func (m *QueryGetAllResourceVersionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetAllResourceVersionsResponse) XXX_Merge 

func (m *QueryGetAllResourceVersionsResponse) XXX_Merge(src proto.Message)

func (*QueryGetAllResourceVersionsResponse) XXX_Size 

func (m *QueryGetAllResourceVersionsResponse) XXX_Size() int

func (*QueryGetAllResourceVersionsResponse) XXX_Unmarshal 

func (m *QueryGetAllResourceVersionsResponse) XXX_Unmarshal(b []byte) error

type QueryGetCollectionResourcesRequest 

type QueryGetCollectionResourcesRequest struct {
	CollectionId string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
}

func (*QueryGetCollectionResourcesRequest) Descriptor 

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

func (*QueryGetCollectionResourcesRequest) GetCollectionId 

func (m *QueryGetCollectionResourcesRequest) GetCollectionId() string

func (*QueryGetCollectionResourcesRequest) Marshal 

func (m *QueryGetCollectionResourcesRequest) Marshal() (dAtA []byte, err error)

func (*QueryGetCollectionResourcesRequest) MarshalTo 

func (m *QueryGetCollectionResourcesRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetCollectionResourcesRequest) MarshalToSizedBuffer 

func (m *QueryGetCollectionResourcesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetCollectionResourcesRequest) ProtoMessage 

func (*QueryGetCollectionResourcesRequest) ProtoMessage()

func (*QueryGetCollectionResourcesRequest) Reset 

func (m *QueryGetCollectionResourcesRequest) Reset()

func (*QueryGetCollectionResourcesRequest) Size 

func (m *QueryGetCollectionResourcesRequest) Size() (n int)

func (*QueryGetCollectionResourcesRequest) String 

func (m *QueryGetCollectionResourcesRequest) String() string

func (*QueryGetCollectionResourcesRequest) Unmarshal 

func (m *QueryGetCollectionResourcesRequest) Unmarshal(dAtA []byte) error

func (*QueryGetCollectionResourcesRequest) XXX_DiscardUnknown 

func (m *QueryGetCollectionResourcesRequest) XXX_DiscardUnknown()

func (*QueryGetCollectionResourcesRequest) XXX_Marshal 

func (m *QueryGetCollectionResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetCollectionResourcesRequest) XXX_Merge 

func (m *QueryGetCollectionResourcesRequest) XXX_Merge(src proto.Message)

func (*QueryGetCollectionResourcesRequest) XXX_Size 

func (m *QueryGetCollectionResourcesRequest) XXX_Size() int

func (*QueryGetCollectionResourcesRequest) XXX_Unmarshal 

func (m *QueryGetCollectionResourcesRequest) XXX_Unmarshal(b []byte) error

type QueryGetCollectionResourcesResponse 

type QueryGetCollectionResourcesResponse struct {
	Resources []*ResourceHeader `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
}

func (*QueryGetCollectionResourcesResponse) Descriptor 

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

func (*QueryGetCollectionResourcesResponse) GetResources 

func (m *QueryGetCollectionResourcesResponse) GetResources() []*ResourceHeader

func (*QueryGetCollectionResourcesResponse) Marshal 

func (m *QueryGetCollectionResourcesResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetCollectionResourcesResponse) MarshalTo 

func (m *QueryGetCollectionResourcesResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetCollectionResourcesResponse) MarshalToSizedBuffer 

func (m *QueryGetCollectionResourcesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetCollectionResourcesResponse) ProtoMessage 

func (*QueryGetCollectionResourcesResponse) ProtoMessage()

func (*QueryGetCollectionResourcesResponse) Reset 

func (m *QueryGetCollectionResourcesResponse) Reset()

func (*QueryGetCollectionResourcesResponse) Size 

func (m *QueryGetCollectionResourcesResponse) Size() (n int)

func (*QueryGetCollectionResourcesResponse) String 

func (m *QueryGetCollectionResourcesResponse) String() string

func (*QueryGetCollectionResourcesResponse) Unmarshal 

func (m *QueryGetCollectionResourcesResponse) Unmarshal(dAtA []byte) error

func (*QueryGetCollectionResourcesResponse) XXX_DiscardUnknown 

func (m *QueryGetCollectionResourcesResponse) XXX_DiscardUnknown()

func (*QueryGetCollectionResourcesResponse) XXX_Marshal 

func (m *QueryGetCollectionResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetCollectionResourcesResponse) XXX_Merge 

func (m *QueryGetCollectionResourcesResponse) XXX_Merge(src proto.Message)

func (*QueryGetCollectionResourcesResponse) XXX_Size 

func (m *QueryGetCollectionResourcesResponse) XXX_Size() int

func (*QueryGetCollectionResourcesResponse) XXX_Unmarshal 

func (m *QueryGetCollectionResourcesResponse) XXX_Unmarshal(b []byte) error

type QueryGetResourceRequest 

type QueryGetResourceRequest struct {
	CollectionId string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Id           string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*QueryGetResourceRequest) Descriptor 

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

func (*QueryGetResourceRequest) GetCollectionId 

func (m *QueryGetResourceRequest) GetCollectionId() string

func (*QueryGetResourceRequest) GetId 

func (m *QueryGetResourceRequest) GetId() string

func (*QueryGetResourceRequest) Marshal 

func (m *QueryGetResourceRequest) Marshal() (dAtA []byte, err error)

func (*QueryGetResourceRequest) MarshalTo 

func (m *QueryGetResourceRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetResourceRequest) MarshalToSizedBuffer 

func (m *QueryGetResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetResourceRequest) ProtoMessage 

func (*QueryGetResourceRequest) ProtoMessage()

func (*QueryGetResourceRequest) Reset 

func (m *QueryGetResourceRequest) Reset()

func (*QueryGetResourceRequest) Size 

func (m *QueryGetResourceRequest) Size() (n int)

func (*QueryGetResourceRequest) String 

func (m *QueryGetResourceRequest) String() string

func (*QueryGetResourceRequest) Unmarshal 

func (m *QueryGetResourceRequest) Unmarshal(dAtA []byte) error

func (*QueryGetResourceRequest) XXX_DiscardUnknown 

func (m *QueryGetResourceRequest) XXX_DiscardUnknown()

func (*QueryGetResourceRequest) XXX_Marshal 

func (m *QueryGetResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetResourceRequest) XXX_Merge 

func (m *QueryGetResourceRequest) XXX_Merge(src proto.Message)

func (*QueryGetResourceRequest) XXX_Size 

func (m *QueryGetResourceRequest) XXX_Size() int

func (*QueryGetResourceRequest) XXX_Unmarshal 

func (m *QueryGetResourceRequest) XXX_Unmarshal(b []byte) error

type QueryGetResourceResponse 

type QueryGetResourceResponse struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
}

func (*QueryGetResourceResponse) Descriptor 

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

func (*QueryGetResourceResponse) GetResource 

func (m *QueryGetResourceResponse) GetResource() *Resource

func (*QueryGetResourceResponse) Marshal 

func (m *QueryGetResourceResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetResourceResponse) MarshalTo 

func (m *QueryGetResourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetResourceResponse) MarshalToSizedBuffer 

func (m *QueryGetResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetResourceResponse) ProtoMessage 

func (*QueryGetResourceResponse) ProtoMessage()

func (*QueryGetResourceResponse) Reset 

func (m *QueryGetResourceResponse) Reset()

func (*QueryGetResourceResponse) Size 

func (m *QueryGetResourceResponse) Size() (n int)

func (*QueryGetResourceResponse) String 

func (m *QueryGetResourceResponse) String() string

func (*QueryGetResourceResponse) Unmarshal 

func (m *QueryGetResourceResponse) Unmarshal(dAtA []byte) error

func (*QueryGetResourceResponse) XXX_DiscardUnknown 

func (m *QueryGetResourceResponse) XXX_DiscardUnknown()

func (*QueryGetResourceResponse) XXX_Marshal 

func (m *QueryGetResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetResourceResponse) XXX_Merge 

func (m *QueryGetResourceResponse) XXX_Merge(src proto.Message)

func (*QueryGetResourceResponse) XXX_Size 

func (m *QueryGetResourceResponse) XXX_Size() int

func (*QueryGetResourceResponse) XXX_Unmarshal 

func (m *QueryGetResourceResponse) XXX_Unmarshal(b []byte) error

type QueryServer 

type QueryServer interface {
	Resource(context.Context, *QueryGetResourceRequest) (*QueryGetResourceResponse, error)
	CollectionResources(context.Context, *QueryGetCollectionResourcesRequest) (*QueryGetCollectionResourcesResponse, error)
	AllResourceVersions(context.Context, *QueryGetAllResourceVersionsRequest) (*QueryGetAllResourceVersionsResponse, error)
}

QueryServer is the server API for Query service.

type Resource 

type Resource struct {
	Header *ResourceHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Data   []byte          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Resource) Descriptor 

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

func (*Resource) GetData 

func (m *Resource) GetData() []byte

func (*Resource) GetHeader 

func (m *Resource) GetHeader() *ResourceHeader

func (*Resource) Marshal 

func (m *Resource) Marshal() (dAtA []byte, err error)

func (*Resource) MarshalTo 

func (m *Resource) MarshalTo(dAtA []byte) (int, error)

func (*Resource) MarshalToSizedBuffer 

func (m *Resource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) Size 

func (m *Resource) Size() (n int)

func (*Resource) String 

func (m *Resource) String() string

func (*Resource) Unmarshal 

func (m *Resource) Unmarshal(dAtA []byte) error

func (*Resource) XXX_DiscardUnknown 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal 

func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resource) XXX_Merge 

func (m *Resource) XXX_Merge(src proto.Message)

func (*Resource) XXX_Size 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal 

func (m *Resource) XXX_Unmarshal(b []byte) error

type ResourceHeader 

type ResourceHeader struct {
	CollectionId      string `protobuf:"bytes,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Id                string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name              string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ResourceType      string `protobuf:"bytes,4,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	MediaType         string `protobuf:"bytes,5,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	Created           string `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	Checksum          []byte `protobuf:"bytes,7,opt,name=checksum,proto3" json:"checksum,omitempty"`
	PreviousVersionId string `protobuf:"bytes,8,opt,name=previous_version_id,json=previousVersionId,proto3" json:"previous_version_id,omitempty"`
	NextVersionId     string `protobuf:"bytes,9,opt,name=next_version_id,json=nextVersionId,proto3" json:"next_version_id,omitempty"`
}

func (*ResourceHeader) Descriptor 

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

func (*ResourceHeader) GetChecksum 

func (m *ResourceHeader) GetChecksum() []byte

func (*ResourceHeader) GetCollectionId 

func (m *ResourceHeader) GetCollectionId() string

func (*ResourceHeader) GetCreated 

func (m *ResourceHeader) GetCreated() string

func (*ResourceHeader) GetId 

func (m *ResourceHeader) GetId() string

func (*ResourceHeader) GetMediaType 

func (m *ResourceHeader) GetMediaType() string

func (*ResourceHeader) GetName 

func (m *ResourceHeader) GetName() string

func (*ResourceHeader) GetNextVersionId 

func (m *ResourceHeader) GetNextVersionId() string

func (*ResourceHeader) GetPreviousVersionId 

func (m *ResourceHeader) GetPreviousVersionId() string

func (*ResourceHeader) GetResourceType 

func (m *ResourceHeader) GetResourceType() string

func (*ResourceHeader) Marshal 

func (m *ResourceHeader) Marshal() (dAtA []byte, err error)

func (*ResourceHeader) MarshalTo 

func (m *ResourceHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResourceHeader) MarshalToSizedBuffer 

func (m *ResourceHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceHeader) ProtoMessage 

func (*ResourceHeader) ProtoMessage()

func (*ResourceHeader) Reset 

func (m *ResourceHeader) Reset()

func (*ResourceHeader) Size 

func (m *ResourceHeader) Size() (n int)

func (*ResourceHeader) String 

func (m *ResourceHeader) String() string

func (*ResourceHeader) Unmarshal 

func (m *ResourceHeader) Unmarshal(dAtA []byte) error

func (*ResourceHeader) XXX_DiscardUnknown 

func (m *ResourceHeader) XXX_DiscardUnknown()

func (*ResourceHeader) XXX_Marshal 

func (m *ResourceHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceHeader) XXX_Merge 

func (m *ResourceHeader) XXX_Merge(src proto.Message)

func (*ResourceHeader) XXX_Size 

func (m *ResourceHeader) XXX_Size() int

func (*ResourceHeader) XXX_Unmarshal 

func (m *ResourceHeader) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateResource 

func (*UnimplementedMsgServer) CreateResource(ctx context.Context, req *MsgCreateResource) (*MsgCreateResourceResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllResourceVersions 

func (*UnimplementedQueryServer) AllResourceVersions(ctx context.Context, req *QueryGetAllResourceVersionsRequest) (*QueryGetAllResourceVersionsResponse, error)

func (*UnimplementedQueryServer) CollectionResources 

func (*UnimplementedQueryServer) CollectionResources(ctx context.Context, req *QueryGetCollectionResourcesRequest) (*QueryGetCollectionResourcesResponse, error)

func (*UnimplementedQueryServer) Resource 

func (*UnimplementedQueryServer) Resource(ctx context.Context, req *QueryGetResourceRequest) (*QueryGetResourceResponse, error)

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.