types

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: May 29, 2024 License: LGPL-3.0 Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DefaultPageRequestLimit = uint32(10)
)
View Source 
const (
	ModuleName = "shard_sequencer"
)

Variables

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

Functions

func ExtractPageRequest 

func ExtractPageRequest(pr *PageRequest) ([]byte, uint32)

ExtractPageRequest first checks if given a valid page request. If so, it returns the key and limit. Else, it returns the default key (nil) and limit.

func IsEmptyOrDefault 

func IsEmptyOrDefault(pr *PageRequest) bool

IsEmptyOrDefault returns true if the page request is nil, or if it only contains default values.

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 Epoch 

type Epoch struct {
	Epoch         uint64         `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	UnixTimestamp uint64         `protobuf:"varint,2,opt,name=unix_timestamp,json=unixTimestamp,proto3" json:"unix_timestamp,omitempty"`
	Txs           []*Transaction `protobuf:"bytes,3,rep,name=txs,proto3" json:"txs,omitempty"`
}

Epoch contains an epoch number, and the transactions that occurred in that epoch.

func (*Epoch) Descriptor 

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

func (*Epoch) GetEpoch 

func (m *Epoch) GetEpoch() uint64

func (*Epoch) GetTxs 

func (m *Epoch) GetTxs() []*Transaction

func (*Epoch) GetUnixTimestamp 

func (m *Epoch) GetUnixTimestamp() uint64

func (*Epoch) Marshal 

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

func (*Epoch) MarshalTo 

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

func (*Epoch) MarshalToSizedBuffer 

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

func (*Epoch) ProtoMessage 

func (*Epoch) ProtoMessage()

func (*Epoch) Reset 

func (m *Epoch) Reset()

func (*Epoch) Size 

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

func (*Epoch) String 

func (m *Epoch) String() string

func (*Epoch) Unmarshal 

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

func (*Epoch) XXX_DiscardUnknown 

func (m *Epoch) XXX_DiscardUnknown()

func (*Epoch) XXX_Marshal 

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

func (*Epoch) XXX_Merge 

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

func (*Epoch) XXX_Size 

func (m *Epoch) XXX_Size() int

func (*Epoch) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// namespace_transactions contains a world's namespace, and all the transactions that occurred within that world.
	NamespaceTransactions []*NamespaceTransactions `protobuf:"bytes,1,rep,name=namespace_transactions,json=namespaceTransactions,proto3" json:"namespace_transactions,omitempty"`
}

func DefaultGenesis 

func DefaultGenesis() *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetNamespaceTransactions 

func (m *GenesisState) GetNamespaceTransactions() []*NamespaceTransactions

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 (g *GenesisState) Validate() error

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 {
	SubmitShardTx(ctx context.Context, in *SubmitShardTxRequest, opts ...grpc.CallOption) (*SubmitShardTxResponse, 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 {
	SubmitShardTx(context.Context, *SubmitShardTxRequest) (*SubmitShardTxResponse, error)
}

MsgServer is the server API for Msg service.

type NamespaceTransactions 

type NamespaceTransactions struct {
	// namespace is the namespace the transactions occurred in.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// epochs contains an epoch number, and the transactions that occurred within that epoch.
	Epochs []*Epoch `protobuf:"bytes,2,rep,name=epochs,proto3" json:"epochs,omitempty"`
}

func (*NamespaceTransactions) Descriptor 

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

func (*NamespaceTransactions) GetEpochs 

func (m *NamespaceTransactions) GetEpochs() []*Epoch

func (*NamespaceTransactions) GetNamespace 

func (m *NamespaceTransactions) GetNamespace() string

func (*NamespaceTransactions) Marshal 

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

func (*NamespaceTransactions) MarshalTo 

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

func (*NamespaceTransactions) MarshalToSizedBuffer 

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

func (*NamespaceTransactions) ProtoMessage 

func (*NamespaceTransactions) ProtoMessage()

func (*NamespaceTransactions) Reset 

func (m *NamespaceTransactions) Reset()

func (*NamespaceTransactions) Size 

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

func (*NamespaceTransactions) String 

func (m *NamespaceTransactions) String() string

func (*NamespaceTransactions) Unmarshal 

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

func (*NamespaceTransactions) XXX_DiscardUnknown 

func (m *NamespaceTransactions) XXX_DiscardUnknown()

func (*NamespaceTransactions) XXX_Marshal 

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

func (*NamespaceTransactions) XXX_Merge 

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

func (*NamespaceTransactions) XXX_Size 

func (m *NamespaceTransactions) XXX_Size() int

func (*NamespaceTransactions) XXX_Unmarshal 

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

type PageRequest 

type PageRequest struct {
	// key is the cosmos SDK store key to begin the iteration on.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// limit is the amount of items we want to limit in our return.
	// example, if the collection we are interested has 10 items,
	// and we set limit to 5, the query will only return 5 items.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
}

PageRequest represents a request for a paged query.

func DefaultPageRequest 

func DefaultPageRequest() *PageRequest

DefaultPageRequest returns a default page request with a nil key, and the limit set to DefaultPageRequestLimit.

func (*PageRequest) Descriptor 

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

func (*PageRequest) GetKey 

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

func (*PageRequest) GetLimit 

func (m *PageRequest) GetLimit() uint32

func (*PageRequest) Marshal 

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

func (*PageRequest) MarshalTo 

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

func (*PageRequest) MarshalToSizedBuffer 

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

func (*PageRequest) ProtoMessage 

func (*PageRequest) ProtoMessage()

func (*PageRequest) Reset 

func (m *PageRequest) Reset()

func (*PageRequest) Size 

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

func (*PageRequest) String 

func (m *PageRequest) String() string

func (*PageRequest) Unmarshal 

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

func (*PageRequest) XXX_DiscardUnknown 

func (m *PageRequest) XXX_DiscardUnknown()

func (*PageRequest) XXX_Marshal 

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

func (*PageRequest) XXX_Merge 

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

func (*PageRequest) XXX_Size 

func (m *PageRequest) XXX_Size() int

func (*PageRequest) XXX_Unmarshal 

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

type PageResponse 

type PageResponse struct {
	// if a key is present, that means there are more items from the collection to query, and the given key is the key for
	// the item after the last one returned. if key is nil, that means there are no more items in the collection to query.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

PageResponse represents a response to a paged query.

func (*PageResponse) Descriptor 

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

func (*PageResponse) GetKey 

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

func (*PageResponse) Marshal 

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

func (*PageResponse) MarshalTo 

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

func (*PageResponse) MarshalToSizedBuffer 

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

func (*PageResponse) ProtoMessage 

func (*PageResponse) ProtoMessage()

func (*PageResponse) Reset 

func (m *PageResponse) Reset()

func (*PageResponse) Size 

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

func (*PageResponse) String 

func (m *PageResponse) String() string

func (*PageResponse) Unmarshal 

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

func (*PageResponse) XXX_DiscardUnknown 

func (m *PageResponse) XXX_DiscardUnknown()

func (*PageResponse) XXX_Marshal 

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

func (*PageResponse) XXX_Merge 

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

func (*PageResponse) XXX_Size 

func (m *PageResponse) XXX_Size() int

func (*PageResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	Transactions(ctx context.Context, in *QueryTransactionsRequest, opts ...grpc.CallOption) (*QueryTransactionsResponse, 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 {
	Transactions(context.Context, *QueryTransactionsRequest) (*QueryTransactionsResponse, error)
}

QueryServer is the server API for Query service.

type QueryTransactionsRequest 

type QueryTransactionsRequest struct {
	Namespace string       `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Page      *PageRequest `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
}

func (*QueryTransactionsRequest) Descriptor 

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

func (*QueryTransactionsRequest) GetNamespace 

func (m *QueryTransactionsRequest) GetNamespace() string

func (*QueryTransactionsRequest) GetPage 

func (m *QueryTransactionsRequest) GetPage() *PageRequest

func (*QueryTransactionsRequest) Marshal 

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

func (*QueryTransactionsRequest) MarshalTo 

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

func (*QueryTransactionsRequest) MarshalToSizedBuffer 

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

func (*QueryTransactionsRequest) ProtoMessage 

func (*QueryTransactionsRequest) ProtoMessage()

func (*QueryTransactionsRequest) Reset 

func (m *QueryTransactionsRequest) Reset()

func (*QueryTransactionsRequest) Size 

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

func (*QueryTransactionsRequest) String 

func (m *QueryTransactionsRequest) String() string

func (*QueryTransactionsRequest) Unmarshal 

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

func (*QueryTransactionsRequest) XXX_DiscardUnknown 

func (m *QueryTransactionsRequest) XXX_DiscardUnknown()

func (*QueryTransactionsRequest) XXX_Marshal 

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

func (*QueryTransactionsRequest) XXX_Merge 

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

func (*QueryTransactionsRequest) XXX_Size 

func (m *QueryTransactionsRequest) XXX_Size() int

func (*QueryTransactionsRequest) XXX_Unmarshal 

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

type QueryTransactionsResponse 

type QueryTransactionsResponse struct {
	// epochs contains the transactions. Each entry contains an epoch, and a list of txs that occurred in that epoch.
	Epochs []*Epoch `protobuf:"bytes,1,rep,name=epochs,proto3" json:"epochs,omitempty"`
	// page contains information on how to query the next items in the collection, if any.
	// when page is nil/empty, there is nothing left to query.
	Page *PageResponse `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"`
}

func (*QueryTransactionsResponse) Descriptor 

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

func (*QueryTransactionsResponse) GetEpochs 

func (m *QueryTransactionsResponse) GetEpochs() []*Epoch

func (*QueryTransactionsResponse) GetPage 

func (m *QueryTransactionsResponse) GetPage() *PageResponse

func (*QueryTransactionsResponse) Marshal 

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

func (*QueryTransactionsResponse) MarshalTo 

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

func (*QueryTransactionsResponse) MarshalToSizedBuffer 

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

func (*QueryTransactionsResponse) ProtoMessage 

func (*QueryTransactionsResponse) ProtoMessage()

func (*QueryTransactionsResponse) Reset 

func (m *QueryTransactionsResponse) Reset()

func (*QueryTransactionsResponse) Size 

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

func (*QueryTransactionsResponse) String 

func (m *QueryTransactionsResponse) String() string

func (*QueryTransactionsResponse) Unmarshal 

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

func (*QueryTransactionsResponse) XXX_DiscardUnknown 

func (m *QueryTransactionsResponse) XXX_DiscardUnknown()

func (*QueryTransactionsResponse) XXX_Marshal 

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

func (*QueryTransactionsResponse) XXX_Merge 

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

func (*QueryTransactionsResponse) XXX_Size 

func (m *QueryTransactionsResponse) XXX_Size() int

func (*QueryTransactionsResponse) XXX_Unmarshal 

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

type SubmitShardTxRequest 

type SubmitShardTxRequest struct {
	// sender is the address of the sender. this will be set to the module address.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// namespace is the namespace of the world the transactions originated from.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// epoch is an arbitrary interval that this transaction was executed in.
	// for loop driven games, this is likely a tick. for event driven games,
	// this could be some general period of time.
	Epoch         uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	UnixTimestamp uint64 `protobuf:"varint,4,opt,name=unix_timestamp,json=unixTimestamp,proto3" json:"unix_timestamp,omitempty"`
	// txs are the transactions that occurred in this tick.
	Txs []*Transaction `protobuf:"bytes,5,rep,name=txs,proto3" json:"txs,omitempty"`
}

func (*SubmitShardTxRequest) Descriptor 

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

func (*SubmitShardTxRequest) GetEpoch 

func (m *SubmitShardTxRequest) GetEpoch() uint64

func (*SubmitShardTxRequest) GetNamespace 

func (m *SubmitShardTxRequest) GetNamespace() string

func (*SubmitShardTxRequest) GetSender 

func (m *SubmitShardTxRequest) GetSender() string

func (*SubmitShardTxRequest) GetTxs 

func (m *SubmitShardTxRequest) GetTxs() []*Transaction

func (*SubmitShardTxRequest) GetUnixTimestamp 

func (m *SubmitShardTxRequest) GetUnixTimestamp() uint64

func (*SubmitShardTxRequest) Marshal 

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

func (*SubmitShardTxRequest) MarshalTo 

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

func (*SubmitShardTxRequest) MarshalToSizedBuffer 

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

func (*SubmitShardTxRequest) ProtoMessage 

func (*SubmitShardTxRequest) ProtoMessage()

func (*SubmitShardTxRequest) Reset 

func (m *SubmitShardTxRequest) Reset()

func (*SubmitShardTxRequest) Size 

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

func (*SubmitShardTxRequest) String 

func (m *SubmitShardTxRequest) String() string

func (*SubmitShardTxRequest) Unmarshal 

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

func (*SubmitShardTxRequest) ValidateBasic 

func (m *SubmitShardTxRequest) ValidateBasic() error

func (*SubmitShardTxRequest) XXX_DiscardUnknown 

func (m *SubmitShardTxRequest) XXX_DiscardUnknown()

func (*SubmitShardTxRequest) XXX_Marshal 

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

func (*SubmitShardTxRequest) XXX_Merge 

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

func (*SubmitShardTxRequest) XXX_Size 

func (m *SubmitShardTxRequest) XXX_Size() int

func (*SubmitShardTxRequest) XXX_Unmarshal 

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

type SubmitShardTxResponse 

type SubmitShardTxResponse struct {
}

func (*SubmitShardTxResponse) Descriptor 

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

func (*SubmitShardTxResponse) Marshal 

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

func (*SubmitShardTxResponse) MarshalTo 

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

func (*SubmitShardTxResponse) MarshalToSizedBuffer 

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

func (*SubmitShardTxResponse) ProtoMessage 

func (*SubmitShardTxResponse) ProtoMessage()

func (*SubmitShardTxResponse) Reset 

func (m *SubmitShardTxResponse) Reset()

func (*SubmitShardTxResponse) Size 

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

func (*SubmitShardTxResponse) String 

func (m *SubmitShardTxResponse) String() string

func (*SubmitShardTxResponse) Unmarshal 

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

func (*SubmitShardTxResponse) XXX_DiscardUnknown 

func (m *SubmitShardTxResponse) XXX_DiscardUnknown()

func (*SubmitShardTxResponse) XXX_Marshal 

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

func (*SubmitShardTxResponse) XXX_Merge 

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

func (*SubmitShardTxResponse) XXX_Size 

func (m *SubmitShardTxResponse) XXX_Size() int

func (*SubmitShardTxResponse) XXX_Unmarshal 

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

type Transaction 

type Transaction struct {
	// tx_id is the ID associated with the payloads below. This is needed so we know which transaction struct
	// to unmarshal the payload.Body into.
	TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// game_shard_transaction is an encoded game shard transaction.
	GameShardTransaction []byte `protobuf:"bytes,2,opt,name=game_shard_transaction,json=gameShardTransaction,proto3" json:"game_shard_transaction,omitempty"`
}

func (*Transaction) Descriptor 

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

func (*Transaction) GetGameShardTransaction 

func (m *Transaction) GetGameShardTransaction() []byte

func (*Transaction) GetTxId 

func (m *Transaction) GetTxId() uint64

func (*Transaction) Marshal 

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

func (*Transaction) MarshalTo 

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

func (*Transaction) MarshalToSizedBuffer 

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

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) Reset 

func (m *Transaction) Reset()

func (*Transaction) Size 

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

func (*Transaction) String 

func (m *Transaction) String() string

func (*Transaction) Unmarshal 

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

func (*Transaction) XXX_DiscardUnknown 

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal 

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

func (*Transaction) XXX_Merge 

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

func (*Transaction) XXX_Size 

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SubmitShardTx 

func (*UnimplementedMsgServer) SubmitShardTx(ctx context.Context, req *SubmitShardTxRequest) (*SubmitShardTxResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Transactions 

func (*UnimplementedQueryServer) Transactions(ctx context.Context, req *QueryTransactionsRequest) (*QueryTransactionsResponse, 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.