types

package
v0.0.0-...-b43c5a5 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type MsgClient 

type MsgClient interface {
	// SetValue defines a method for setting a key-value pair.
	SetValue(ctx context.Context, in *MsgSetValue, opts ...grpc.CallOption) (*MsgSetValueResponse, 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 MsgServer 

type MsgServer interface {
	// SetValue defines a method for setting a key-value pair.
	SetValue(context.Context, *MsgSetValue) (*MsgSetValueResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetValue 

type MsgSetValue struct {
	FromAddress string `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	Key         string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value       string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

MsgSetValue defines the Msg/SetValue request type for setting a key-value pair.

func (*MsgSetValue) Descriptor 

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

func (*MsgSetValue) GetFromAddress 

func (m *MsgSetValue) GetFromAddress() string

func (*MsgSetValue) GetKey 

func (m *MsgSetValue) GetKey() string

func (*MsgSetValue) GetValue 

func (m *MsgSetValue) GetValue() string

func (*MsgSetValue) Marshal 

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

func (*MsgSetValue) MarshalTo 

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

func (*MsgSetValue) MarshalToSizedBuffer 

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

func (*MsgSetValue) ProtoMessage 

func (*MsgSetValue) ProtoMessage()

func (*MsgSetValue) Reset 

func (m *MsgSetValue) Reset()

func (*MsgSetValue) Size 

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

func (*MsgSetValue) String 

func (m *MsgSetValue) String() string

func (*MsgSetValue) Unmarshal 

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

func (*MsgSetValue) ValidateBasic 

func (m *MsgSetValue) ValidateBasic() error

func (*MsgSetValue) XXX_DiscardUnknown 

func (m *MsgSetValue) XXX_DiscardUnknown()

func (*MsgSetValue) XXX_Marshal 

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

func (*MsgSetValue) XXX_Merge 

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

func (*MsgSetValue) XXX_Size 

func (m *MsgSetValue) XXX_Size() int

func (*MsgSetValue) XXX_Unmarshal 

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

type MsgSetValueResponse 

type MsgSetValueResponse struct {
}

MsgSetValueResponse defines the Msg/SetValue response type.

func (*MsgSetValueResponse) Descriptor 

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

func (*MsgSetValueResponse) Marshal 

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

func (*MsgSetValueResponse) MarshalTo 

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

func (*MsgSetValueResponse) MarshalToSizedBuffer 

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

func (*MsgSetValueResponse) ProtoMessage 

func (*MsgSetValueResponse) ProtoMessage()

func (*MsgSetValueResponse) Reset 

func (m *MsgSetValueResponse) Reset()

func (*MsgSetValueResponse) Size 

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

func (*MsgSetValueResponse) String 

func (m *MsgSetValueResponse) String() string

func (*MsgSetValueResponse) Unmarshal 

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

func (*MsgSetValueResponse) XXX_DiscardUnknown 

func (m *MsgSetValueResponse) XXX_DiscardUnknown()

func (*MsgSetValueResponse) XXX_Marshal 

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

func (*MsgSetValueResponse) XXX_Merge 

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

func (*MsgSetValueResponse) XXX_Size 

func (m *MsgSetValueResponse) XXX_Size() int

func (*MsgSetValueResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Value queries a value stored at a given key.
	Value(ctx context.Context, in *QueryValueRequest, opts ...grpc.CallOption) (*QueryValueResponse, 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 QueryServer 

type QueryServer interface {
	// Value queries a value stored at a given key.
	Value(context.Context, *QueryValueRequest) (*QueryValueResponse, error)
}

QueryServer is the server API for Query service.

type QueryValueRequest 

type QueryValueRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

QueryValueRequest is the request type for the Query/Value method.

func (*QueryValueRequest) Descriptor 

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

func (*QueryValueRequest) GetKey 

func (m *QueryValueRequest) GetKey() string

func (*QueryValueRequest) Marshal 

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

func (*QueryValueRequest) MarshalTo 

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

func (*QueryValueRequest) MarshalToSizedBuffer 

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

func (*QueryValueRequest) ProtoMessage 

func (*QueryValueRequest) ProtoMessage()

func (*QueryValueRequest) Reset 

func (m *QueryValueRequest) Reset()

func (*QueryValueRequest) Size 

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

func (*QueryValueRequest) String 

func (m *QueryValueRequest) String() string

func (*QueryValueRequest) Unmarshal 

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

func (*QueryValueRequest) XXX_DiscardUnknown 

func (m *QueryValueRequest) XXX_DiscardUnknown()

func (*QueryValueRequest) XXX_Marshal 

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

func (*QueryValueRequest) XXX_Merge 

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

func (*QueryValueRequest) XXX_Size 

func (m *QueryValueRequest) XXX_Size() int

func (*QueryValueRequest) XXX_Unmarshal 

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

type QueryValueResponse 

type QueryValueResponse struct {
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

QueryValueResponse is the response type for the Query/Value method.

func (*QueryValueResponse) Descriptor 

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

func (*QueryValueResponse) GetValue 

func (m *QueryValueResponse) GetValue() string

func (*QueryValueResponse) Marshal 

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

func (*QueryValueResponse) MarshalTo 

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

func (*QueryValueResponse) MarshalToSizedBuffer 

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

func (*QueryValueResponse) ProtoMessage 

func (*QueryValueResponse) ProtoMessage()

func (*QueryValueResponse) Reset 

func (m *QueryValueResponse) Reset()

func (*QueryValueResponse) Size 

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

func (*QueryValueResponse) String 

func (m *QueryValueResponse) String() string

func (*QueryValueResponse) Unmarshal 

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

func (*QueryValueResponse) XXX_DiscardUnknown 

func (m *QueryValueResponse) XXX_DiscardUnknown()

func (*QueryValueResponse) XXX_Marshal 

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

func (*QueryValueResponse) XXX_Merge 

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

func (*QueryValueResponse) XXX_Size 

func (m *QueryValueResponse) XXX_Size() int

func (*QueryValueResponse) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SetValue 

func (*UnimplementedMsgServer) SetValue(ctx context.Context, req *MsgSetValue) (*MsgSetValueResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Value 

func (*UnimplementedQueryServer) Value(ctx context.Context, req *QueryValueRequest) (*QueryValueResponse, 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.