types

package
v2.2.0 Latest Latest
Warning

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

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

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 = "aol"

	// 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

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_capability"
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

View Source 
const GenesisKeySeparator = "/"

Variables

View Source 
var (
	ErrMessageTooLarge     = errors.Register(ModuleName, 2, "message too large")
	ErrInvalidTopic        = errors.Register(ModuleName, 3, "invalid topic")
	ErrInvalidMoniker      = errors.Register(ModuleName, 4, "invalid moniker")
	ErrTopicExists         = errors.Register(ModuleName, 5, "topic already exists")
	ErrWriterExists        = errors.Register(ModuleName, 6, "writer already exists")
	ErrTopicNotFound       = errors.Register(ModuleName, 7, "topic not found")
	ErrWriterNotFound      = errors.Register(ModuleName, 8, "writer not found")
	ErrWriterNotAuthorized = errors.Register(ModuleName, 9, "writer not authorized")
)

x/aol 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 (
	OwnerKeyPrefix  = []byte{0x00}
	TopicKeyPrefix  = []byte{0x01}
	WriterKeyPrefix = []byte{0x02}
	RecordKeyPrefix = []byte{0x03}
)
View Source 
var (
	ErrInvalidLengthOwner        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOwner          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOwner = 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 (
	ErrInvalidLengthRecord        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRecord          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRecord = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTopic        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopic          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTopic = 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 (
	ErrInvalidLengthWriter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWriter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWriter = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

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)

Types

type GenesisState 

type GenesisState struct {
	Owners  map[string]*Owner  `` /* 153-byte string literal not displayed */
	Topics  map[string]*Topic  `` /* 153-byte string literal not displayed */
	Writers map[string]*Writer `` /* 155-byte string literal not displayed */
	Records map[string]*Record `` /* 155-byte string literal not displayed */
}

GenesisState defines the aol 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) GetOwners 

func (m *GenesisState) GetOwners() map[string]*Owner

func (*GenesisState) GetRecords 

func (m *GenesisState) GetRecords() map[string]*Record

func (*GenesisState) GetTopics 

func (m *GenesisState) GetTopics() map[string]*Topic

func (*GenesisState) GetWriters 

func (m *GenesisState) GetWriters() map[string]*Writer

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 MsgAddRecordRequest added in v2.2.0 

type MsgAddRecordRequest struct {
	TopicName       string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Key             []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value           []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	WriterAddress   string `protobuf:"bytes,4,opt,name=writer_address,json=writerAddress,proto3" json:"writer_address,omitempty"`
	OwnerAddress    string `protobuf:"bytes,5,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	FeePayerAddress string `protobuf:"bytes,6,opt,name=fee_payer_address,json=feePayerAddress,proto3" json:"fee_payer_address,omitempty"`
}

MsgAddRecord defines the Msg/AddRecord request type.

func NewMsgAddRecordRequest added in v2.2.0 

func NewMsgAddRecordRequest(topicName string, key, value []byte, writerAddress, ownerAddress, feePayerAddress string) *MsgAddRecordRequest

func (*MsgAddRecordRequest) Descriptor added in v2.2.0 

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

func (*MsgAddRecordRequest) GetFeePayerAddress added in v2.2.0 

func (m *MsgAddRecordRequest) GetFeePayerAddress() string

func (*MsgAddRecordRequest) GetKey added in v2.2.0 

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

func (*MsgAddRecordRequest) GetOwnerAddress added in v2.2.0 

func (m *MsgAddRecordRequest) GetOwnerAddress() string

func (*MsgAddRecordRequest) GetSignBytes added in v2.2.0 

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

func (*MsgAddRecordRequest) GetSigners added in v2.2.0 

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

func (*MsgAddRecordRequest) GetTopicName added in v2.2.0 

func (m *MsgAddRecordRequest) GetTopicName() string

func (*MsgAddRecordRequest) GetValue added in v2.2.0 

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

func (*MsgAddRecordRequest) GetWriterAddress added in v2.2.0 

func (m *MsgAddRecordRequest) GetWriterAddress() string

func (*MsgAddRecordRequest) Marshal added in v2.2.0 

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

func (*MsgAddRecordRequest) MarshalTo added in v2.2.0 

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

func (*MsgAddRecordRequest) MarshalToSizedBuffer added in v2.2.0 

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

func (*MsgAddRecordRequest) ProtoMessage added in v2.2.0 

func (*MsgAddRecordRequest) ProtoMessage()

func (*MsgAddRecordRequest) Reset added in v2.2.0 

func (m *MsgAddRecordRequest) Reset()

func (*MsgAddRecordRequest) Route added in v2.2.0 

func (msg *MsgAddRecordRequest) Route() string

func (*MsgAddRecordRequest) Size added in v2.2.0 

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

func (*MsgAddRecordRequest) String added in v2.2.0 

func (m *MsgAddRecordRequest) String() string

func (*MsgAddRecordRequest) Type added in v2.2.0 

func (msg *MsgAddRecordRequest) Type() string

func (*MsgAddRecordRequest) Unmarshal added in v2.2.0 

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

func (*MsgAddRecordRequest) ValidateBasic added in v2.2.0 

func (msg *MsgAddRecordRequest) ValidateBasic() error

func (*MsgAddRecordRequest) XXX_DiscardUnknown added in v2.2.0 

func (m *MsgAddRecordRequest) XXX_DiscardUnknown()

func (*MsgAddRecordRequest) XXX_Marshal added in v2.2.0 

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

func (*MsgAddRecordRequest) XXX_Merge added in v2.2.0 

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

func (*MsgAddRecordRequest) XXX_Size added in v2.2.0 

func (m *MsgAddRecordRequest) XXX_Size() int

func (*MsgAddRecordRequest) XXX_Unmarshal added in v2.2.0 

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

type MsgAddRecordResponse 

type MsgAddRecordResponse struct {
	OwnerAddress string `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	TopicName    string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Offset       uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
}

MsgAddRecordResponse defines the Msg/AddRecordResponse response type.

func (*MsgAddRecordResponse) Descriptor 

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

func (*MsgAddRecordResponse) GetOffset 

func (m *MsgAddRecordResponse) GetOffset() uint64

func (*MsgAddRecordResponse) GetOwnerAddress 

func (m *MsgAddRecordResponse) GetOwnerAddress() string

func (*MsgAddRecordResponse) GetTopicName 

func (m *MsgAddRecordResponse) GetTopicName() string

func (*MsgAddRecordResponse) Marshal 

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

func (*MsgAddRecordResponse) MarshalTo 

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

func (*MsgAddRecordResponse) MarshalToSizedBuffer 

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

func (*MsgAddRecordResponse) ProtoMessage 

func (*MsgAddRecordResponse) ProtoMessage()

func (*MsgAddRecordResponse) Reset 

func (m *MsgAddRecordResponse) Reset()

func (*MsgAddRecordResponse) Size 

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

func (*MsgAddRecordResponse) String 

func (m *MsgAddRecordResponse) String() string

func (*MsgAddRecordResponse) Unmarshal 

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

func (*MsgAddRecordResponse) XXX_DiscardUnknown 

func (m *MsgAddRecordResponse) XXX_DiscardUnknown()

func (*MsgAddRecordResponse) XXX_Marshal 

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

func (*MsgAddRecordResponse) XXX_Merge 

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

func (*MsgAddRecordResponse) XXX_Size 

func (m *MsgAddRecordResponse) XXX_Size() int

func (*MsgAddRecordResponse) XXX_Unmarshal 

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

type MsgAddWriterRequest added in v2.2.0 

type MsgAddWriterRequest struct {
	TopicName     string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Moniker       string `protobuf:"bytes,2,opt,name=moniker,proto3" json:"moniker,omitempty"`
	Description   string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	WriterAddress string `protobuf:"bytes,4,opt,name=writer_address,json=writerAddress,proto3" json:"writer_address,omitempty"`
	OwnerAddress  string `protobuf:"bytes,5,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
}

MsgAddWriter defines the Msg/AddWriter request type.

func NewMsgAddWriter 

func NewMsgAddWriter(topicName, moniker, description, writerAddress, ownerAddress string) *MsgAddWriterRequest

func (*MsgAddWriterRequest) Descriptor added in v2.2.0 

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

func (*MsgAddWriterRequest) GetDescription added in v2.2.0 

func (m *MsgAddWriterRequest) GetDescription() string

func (*MsgAddWriterRequest) GetMoniker added in v2.2.0 

func (m *MsgAddWriterRequest) GetMoniker() string

func (*MsgAddWriterRequest) GetOwnerAddress added in v2.2.0 

func (m *MsgAddWriterRequest) GetOwnerAddress() string

func (*MsgAddWriterRequest) GetSignBytes added in v2.2.0 

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

func (*MsgAddWriterRequest) GetSigners added in v2.2.0 

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

func (*MsgAddWriterRequest) GetTopicName added in v2.2.0 

func (m *MsgAddWriterRequest) GetTopicName() string

func (*MsgAddWriterRequest) GetWriterAddress added in v2.2.0 

func (m *MsgAddWriterRequest) GetWriterAddress() string

func (*MsgAddWriterRequest) Marshal added in v2.2.0 

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

func (*MsgAddWriterRequest) MarshalTo added in v2.2.0 

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

func (*MsgAddWriterRequest) MarshalToSizedBuffer added in v2.2.0 

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

func (*MsgAddWriterRequest) ProtoMessage added in v2.2.0 

func (*MsgAddWriterRequest) ProtoMessage()

func (*MsgAddWriterRequest) Reset added in v2.2.0 

func (m *MsgAddWriterRequest) Reset()

func (*MsgAddWriterRequest) Route added in v2.2.0 

func (msg *MsgAddWriterRequest) Route() string

func (*MsgAddWriterRequest) Size added in v2.2.0 

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

func (*MsgAddWriterRequest) String added in v2.2.0 

func (m *MsgAddWriterRequest) String() string

func (*MsgAddWriterRequest) Type added in v2.2.0 

func (msg *MsgAddWriterRequest) Type() string

func (*MsgAddWriterRequest) Unmarshal added in v2.2.0 

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

func (*MsgAddWriterRequest) ValidateBasic added in v2.2.0 

func (msg *MsgAddWriterRequest) ValidateBasic() error

func (*MsgAddWriterRequest) XXX_DiscardUnknown added in v2.2.0 

func (m *MsgAddWriterRequest) XXX_DiscardUnknown()

func (*MsgAddWriterRequest) XXX_Marshal added in v2.2.0 

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

func (*MsgAddWriterRequest) XXX_Merge added in v2.2.0 

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

func (*MsgAddWriterRequest) XXX_Size added in v2.2.0 

func (m *MsgAddWriterRequest) XXX_Size() int

func (*MsgAddWriterRequest) XXX_Unmarshal added in v2.2.0 

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

type MsgAddWriterResponse 

type MsgAddWriterResponse struct {
}

MsgAddWriter defines the Msg/AddWriter response type.

func (*MsgAddWriterResponse) Descriptor 

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

func (*MsgAddWriterResponse) Marshal 

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

func (*MsgAddWriterResponse) MarshalTo 

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

func (*MsgAddWriterResponse) MarshalToSizedBuffer 

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

func (*MsgAddWriterResponse) ProtoMessage 

func (*MsgAddWriterResponse) ProtoMessage()

func (*MsgAddWriterResponse) Reset 

func (m *MsgAddWriterResponse) Reset()

func (*MsgAddWriterResponse) Size 

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

func (*MsgAddWriterResponse) String 

func (m *MsgAddWriterResponse) String() string

func (*MsgAddWriterResponse) Unmarshal 

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

func (*MsgAddWriterResponse) XXX_DiscardUnknown 

func (m *MsgAddWriterResponse) XXX_DiscardUnknown()

func (*MsgAddWriterResponse) XXX_Marshal 

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

func (*MsgAddWriterResponse) XXX_Merge 

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

func (*MsgAddWriterResponse) XXX_Size 

func (m *MsgAddWriterResponse) XXX_Size() int

func (*MsgAddWriterResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreateTopic defines a method for creating a topic.
	CreateTopic(ctx context.Context, in *MsgCreateTopicRequest, opts ...grpc.CallOption) (*MsgCreateTopicResponse, error)
	// AddWriter defines a method for adding a writer to the topic.
	AddWriter(ctx context.Context, in *MsgAddWriterRequest, opts ...grpc.CallOption) (*MsgAddWriterResponse, error)
	// DeleteWriter defines a method for deleting a writer to the topic.
	DeleteWriter(ctx context.Context, in *MsgDeleteWriterRequest, opts ...grpc.CallOption) (*MsgDeleteWriterResponse, error)
	// AddRecord defines a method for adding a record to the topic with the
	// writer.
	AddRecord(ctx context.Context, in *MsgAddRecordRequest, opts ...grpc.CallOption) (*MsgAddRecordResponse, 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 MsgCreateTopicRequest added in v2.2.0 

type MsgCreateTopicRequest struct {
	TopicName    string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Description  string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	OwnerAddress string `protobuf:"bytes,3,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
}

MsgCreateTopic defines the Msg/CreateTopic request type.

func NewMsgCreateTopic 

func NewMsgCreateTopic(topicName, description, ownerAddress string) *MsgCreateTopicRequest

func (*MsgCreateTopicRequest) Descriptor added in v2.2.0 

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

func (*MsgCreateTopicRequest) GetDescription added in v2.2.0 

func (m *MsgCreateTopicRequest) GetDescription() string

func (*MsgCreateTopicRequest) GetOwnerAddress added in v2.2.0 

func (m *MsgCreateTopicRequest) GetOwnerAddress() string

func (*MsgCreateTopicRequest) GetSignBytes added in v2.2.0 

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

func (*MsgCreateTopicRequest) GetSigners added in v2.2.0 

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

func (*MsgCreateTopicRequest) GetTopicName added in v2.2.0 

func (m *MsgCreateTopicRequest) GetTopicName() string

func (*MsgCreateTopicRequest) Marshal added in v2.2.0 

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

func (*MsgCreateTopicRequest) MarshalTo added in v2.2.0 

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

func (*MsgCreateTopicRequest) MarshalToSizedBuffer added in v2.2.0 

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

func (*MsgCreateTopicRequest) ProtoMessage added in v2.2.0 

func (*MsgCreateTopicRequest) ProtoMessage()

func (*MsgCreateTopicRequest) Reset added in v2.2.0 

func (m *MsgCreateTopicRequest) Reset()

func (*MsgCreateTopicRequest) Route added in v2.2.0 

func (msg *MsgCreateTopicRequest) Route() string

func (*MsgCreateTopicRequest) Size added in v2.2.0 

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

func (*MsgCreateTopicRequest) String added in v2.2.0 

func (m *MsgCreateTopicRequest) String() string

func (*MsgCreateTopicRequest) Type added in v2.2.0 

func (msg *MsgCreateTopicRequest) Type() string

func (*MsgCreateTopicRequest) Unmarshal added in v2.2.0 

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

func (*MsgCreateTopicRequest) ValidateBasic added in v2.2.0 

func (msg *MsgCreateTopicRequest) ValidateBasic() error

func (*MsgCreateTopicRequest) XXX_DiscardUnknown added in v2.2.0 

func (m *MsgCreateTopicRequest) XXX_DiscardUnknown()

func (*MsgCreateTopicRequest) XXX_Marshal added in v2.2.0 

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

func (*MsgCreateTopicRequest) XXX_Merge added in v2.2.0 

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

func (*MsgCreateTopicRequest) XXX_Size added in v2.2.0 

func (m *MsgCreateTopicRequest) XXX_Size() int

func (*MsgCreateTopicRequest) XXX_Unmarshal added in v2.2.0 

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

type MsgCreateTopicResponse 

type MsgCreateTopicResponse struct {
}

MsgCreateTopicResponse defines the Msg/CreateTopic response type.

func (*MsgCreateTopicResponse) Descriptor 

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

func (*MsgCreateTopicResponse) Marshal 

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

func (*MsgCreateTopicResponse) MarshalTo 

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

func (*MsgCreateTopicResponse) MarshalToSizedBuffer 

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

func (*MsgCreateTopicResponse) ProtoMessage 

func (*MsgCreateTopicResponse) ProtoMessage()

func (*MsgCreateTopicResponse) Reset 

func (m *MsgCreateTopicResponse) Reset()

func (*MsgCreateTopicResponse) Size 

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

func (*MsgCreateTopicResponse) String 

func (m *MsgCreateTopicResponse) String() string

func (*MsgCreateTopicResponse) Unmarshal 

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

func (*MsgCreateTopicResponse) XXX_DiscardUnknown 

func (m *MsgCreateTopicResponse) XXX_DiscardUnknown()

func (*MsgCreateTopicResponse) XXX_Marshal 

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

func (*MsgCreateTopicResponse) XXX_Merge 

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

func (*MsgCreateTopicResponse) XXX_Size 

func (m *MsgCreateTopicResponse) XXX_Size() int

func (*MsgCreateTopicResponse) XXX_Unmarshal 

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

type MsgDeleteWriterRequest added in v2.2.0 

type MsgDeleteWriterRequest struct {
	TopicName     string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	WriterAddress string `protobuf:"bytes,2,opt,name=writer_address,json=writerAddress,proto3" json:"writer_address,omitempty"`
	OwnerAddress  string `protobuf:"bytes,3,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
}

MsgDeleteWriter defines the Msg/DeleteWriter request type.

func NewMsgDeleteWriter 

func NewMsgDeleteWriter(topicName, writerAddress, ownerAddress string) *MsgDeleteWriterRequest

func (*MsgDeleteWriterRequest) Descriptor added in v2.2.0 

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

func (*MsgDeleteWriterRequest) GetOwnerAddress added in v2.2.0 

func (m *MsgDeleteWriterRequest) GetOwnerAddress() string

func (*MsgDeleteWriterRequest) GetSignBytes added in v2.2.0 

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

func (*MsgDeleteWriterRequest) GetSigners added in v2.2.0 

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

func (*MsgDeleteWriterRequest) GetTopicName added in v2.2.0 

func (m *MsgDeleteWriterRequest) GetTopicName() string

func (*MsgDeleteWriterRequest) GetWriterAddress added in v2.2.0 

func (m *MsgDeleteWriterRequest) GetWriterAddress() string

func (*MsgDeleteWriterRequest) Marshal added in v2.2.0 

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

func (*MsgDeleteWriterRequest) MarshalTo added in v2.2.0 

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

func (*MsgDeleteWriterRequest) MarshalToSizedBuffer added in v2.2.0 

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

func (*MsgDeleteWriterRequest) ProtoMessage added in v2.2.0 

func (*MsgDeleteWriterRequest) ProtoMessage()

func (*MsgDeleteWriterRequest) Reset added in v2.2.0 

func (m *MsgDeleteWriterRequest) Reset()

func (*MsgDeleteWriterRequest) Route added in v2.2.0 

func (msg *MsgDeleteWriterRequest) Route() string

func (*MsgDeleteWriterRequest) Size added in v2.2.0 

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

func (*MsgDeleteWriterRequest) String added in v2.2.0 

func (m *MsgDeleteWriterRequest) String() string

func (*MsgDeleteWriterRequest) Type added in v2.2.0 

func (msg *MsgDeleteWriterRequest) Type() string

func (*MsgDeleteWriterRequest) Unmarshal added in v2.2.0 

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

func (*MsgDeleteWriterRequest) ValidateBasic added in v2.2.0 

func (msg *MsgDeleteWriterRequest) ValidateBasic() error

func (*MsgDeleteWriterRequest) XXX_DiscardUnknown added in v2.2.0 

func (m *MsgDeleteWriterRequest) XXX_DiscardUnknown()

func (*MsgDeleteWriterRequest) XXX_Marshal added in v2.2.0 

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

func (*MsgDeleteWriterRequest) XXX_Merge added in v2.2.0 

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

func (*MsgDeleteWriterRequest) XXX_Size added in v2.2.0 

func (m *MsgDeleteWriterRequest) XXX_Size() int

func (*MsgDeleteWriterRequest) XXX_Unmarshal added in v2.2.0 

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

type MsgDeleteWriterResponse 

type MsgDeleteWriterResponse struct {
}

MsgDeleteWriter defines the Msg/DeleteWriter response type.

func (*MsgDeleteWriterResponse) Descriptor 

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

func (*MsgDeleteWriterResponse) Marshal 

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

func (*MsgDeleteWriterResponse) MarshalTo 

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

func (*MsgDeleteWriterResponse) MarshalToSizedBuffer 

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

func (*MsgDeleteWriterResponse) ProtoMessage 

func (*MsgDeleteWriterResponse) ProtoMessage()

func (*MsgDeleteWriterResponse) Reset 

func (m *MsgDeleteWriterResponse) Reset()

func (*MsgDeleteWriterResponse) Size 

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

func (*MsgDeleteWriterResponse) String 

func (m *MsgDeleteWriterResponse) String() string

func (*MsgDeleteWriterResponse) Unmarshal 

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

func (*MsgDeleteWriterResponse) XXX_DiscardUnknown 

func (m *MsgDeleteWriterResponse) XXX_DiscardUnknown()

func (*MsgDeleteWriterResponse) XXX_Marshal 

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

func (*MsgDeleteWriterResponse) XXX_Merge 

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

func (*MsgDeleteWriterResponse) XXX_Size 

func (m *MsgDeleteWriterResponse) XXX_Size() int

func (*MsgDeleteWriterResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateTopic defines a method for creating a topic.
	CreateTopic(context.Context, *MsgCreateTopicRequest) (*MsgCreateTopicResponse, error)
	// AddWriter defines a method for adding a writer to the topic.
	AddWriter(context.Context, *MsgAddWriterRequest) (*MsgAddWriterResponse, error)
	// DeleteWriter defines a method for deleting a writer to the topic.
	DeleteWriter(context.Context, *MsgDeleteWriterRequest) (*MsgDeleteWriterResponse, error)
	// AddRecord defines a method for adding a record to the topic with the
	// writer.
	AddRecord(context.Context, *MsgAddRecordRequest) (*MsgAddRecordResponse, error)
}

MsgServer is the server API for Msg service.

type Owner 

type Owner struct {
	TotalTopics uint64 `protobuf:"varint,1,opt,name=total_topics,json=totalTopics,proto3" json:"total_topics,omitempty"`
}

Owner defines a owner type.

func (*Owner) Descriptor 

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

func (*Owner) GetTotalTopics 

func (m *Owner) GetTotalTopics() uint64

func (Owner) IncreaseTotalTopics 

func (o Owner) IncreaseTotalTopics() Owner

func (*Owner) Marshal 

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

func (*Owner) MarshalTo 

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

func (*Owner) MarshalToSizedBuffer 

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

func (*Owner) ProtoMessage 

func (*Owner) ProtoMessage()

func (*Owner) Reset 

func (m *Owner) Reset()

func (*Owner) Size 

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

func (*Owner) String 

func (m *Owner) String() string

func (*Owner) Unmarshal 

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

func (*Owner) XXX_DiscardUnknown 

func (m *Owner) XXX_DiscardUnknown()

func (*Owner) XXX_Marshal 

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

func (*Owner) XXX_Merge 

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

func (*Owner) XXX_Size 

func (m *Owner) XXX_Size() int

func (*Owner) XXX_Unmarshal 

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

type OwnerCompositeKey 

type OwnerCompositeKey struct {
	OwnerAddress sdk.AccAddress
}

func (OwnerCompositeKey) ByteSlices 

func (k OwnerCompositeKey) ByteSlices() [][]byte

func (*OwnerCompositeKey) FromByteSlices 

func (k *OwnerCompositeKey) FromByteSlices(bzs [][]byte) error

func (*OwnerCompositeKey) FromStrings 

func (k *OwnerCompositeKey) FromStrings(strings []string) error

func (OwnerCompositeKey) Strings 

func (k OwnerCompositeKey) Strings() []string

type QueryClient 

type QueryClient interface {
	// Topic returns topic details.
	Topic(ctx context.Context, in *QueryTopicRequest, opts ...grpc.CallOption) (*QueryTopicResponse, error)
	// Topics returns topic names.
	Topics(ctx context.Context, in *QueryTopicsRequest, opts ...grpc.CallOption) (*QueryTopicsResponse, error)
	// Writer returns writer details.
	Writer(ctx context.Context, in *QueryWriterRequest, opts ...grpc.CallOption) (*QueryWriterResponse, error)
	// Writers returns writer addresses.
	Writers(ctx context.Context, in *QueryWritersRequest, opts ...grpc.CallOption) (*QueryWritersResponse, error)
	// Record returns record details.
	Record(ctx context.Context, in *QueryRecordRequest, opts ...grpc.CallOption) (*QueryRecordResponse, 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 QueryRecordRequest 

type QueryRecordRequest struct {
	OwnerAddress string `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	TopicName    string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Offset       uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
}

QueryRecordRequest is the request type for the Query/Record RPC method.

func (*QueryRecordRequest) Descriptor 

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

func (*QueryRecordRequest) GetOffset 

func (m *QueryRecordRequest) GetOffset() uint64

func (*QueryRecordRequest) GetOwnerAddress 

func (m *QueryRecordRequest) GetOwnerAddress() string

func (*QueryRecordRequest) GetTopicName 

func (m *QueryRecordRequest) GetTopicName() string

func (*QueryRecordRequest) Marshal 

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

func (*QueryRecordRequest) MarshalTo 

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

func (*QueryRecordRequest) MarshalToSizedBuffer 

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

func (*QueryRecordRequest) ProtoMessage 

func (*QueryRecordRequest) ProtoMessage()

func (*QueryRecordRequest) Reset 

func (m *QueryRecordRequest) Reset()

func (*QueryRecordRequest) Size 

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

func (*QueryRecordRequest) String 

func (m *QueryRecordRequest) String() string

func (*QueryRecordRequest) Unmarshal 

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

func (*QueryRecordRequest) XXX_DiscardUnknown 

func (m *QueryRecordRequest) XXX_DiscardUnknown()

func (*QueryRecordRequest) XXX_Marshal 

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

func (*QueryRecordRequest) XXX_Merge 

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

func (*QueryRecordRequest) XXX_Size 

func (m *QueryRecordRequest) XXX_Size() int

func (*QueryRecordRequest) XXX_Unmarshal 

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

type QueryRecordResponse 

type QueryRecordResponse struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
}

QueryRecordResponse is the response type for the Query/Record RPC method.

func (*QueryRecordResponse) Descriptor 

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

func (*QueryRecordResponse) GetRecord 

func (m *QueryRecordResponse) GetRecord() *Record

func (*QueryRecordResponse) Marshal 

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

func (*QueryRecordResponse) MarshalTo 

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

func (*QueryRecordResponse) MarshalToSizedBuffer 

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

func (*QueryRecordResponse) ProtoMessage 

func (*QueryRecordResponse) ProtoMessage()

func (*QueryRecordResponse) Reset 

func (m *QueryRecordResponse) Reset()

func (*QueryRecordResponse) Size 

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

func (*QueryRecordResponse) String 

func (m *QueryRecordResponse) String() string

func (*QueryRecordResponse) Unmarshal 

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

func (*QueryRecordResponse) XXX_DiscardUnknown 

func (m *QueryRecordResponse) XXX_DiscardUnknown()

func (*QueryRecordResponse) XXX_Marshal 

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

func (*QueryRecordResponse) XXX_Merge 

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

func (*QueryRecordResponse) XXX_Size 

func (m *QueryRecordResponse) XXX_Size() int

func (*QueryRecordResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Topic returns topic details.
	Topic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
	// Topics returns topic names.
	Topics(context.Context, *QueryTopicsRequest) (*QueryTopicsResponse, error)
	// Writer returns writer details.
	Writer(context.Context, *QueryWriterRequest) (*QueryWriterResponse, error)
	// Writers returns writer addresses.
	Writers(context.Context, *QueryWritersRequest) (*QueryWritersResponse, error)
	// Record returns record details.
	Record(context.Context, *QueryRecordRequest) (*QueryRecordResponse, error)
}

QueryServer is the server API for Query service.

type QueryTopicRequest 

type QueryTopicRequest struct {
	OwnerAddress string `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	TopicName    string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
}

QueryTopicRequest is the request type for the Query/Topic RPC method.

func (*QueryTopicRequest) Descriptor 

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

func (*QueryTopicRequest) GetOwnerAddress 

func (m *QueryTopicRequest) GetOwnerAddress() string

func (*QueryTopicRequest) GetTopicName 

func (m *QueryTopicRequest) GetTopicName() string

func (*QueryTopicRequest) Marshal 

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

func (*QueryTopicRequest) MarshalTo 

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

func (*QueryTopicRequest) MarshalToSizedBuffer 

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

func (*QueryTopicRequest) ProtoMessage 

func (*QueryTopicRequest) ProtoMessage()

func (*QueryTopicRequest) Reset 

func (m *QueryTopicRequest) Reset()

func (*QueryTopicRequest) Size 

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

func (*QueryTopicRequest) String 

func (m *QueryTopicRequest) String() string

func (*QueryTopicRequest) Unmarshal 

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

func (*QueryTopicRequest) XXX_DiscardUnknown 

func (m *QueryTopicRequest) XXX_DiscardUnknown()

func (*QueryTopicRequest) XXX_Marshal 

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

func (*QueryTopicRequest) XXX_Merge 

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

func (*QueryTopicRequest) XXX_Size 

func (m *QueryTopicRequest) XXX_Size() int

func (*QueryTopicRequest) XXX_Unmarshal 

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

type QueryTopicResponse 

type QueryTopicResponse struct {
	Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
}

QueryTopicResponse is the response type for the Query/Topic RPC method.

func (*QueryTopicResponse) Descriptor 

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

func (*QueryTopicResponse) GetTopic 

func (m *QueryTopicResponse) GetTopic() *Topic

func (*QueryTopicResponse) Marshal 

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

func (*QueryTopicResponse) MarshalTo 

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

func (*QueryTopicResponse) MarshalToSizedBuffer 

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

func (*QueryTopicResponse) ProtoMessage 

func (*QueryTopicResponse) ProtoMessage()

func (*QueryTopicResponse) Reset 

func (m *QueryTopicResponse) Reset()

func (*QueryTopicResponse) Size 

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

func (*QueryTopicResponse) String 

func (m *QueryTopicResponse) String() string

func (*QueryTopicResponse) Unmarshal 

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

func (*QueryTopicResponse) XXX_DiscardUnknown 

func (m *QueryTopicResponse) XXX_DiscardUnknown()

func (*QueryTopicResponse) XXX_Marshal 

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

func (*QueryTopicResponse) XXX_Merge 

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

func (*QueryTopicResponse) XXX_Size 

func (m *QueryTopicResponse) XXX_Size() int

func (*QueryTopicResponse) XXX_Unmarshal 

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

type QueryTopicsRequest 

type QueryTopicsRequest struct {
	OwnerAddress string             `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	Pagination   *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTopicsRequest is the request type for the Query/Topics RPC method.

func (*QueryTopicsRequest) Descriptor 

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

func (*QueryTopicsRequest) GetOwnerAddress 

func (m *QueryTopicsRequest) GetOwnerAddress() string

func (*QueryTopicsRequest) GetPagination 

func (m *QueryTopicsRequest) GetPagination() *query.PageRequest

func (*QueryTopicsRequest) Marshal 

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

func (*QueryTopicsRequest) MarshalTo 

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

func (*QueryTopicsRequest) MarshalToSizedBuffer 

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

func (*QueryTopicsRequest) ProtoMessage 

func (*QueryTopicsRequest) ProtoMessage()

func (*QueryTopicsRequest) Reset 

func (m *QueryTopicsRequest) Reset()

func (*QueryTopicsRequest) Size 

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

func (*QueryTopicsRequest) String 

func (m *QueryTopicsRequest) String() string

func (*QueryTopicsRequest) Unmarshal 

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

func (*QueryTopicsRequest) XXX_DiscardUnknown 

func (m *QueryTopicsRequest) XXX_DiscardUnknown()

func (*QueryTopicsRequest) XXX_Marshal 

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

func (*QueryTopicsRequest) XXX_Merge 

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

func (*QueryTopicsRequest) XXX_Size 

func (m *QueryTopicsRequest) XXX_Size() int

func (*QueryTopicsRequest) XXX_Unmarshal 

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

type QueryTopicsResponse 

type QueryTopicsResponse struct {
	TopicNames []string            `protobuf:"bytes,1,rep,name=topic_names,json=topicNames,proto3" json:"topic_names,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTopicsResponse is the response type for the Query/Topics RPC method.

func (*QueryTopicsResponse) Descriptor 

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

func (*QueryTopicsResponse) GetPagination 

func (m *QueryTopicsResponse) GetPagination() *query.PageResponse

func (*QueryTopicsResponse) GetTopicNames 

func (m *QueryTopicsResponse) GetTopicNames() []string

func (*QueryTopicsResponse) Marshal 

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

func (*QueryTopicsResponse) MarshalTo 

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

func (*QueryTopicsResponse) MarshalToSizedBuffer 

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

func (*QueryTopicsResponse) ProtoMessage 

func (*QueryTopicsResponse) ProtoMessage()

func (*QueryTopicsResponse) Reset 

func (m *QueryTopicsResponse) Reset()

func (*QueryTopicsResponse) Size 

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

func (*QueryTopicsResponse) String 

func (m *QueryTopicsResponse) String() string

func (*QueryTopicsResponse) Unmarshal 

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

func (*QueryTopicsResponse) XXX_DiscardUnknown 

func (m *QueryTopicsResponse) XXX_DiscardUnknown()

func (*QueryTopicsResponse) XXX_Marshal 

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

func (*QueryTopicsResponse) XXX_Merge 

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

func (*QueryTopicsResponse) XXX_Size 

func (m *QueryTopicsResponse) XXX_Size() int

func (*QueryTopicsResponse) XXX_Unmarshal 

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

type QueryWriterRequest 

type QueryWriterRequest struct {
	OwnerAddress  string `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	TopicName     string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	WriterAddress string `protobuf:"bytes,3,opt,name=writer_address,json=writerAddress,proto3" json:"writer_address,omitempty"`
}

QueryWriterRequest is the request type for the Query/Writer RPC method.

func (*QueryWriterRequest) Descriptor 

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

func (*QueryWriterRequest) GetOwnerAddress 

func (m *QueryWriterRequest) GetOwnerAddress() string

func (*QueryWriterRequest) GetTopicName 

func (m *QueryWriterRequest) GetTopicName() string

func (*QueryWriterRequest) GetWriterAddress 

func (m *QueryWriterRequest) GetWriterAddress() string

func (*QueryWriterRequest) Marshal 

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

func (*QueryWriterRequest) MarshalTo 

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

func (*QueryWriterRequest) MarshalToSizedBuffer 

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

func (*QueryWriterRequest) ProtoMessage 

func (*QueryWriterRequest) ProtoMessage()

func (*QueryWriterRequest) Reset 

func (m *QueryWriterRequest) Reset()

func (*QueryWriterRequest) Size 

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

func (*QueryWriterRequest) String 

func (m *QueryWriterRequest) String() string

func (*QueryWriterRequest) Unmarshal 

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

func (*QueryWriterRequest) XXX_DiscardUnknown 

func (m *QueryWriterRequest) XXX_DiscardUnknown()

func (*QueryWriterRequest) XXX_Marshal 

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

func (*QueryWriterRequest) XXX_Merge 

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

func (*QueryWriterRequest) XXX_Size 

func (m *QueryWriterRequest) XXX_Size() int

func (*QueryWriterRequest) XXX_Unmarshal 

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

type QueryWriterResponse 

type QueryWriterResponse struct {
	Writer *Writer `protobuf:"bytes,1,opt,name=writer,proto3" json:"writer,omitempty"`
}

QueryWriterResponse is the response type for the Query/Writer RPC method.

func (*QueryWriterResponse) Descriptor 

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

func (*QueryWriterResponse) GetWriter 

func (m *QueryWriterResponse) GetWriter() *Writer

func (*QueryWriterResponse) Marshal 

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

func (*QueryWriterResponse) MarshalTo 

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

func (*QueryWriterResponse) MarshalToSizedBuffer 

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

func (*QueryWriterResponse) ProtoMessage 

func (*QueryWriterResponse) ProtoMessage()

func (*QueryWriterResponse) Reset 

func (m *QueryWriterResponse) Reset()

func (*QueryWriterResponse) Size 

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

func (*QueryWriterResponse) String 

func (m *QueryWriterResponse) String() string

func (*QueryWriterResponse) Unmarshal 

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

func (*QueryWriterResponse) XXX_DiscardUnknown 

func (m *QueryWriterResponse) XXX_DiscardUnknown()

func (*QueryWriterResponse) XXX_Marshal 

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

func (*QueryWriterResponse) XXX_Merge 

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

func (*QueryWriterResponse) XXX_Size 

func (m *QueryWriterResponse) XXX_Size() int

func (*QueryWriterResponse) XXX_Unmarshal 

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

type QueryWritersRequest 

type QueryWritersRequest struct {
	OwnerAddress string             `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"`
	TopicName    string             `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	Pagination   *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryWritersRequest is the request type for the Query/Writers RPC method.

func (*QueryWritersRequest) Descriptor 

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

func (*QueryWritersRequest) GetOwnerAddress 

func (m *QueryWritersRequest) GetOwnerAddress() string

func (*QueryWritersRequest) GetPagination 

func (m *QueryWritersRequest) GetPagination() *query.PageRequest

func (*QueryWritersRequest) GetTopicName 

func (m *QueryWritersRequest) GetTopicName() string

func (*QueryWritersRequest) Marshal 

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

func (*QueryWritersRequest) MarshalTo 

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

func (*QueryWritersRequest) MarshalToSizedBuffer 

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

func (*QueryWritersRequest) ProtoMessage 

func (*QueryWritersRequest) ProtoMessage()

func (*QueryWritersRequest) Reset 

func (m *QueryWritersRequest) Reset()

func (*QueryWritersRequest) Size 

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

func (*QueryWritersRequest) String 

func (m *QueryWritersRequest) String() string

func (*QueryWritersRequest) Unmarshal 

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

func (*QueryWritersRequest) XXX_DiscardUnknown 

func (m *QueryWritersRequest) XXX_DiscardUnknown()

func (*QueryWritersRequest) XXX_Marshal 

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

func (*QueryWritersRequest) XXX_Merge 

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

func (*QueryWritersRequest) XXX_Size 

func (m *QueryWritersRequest) XXX_Size() int

func (*QueryWritersRequest) XXX_Unmarshal 

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

type QueryWritersResponse 

type QueryWritersResponse struct {
	WriterAddresses []string            `protobuf:"bytes,1,rep,name=writer_addresses,json=writerAddresses,proto3" json:"writer_addresses,omitempty"`
	Pagination      *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryWritersResponse is the response type for the Query/Writers RPC method.

func (*QueryWritersResponse) Descriptor 

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

func (*QueryWritersResponse) GetPagination 

func (m *QueryWritersResponse) GetPagination() *query.PageResponse

func (*QueryWritersResponse) GetWriterAddresses 

func (m *QueryWritersResponse) GetWriterAddresses() []string

func (*QueryWritersResponse) Marshal 

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

func (*QueryWritersResponse) MarshalTo 

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

func (*QueryWritersResponse) MarshalToSizedBuffer 

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

func (*QueryWritersResponse) ProtoMessage 

func (*QueryWritersResponse) ProtoMessage()

func (*QueryWritersResponse) Reset 

func (m *QueryWritersResponse) Reset()

func (*QueryWritersResponse) Size 

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

func (*QueryWritersResponse) String 

func (m *QueryWritersResponse) String() string

func (*QueryWritersResponse) Unmarshal 

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

func (*QueryWritersResponse) XXX_DiscardUnknown 

func (m *QueryWritersResponse) XXX_DiscardUnknown()

func (*QueryWritersResponse) XXX_Marshal 

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

func (*QueryWritersResponse) XXX_Merge 

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

func (*QueryWritersResponse) XXX_Size 

func (m *QueryWritersResponse) XXX_Size() int

func (*QueryWritersResponse) XXX_Unmarshal 

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

type Record 

type Record 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"`
	NanoTimestamp int64  `protobuf:"varint,3,opt,name=nano_timestamp,json=nanoTimestamp,proto3" json:"nano_timestamp,omitempty"`
	WriterAddress string `protobuf:"bytes,4,opt,name=writer_address,json=writerAddress,proto3" json:"writer_address,omitempty"`
}

Record defines a record type.

func (*Record) Descriptor 

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

func (*Record) GetKey 

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

func (*Record) GetNanoTimestamp 

func (m *Record) GetNanoTimestamp() int64

func (*Record) GetValue 

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

func (*Record) GetWriterAddress 

func (m *Record) GetWriterAddress() string

func (*Record) Marshal 

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

func (*Record) MarshalTo 

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

func (*Record) MarshalToSizedBuffer 

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

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) Size 

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

func (*Record) String 

func (m *Record) String() string

func (*Record) Unmarshal 

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

func (Record) Validate 

func (r Record) Validate() error

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

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

func (*Record) XXX_Merge 

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

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

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

type RecordCompositeKey 

type RecordCompositeKey struct {
	OwnerAddress sdk.AccAddress
	TopicName    string
	Offset       uint64
}

func (RecordCompositeKey) ByteSlices 

func (k RecordCompositeKey) ByteSlices() [][]byte

func (*RecordCompositeKey) FromByteSlices 

func (k *RecordCompositeKey) FromByteSlices(bzs [][]byte) error

func (*RecordCompositeKey) FromStrings 

func (k *RecordCompositeKey) FromStrings(strings []string) error

func (RecordCompositeKey) Strings 

func (k RecordCompositeKey) Strings() []string

type Topic 

type Topic struct {
	Description  string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	TotalRecords uint64 `protobuf:"varint,2,opt,name=total_records,json=totalRecords,proto3" json:"total_records,omitempty"`
	TotalWriters uint64 `protobuf:"varint,3,opt,name=total_writers,json=totalWriters,proto3" json:"total_writers,omitempty"`
}

Topic defines a topic type.

func (Topic) DecreaseTotalWriters 

func (t Topic) DecreaseTotalWriters() Topic

func (*Topic) Descriptor 

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

func (*Topic) GetDescription 

func (m *Topic) GetDescription() string

func (*Topic) GetTotalRecords 

func (m *Topic) GetTotalRecords() uint64

func (*Topic) GetTotalWriters 

func (m *Topic) GetTotalWriters() uint64

func (Topic) IncreaseTotalRecords 

func (t Topic) IncreaseTotalRecords() Topic

func (Topic) IncreaseTotalWriters 

func (t Topic) IncreaseTotalWriters() Topic

func (*Topic) Marshal 

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

func (*Topic) MarshalTo 

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

func (*Topic) MarshalToSizedBuffer 

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

func (Topic) NextRecordOffset 

func (t Topic) NextRecordOffset() uint64

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) Size 

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

func (*Topic) String 

func (m *Topic) String() string

func (*Topic) Unmarshal 

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

func (Topic) Validate 

func (t Topic) Validate() error

func (*Topic) XXX_DiscardUnknown 

func (m *Topic) XXX_DiscardUnknown()

func (*Topic) XXX_Marshal 

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

func (*Topic) XXX_Merge 

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

func (*Topic) XXX_Size 

func (m *Topic) XXX_Size() int

func (*Topic) XXX_Unmarshal 

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

type TopicCompositeKey 

type TopicCompositeKey struct {
	OwnerAddress sdk.AccAddress
	TopicName    string
}

func (TopicCompositeKey) ByteSlices 

func (k TopicCompositeKey) ByteSlices() [][]byte

func (*TopicCompositeKey) FromByteSlices 

func (k *TopicCompositeKey) FromByteSlices(bzs [][]byte) error

func (*TopicCompositeKey) FromStrings 

func (k *TopicCompositeKey) FromStrings(strings []string) error

func (TopicCompositeKey) Strings 

func (k TopicCompositeKey) Strings() []string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddRecord 

func (*UnimplementedMsgServer) AddRecord(ctx context.Context, req *MsgAddRecordRequest) (*MsgAddRecordResponse, error)

func (*UnimplementedMsgServer) AddWriter 

func (*UnimplementedMsgServer) AddWriter(ctx context.Context, req *MsgAddWriterRequest) (*MsgAddWriterResponse, error)

func (*UnimplementedMsgServer) CreateTopic 

func (*UnimplementedMsgServer) CreateTopic(ctx context.Context, req *MsgCreateTopicRequest) (*MsgCreateTopicResponse, error)

func (*UnimplementedMsgServer) DeleteWriter 

func (*UnimplementedMsgServer) DeleteWriter(ctx context.Context, req *MsgDeleteWriterRequest) (*MsgDeleteWriterResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Record 

func (*UnimplementedQueryServer) Record(ctx context.Context, req *QueryRecordRequest) (*QueryRecordResponse, error)

func (*UnimplementedQueryServer) Topic 

func (*UnimplementedQueryServer) Topic(ctx context.Context, req *QueryTopicRequest) (*QueryTopicResponse, error)

func (*UnimplementedQueryServer) Topics 

func (*UnimplementedQueryServer) Topics(ctx context.Context, req *QueryTopicsRequest) (*QueryTopicsResponse, error)

func (*UnimplementedQueryServer) Writer 

func (*UnimplementedQueryServer) Writer(ctx context.Context, req *QueryWriterRequest) (*QueryWriterResponse, error)

func (*UnimplementedQueryServer) Writers 

func (*UnimplementedQueryServer) Writers(ctx context.Context, req *QueryWritersRequest) (*QueryWritersResponse, error)

type Writer 

type Writer struct {
	Moniker       string `protobuf:"bytes,1,opt,name=moniker,proto3" json:"moniker,omitempty"`
	Description   string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	NanoTimestamp int64  `protobuf:"varint,3,opt,name=nano_timestamp,json=nanoTimestamp,proto3" json:"nano_timestamp,omitempty"`
}

Topic defines a topic type.

func (*Writer) Descriptor 

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

func (*Writer) GetDescription 

func (m *Writer) GetDescription() string

func (*Writer) GetMoniker 

func (m *Writer) GetMoniker() string

func (*Writer) GetNanoTimestamp 

func (m *Writer) GetNanoTimestamp() int64

func (*Writer) Marshal 

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

func (*Writer) MarshalTo 

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

func (*Writer) MarshalToSizedBuffer 

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

func (*Writer) ProtoMessage 

func (*Writer) ProtoMessage()

func (*Writer) Reset 

func (m *Writer) Reset()

func (*Writer) Size 

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

func (*Writer) String 

func (m *Writer) String() string

func (*Writer) Unmarshal 

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

func (Writer) Validate 

func (w Writer) Validate() error

func (*Writer) XXX_DiscardUnknown 

func (m *Writer) XXX_DiscardUnknown()

func (*Writer) XXX_Marshal 

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

func (*Writer) XXX_Merge 

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

func (*Writer) XXX_Size 

func (m *Writer) XXX_Size() int

func (*Writer) XXX_Unmarshal 

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

type WriterCompositeKey 

type WriterCompositeKey struct {
	OwnerAddress  sdk.AccAddress
	TopicName     string
	WriterAddress sdk.AccAddress
}

func (WriterCompositeKey) ByteSlices 

func (k WriterCompositeKey) ByteSlices() [][]byte

func (*WriterCompositeKey) FromByteSlices 

func (k *WriterCompositeKey) FromByteSlices(bzs [][]byte) error

func (*WriterCompositeKey) FromStrings 

func (k *WriterCompositeKey) FromStrings(strings []string) error

func (WriterCompositeKey) Strings 

func (k WriterCompositeKey) Strings() []string

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.