testutil

package
v0.48.1 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessages        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCounter2Server 

func RegisterCounter2Server(s grpc1.Server, srv Counter2Server)

func RegisterCounterServer 

func RegisterCounterServer(s grpc1.Server, srv CounterServer)

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterKeyValueServer 

func RegisterKeyValueServer(s grpc1.Server, srv KeyValueServer)

Types

type Counter2Client 

type Counter2Client interface {
	IncrementCounter(ctx context.Context, in *MsgCounter2, opts ...grpc.CallOption) (*MsgCreateCounterResponse, error)
}

Counter2Client is the client API for Counter2 service.

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

func NewCounter2Client 

func NewCounter2Client(cc grpc1.ClientConn) Counter2Client

type Counter2Server 

type Counter2Server interface {
	IncrementCounter(context.Context, *MsgCounter2) (*MsgCreateCounterResponse, error)
}

Counter2Server is the server API for Counter2 service.

type CounterClient 

type CounterClient interface {
	IncrementCounter(ctx context.Context, in *MsgCounter, opts ...grpc.CallOption) (*MsgCreateCounterResponse, error)
}

CounterClient is the client API for Counter service.

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

func NewCounterClient 

func NewCounterClient(cc grpc1.ClientConn) CounterClient

type CounterServer 

type CounterServer interface {
	IncrementCounter(context.Context, *MsgCounter) (*MsgCreateCounterResponse, error)
}

CounterServer is the server API for Counter service.

type KeyValueClient 

type KeyValueClient interface {
	Set(ctx context.Context, in *MsgKeyValue, opts ...grpc.CallOption) (*MsgCreateKeyValueResponse, error)
}

KeyValueClient is the client API for KeyValue service.

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

func NewKeyValueClient 

func NewKeyValueClient(cc grpc1.ClientConn) KeyValueClient

type KeyValueServer 

type KeyValueServer interface {
	Set(context.Context, *MsgKeyValue) (*MsgCreateKeyValueResponse, error)
}

KeyValueServer is the server API for KeyValue service.

type MsgCounter 

type MsgCounter struct {
	Counter       int64 `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	FailOnHandler bool  `protobuf:"varint,2,opt,name=fail_on_handler,json=failOnHandler,proto3" json:"fail_on_handler,omitempty"`
}

func (*MsgCounter) Descriptor 

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

func (*MsgCounter) GetCounter 

func (m *MsgCounter) GetCounter() int64

func (*MsgCounter) GetFailOnHandler 

func (m *MsgCounter) GetFailOnHandler() bool

func (*MsgCounter) GetSigners 

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

func (*MsgCounter) Marshal 

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

func (*MsgCounter) MarshalTo 

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

func (*MsgCounter) MarshalToSizedBuffer 

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

func (*MsgCounter) ProtoMessage 

func (*MsgCounter) ProtoMessage()

func (*MsgCounter) Reset 

func (m *MsgCounter) Reset()

func (*MsgCounter) Size 

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

func (*MsgCounter) String 

func (m *MsgCounter) String() string

func (*MsgCounter) Unmarshal 

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

func (*MsgCounter) ValidateBasic 

func (msg *MsgCounter) ValidateBasic() error

func (*MsgCounter) XXX_DiscardUnknown 

func (m *MsgCounter) XXX_DiscardUnknown()

func (*MsgCounter) XXX_Marshal 

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

func (*MsgCounter) XXX_Merge 

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

func (*MsgCounter) XXX_Size 

func (m *MsgCounter) XXX_Size() int

func (*MsgCounter) XXX_Unmarshal 

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

type MsgCounter2 

type MsgCounter2 struct {
	Counter       int64 `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	FailOnHandler bool  `protobuf:"varint,2,opt,name=fail_on_handler,json=failOnHandler,proto3" json:"fail_on_handler,omitempty"`
}

func (*MsgCounter2) Descriptor 

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

func (*MsgCounter2) GetCounter 

func (m *MsgCounter2) GetCounter() int64

func (*MsgCounter2) GetFailOnHandler 

func (m *MsgCounter2) GetFailOnHandler() bool

func (*MsgCounter2) GetSigners 

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

func (*MsgCounter2) Marshal 

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

func (*MsgCounter2) MarshalTo 

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

func (*MsgCounter2) MarshalToSizedBuffer 

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

func (*MsgCounter2) ProtoMessage 

func (*MsgCounter2) ProtoMessage()

func (*MsgCounter2) Reset 

func (m *MsgCounter2) Reset()

func (*MsgCounter2) Size 

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

func (*MsgCounter2) String 

func (m *MsgCounter2) String() string

func (*MsgCounter2) Unmarshal 

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

func (*MsgCounter2) ValidateBasic 

func (msg *MsgCounter2) ValidateBasic() error

func (*MsgCounter2) XXX_DiscardUnknown 

func (m *MsgCounter2) XXX_DiscardUnknown()

func (*MsgCounter2) XXX_Marshal 

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

func (*MsgCounter2) XXX_Merge 

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

func (*MsgCounter2) XXX_Size 

func (m *MsgCounter2) XXX_Size() int

func (*MsgCounter2) XXX_Unmarshal 

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

type MsgCreateCounterResponse 

type MsgCreateCounterResponse struct {
}

func (*MsgCreateCounterResponse) Descriptor 

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

func (*MsgCreateCounterResponse) Marshal 

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

func (*MsgCreateCounterResponse) MarshalTo 

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

func (*MsgCreateCounterResponse) MarshalToSizedBuffer 

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

func (*MsgCreateCounterResponse) ProtoMessage 

func (*MsgCreateCounterResponse) ProtoMessage()

func (*MsgCreateCounterResponse) Reset 

func (m *MsgCreateCounterResponse) Reset()

func (*MsgCreateCounterResponse) Size 

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

func (*MsgCreateCounterResponse) String 

func (m *MsgCreateCounterResponse) String() string

func (*MsgCreateCounterResponse) Unmarshal 

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

func (*MsgCreateCounterResponse) XXX_DiscardUnknown 

func (m *MsgCreateCounterResponse) XXX_DiscardUnknown()

func (*MsgCreateCounterResponse) XXX_Marshal 

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

func (*MsgCreateCounterResponse) XXX_Merge 

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

func (*MsgCreateCounterResponse) XXX_Size 

func (m *MsgCreateCounterResponse) XXX_Size() int

func (*MsgCreateCounterResponse) XXX_Unmarshal 

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

type MsgCreateKeyValueResponse 

type MsgCreateKeyValueResponse struct {
}

func (*MsgCreateKeyValueResponse) Descriptor 

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

func (*MsgCreateKeyValueResponse) Marshal 

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

func (*MsgCreateKeyValueResponse) MarshalTo 

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

func (*MsgCreateKeyValueResponse) MarshalToSizedBuffer 

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

func (*MsgCreateKeyValueResponse) ProtoMessage 

func (*MsgCreateKeyValueResponse) ProtoMessage()

func (*MsgCreateKeyValueResponse) Reset 

func (m *MsgCreateKeyValueResponse) Reset()

func (*MsgCreateKeyValueResponse) Size 

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

func (*MsgCreateKeyValueResponse) String 

func (m *MsgCreateKeyValueResponse) String() string

func (*MsgCreateKeyValueResponse) Unmarshal 

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

func (*MsgCreateKeyValueResponse) XXX_DiscardUnknown 

func (m *MsgCreateKeyValueResponse) XXX_DiscardUnknown()

func (*MsgCreateKeyValueResponse) XXX_Marshal 

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

func (*MsgCreateKeyValueResponse) XXX_Merge 

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

func (*MsgCreateKeyValueResponse) XXX_Size 

func (m *MsgCreateKeyValueResponse) XXX_Size() int

func (*MsgCreateKeyValueResponse) XXX_Unmarshal 

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

type MsgKeyValue 

type MsgKeyValue struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Signer string `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"`
}

func (*MsgKeyValue) Descriptor 

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

func (*MsgKeyValue) GetKey 

func (m *MsgKeyValue) GetKey() []byte

func (*MsgKeyValue) GetSigner 

func (m *MsgKeyValue) GetSigner() string

func (*MsgKeyValue) GetSigners 

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

func (*MsgKeyValue) GetValue 

func (m *MsgKeyValue) GetValue() []byte

func (*MsgKeyValue) Marshal 

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

func (*MsgKeyValue) MarshalTo 

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

func (*MsgKeyValue) MarshalToSizedBuffer 

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

func (*MsgKeyValue) ProtoMessage 

func (*MsgKeyValue) ProtoMessage()

func (*MsgKeyValue) Reset 

func (m *MsgKeyValue) Reset()

func (*MsgKeyValue) Size 

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

func (*MsgKeyValue) String 

func (m *MsgKeyValue) String() string

func (*MsgKeyValue) Unmarshal 

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

func (*MsgKeyValue) ValidateBasic 

func (msg *MsgKeyValue) ValidateBasic() error

func (*MsgKeyValue) XXX_DiscardUnknown 

func (m *MsgKeyValue) XXX_DiscardUnknown()

func (*MsgKeyValue) XXX_Marshal 

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

func (*MsgKeyValue) XXX_Merge 

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

func (*MsgKeyValue) XXX_Size 

func (m *MsgKeyValue) XXX_Size() int

func (*MsgKeyValue) XXX_Unmarshal 

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

type UnimplementedCounter2Server 

type UnimplementedCounter2Server struct {
}

UnimplementedCounter2Server can be embedded to have forward compatible implementations.

func (*UnimplementedCounter2Server) IncrementCounter 

func (*UnimplementedCounter2Server) IncrementCounter(ctx context.Context, req *MsgCounter2) (*MsgCreateCounterResponse, error)

type UnimplementedCounterServer 

type UnimplementedCounterServer struct {
}

UnimplementedCounterServer can be embedded to have forward compatible implementations.

func (*UnimplementedCounterServer) IncrementCounter 

func (*UnimplementedCounterServer) IncrementCounter(ctx context.Context, req *MsgCounter) (*MsgCreateCounterResponse, error)

type UnimplementedKeyValueServer 

type UnimplementedKeyValueServer struct {
}

UnimplementedKeyValueServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyValueServer) Set 

func (*UnimplementedKeyValueServer) Set(ctx context.Context, req *MsgKeyValue) (*MsgCreateKeyValueResponse, 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.