types

package
v0.48.0-ramus1 Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2023 License: Apache-2.0 Imports: 38 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 = "orda"

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

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName

	ParamsKey = byte(0x00)

	CCStateStoreKey         = byte(0x10)
	QueueTxStateStoreKey    = byte(0x11)
	CCBatchIndexPrefix      = byte(0x12)
	CCQueueTxPrefix         = byte(0x13)
	CCL2HeightToBatchPrefix = byte(0x14)

	SCCStateStoreKey    = byte(0x20)
	SCCMetadataKey      = byte(0x21)
	SCCBatchIndexPrefix = byte(0x22)
)
View Source 
const (
	DefaultCCBatchMaxBytes         uint64 = 1000_000
	DefaultSCCBatchMaxBytes        uint64 = 1000_000
	DefaultMaxQueueTxSize          uint64 = math.MaxUint16
	DefaultMinQueueTxGas           uint64 = 300000
	DefaultQueueTxExpirationWindow uint64 = 600
	DefaultFraudProofWindow        uint64 = 7 * 24 * 60 * 60 / 6
	DefaultSequencerPublishWindow  uint64 = 600
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidLengthDa        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDa          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDa = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidCompressedData    = sdkerrors.Register(ModuleName, 1100, "this data cannot be decompressed.")
	ErrInvalidCCBatch           = sdkerrors.Register(ModuleName, 1101, "invalid cc batch")
	ErrInvalidQueueTx           = sdkerrors.Register(ModuleName, 1102, "invalid queue tx")
	ErrCCStateNotFound          = sdkerrors.Register(ModuleName, 1103, "cc state not found")
	ErrCCRefNotFound            = sdkerrors.Register(ModuleName, 1104, "cc reference not found")
	ErrQueueTxStateNotFound     = sdkerrors.Register(ModuleName, 1105, "queue tx state not found")
	ErrQueueTxNotFound          = sdkerrors.Register(ModuleName, 1106, "queue tx not found")
	ErrL2HeightBatchMapNotFound = sdkerrors.Register(ModuleName, 1107, "this l2 height does not match any processed batches")
)
View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 CompressionOption_name = map[int32]string{
	0: "COMPRESSION_OPTION_UNSPECIFIED",
	1: "COMPRESSION_OPTION_ZLIB",
	2: "COMPRESSION_OPTION_ZSTD",
}
View Source 
var CompressionOption_value = map[string]int32{
	"COMPRESSION_OPTION_UNSPECIFIED": 0,
	"COMPRESSION_OPTION_ZLIB":        1,
	"COMPRESSION_OPTION_ZSTD":        2,
}
View Source 
var QueueTxStatus_name = map[int32]string{
	0: "QUEUE_TX_PENDING",
	1: "QUEUE_TX_SUBMITTED",
	2: "QUEUE_TX_EXPIRED",
}
View Source 
var QueueTxStatus_value = map[string]int32{
	"QUEUE_TX_PENDING":   0,
	"QUEUE_TX_SUBMITTED": 1,
	"QUEUE_TX_EXPIRED":   2,
}

Functions

func GenRollupPrefix 

func GenRollupPrefix(rollupName string, prefix byte) []byte

func GetCCBatchIndexKey 

func GetCCBatchIndexKey(rollupName string, i uint64) []byte

func GetCCL2HeightToBatchKey 

func GetCCL2HeightToBatchKey(rollupName string, l2height uint64) []byte

func GetCCQueueTxKey 

func GetCCQueueTxKey(rollupName string, i uint64) []byte

func GetCCStateStoreKey 

func GetCCStateStoreKey(rollupName string) []byte

func GetQueueTxStateStoreKey 

func GetQueueTxStateStoreKey(rollupName string) []byte

func GetSCCBatchIndexKey 

func GetSCCBatchIndexKey(rollupName string, i uint64) []byte

func GetSCCStateStoreKey 

func GetSCCStateStoreKey(rollupName string) []byte

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SplitPrefixIndexKey 

func SplitPrefixIndexKey(key []byte) (prefix []byte, rollupName string, index uint64)

func SplitPrefixKey 

func SplitPrefixKey(key []byte) (prefix []byte, rollupName string)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetParams(ctx sdk.Context) (params authtypes.Params)
}

type CC 

type CC struct {
	RollupName   string        `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	CCState      CCState       `protobuf:"bytes,2,opt,name=cc_state,json=ccState,proto3" json:"cc_state"`
	History      []CCRef       `protobuf:"bytes,3,rep,name=history,proto3" json:"history"`
	QueueTxState QueueTxState  `protobuf:"bytes,4,opt,name=queue_tx_state,json=queueTxState,proto3" json:"queue_tx_state"`
	QueueList    []L1ToL2Queue `protobuf:"bytes,5,rep,name=queue_list,json=queueList,proto3" json:"queue_list"`
	L2BatchMap   []L2BatchMap  `protobuf:"bytes,6,rep,name=l2_batch_map,json=l2BatchMap,proto3" json:"l2_batch_map"`
}

func (*CC) Descriptor 

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

func (*CC) GetCCState 

func (m *CC) GetCCState() CCState

func (*CC) GetHistory 

func (m *CC) GetHistory() []CCRef

func (*CC) GetL2BatchMap 

func (m *CC) GetL2BatchMap() []L2BatchMap

func (*CC) GetQueueList 

func (m *CC) GetQueueList() []L1ToL2Queue

func (*CC) GetQueueTxState 

func (m *CC) GetQueueTxState() QueueTxState

func (*CC) GetRollupName 

func (m *CC) GetRollupName() string

func (*CC) Marshal 

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

func (*CC) MarshalTo 

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

func (*CC) MarshalToSizedBuffer 

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

func (*CC) ProtoMessage 

func (*CC) ProtoMessage()

func (*CC) Reset 

func (m *CC) Reset()

func (*CC) Size 

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

func (*CC) String 

func (m *CC) String() string

func (*CC) Unmarshal 

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

func (*CC) XXX_DiscardUnknown 

func (m *CC) XXX_DiscardUnknown()

func (*CC) XXX_Marshal 

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

func (*CC) XXX_Merge 

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

func (*CC) XXX_Size 

func (m *CC) XXX_Size() int

func (*CC) XXX_Unmarshal 

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

type CCBatch 

type CCBatch struct {
	// previous total batch frames.
	ShouldStartAtFrame uint64 `protobuf:"varint,1,opt,name=should_start_at_frame,json=shouldStartAtFrame,proto3" json:"should_start_at_frame,omitempty"`
	// One batch frame matches one roll-up block.
	Frames []*CCBatchFrame `protobuf:"bytes,2,rep,name=frames,proto3" json:"frames,omitempty"`
}

CCBatch is a data unit per batch epoch.

func (*CCBatch) Descriptor 

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

func (*CCBatch) GetFrames 

func (m *CCBatch) GetFrames() []*CCBatchFrame

func (*CCBatch) GetShouldStartAtFrame 

func (m *CCBatch) GetShouldStartAtFrame() uint64

func (*CCBatch) Marshal 

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

func (*CCBatch) MarshalTo 

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

func (*CCBatch) MarshalToSizedBuffer 

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

func (*CCBatch) ProtoMessage 

func (*CCBatch) ProtoMessage()

func (*CCBatch) Reset 

func (m *CCBatch) Reset()

func (*CCBatch) Size 

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

func (*CCBatch) String 

func (m *CCBatch) String() string

func (*CCBatch) Unmarshal 

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

func (*CCBatch) XXX_DiscardUnknown 

func (m *CCBatch) XXX_DiscardUnknown()

func (*CCBatch) XXX_Marshal 

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

func (*CCBatch) XXX_Merge 

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

func (*CCBatch) XXX_Size 

func (m *CCBatch) XXX_Size() int

func (*CCBatch) XXX_Unmarshal 

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

type CCBatchElement 

type CCBatchElement struct {
	// SEQUENCER TX ONLY
	Txraw []byte `protobuf:"bytes,1,opt,name=txraw,proto3" json:"txraw,omitempty"`
	// QUEUED TX ONLY
	QueueIndex uint64 `protobuf:"varint,2,opt,name=queue_index,json=queueIndex,proto3" json:"queue_index,omitempty"`
}

func (*CCBatchElement) Descriptor 

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

func (*CCBatchElement) GetQueueIndex 

func (m *CCBatchElement) GetQueueIndex() uint64

func (*CCBatchElement) GetTxraw 

func (m *CCBatchElement) GetTxraw() []byte

func (*CCBatchElement) Marshal 

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

func (*CCBatchElement) MarshalTo 

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

func (*CCBatchElement) MarshalToSizedBuffer 

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

func (*CCBatchElement) ProtoMessage 

func (*CCBatchElement) ProtoMessage()

func (*CCBatchElement) Reset 

func (m *CCBatchElement) Reset()

func (*CCBatchElement) Size 

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

func (*CCBatchElement) String 

func (m *CCBatchElement) String() string

func (*CCBatchElement) Unmarshal 

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

func (*CCBatchElement) XXX_DiscardUnknown 

func (m *CCBatchElement) XXX_DiscardUnknown()

func (*CCBatchElement) XXX_Marshal 

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

func (*CCBatchElement) XXX_Merge 

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

func (*CCBatchElement) XXX_Size 

func (m *CCBatchElement) XXX_Size() int

func (*CCBatchElement) XXX_Unmarshal 

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

type CCBatchFrame 

type CCBatchFrame struct {
	Header   *CCBatchHeader    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Elements []*CCBatchElement `protobuf:"bytes,2,rep,name=elements,proto3" json:"elements,omitempty"`
}

func (*CCBatchFrame) Descriptor 

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

func (*CCBatchFrame) GetElements 

func (m *CCBatchFrame) GetElements() []*CCBatchElement

func (*CCBatchFrame) GetHeader 

func (m *CCBatchFrame) GetHeader() *CCBatchHeader

func (*CCBatchFrame) Marshal 

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

func (*CCBatchFrame) MarshalTo 

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

func (*CCBatchFrame) MarshalToSizedBuffer 

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

func (*CCBatchFrame) ProtoMessage 

func (*CCBatchFrame) ProtoMessage()

func (*CCBatchFrame) Reset 

func (m *CCBatchFrame) Reset()

func (*CCBatchFrame) Size 

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

func (*CCBatchFrame) String 

func (m *CCBatchFrame) String() string

func (*CCBatchFrame) Unmarshal 

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

func (*CCBatchFrame) XXX_DiscardUnknown 

func (m *CCBatchFrame) XXX_DiscardUnknown()

func (*CCBatchFrame) XXX_Marshal 

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

func (*CCBatchFrame) XXX_Merge 

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

func (*CCBatchFrame) XXX_Size 

func (m *CCBatchFrame) XXX_Size() int

func (*CCBatchFrame) XXX_Unmarshal 

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

type CCBatchHeader 

type CCBatchHeader struct {
	// parent_hash is the parent L2 block hash
	ParentHash []byte `protobuf:"bytes,1,opt,name=parent_hash,json=parentHash,proto3" json:"parent_hash,omitempty"`
	// timestamp is the L2 block unix timestamp of the batch.
	Timestamp time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	L2Height  uint64    `protobuf:"varint,3,opt,name=l2_height,json=l2Height,proto3" json:"l2_height,omitempty"`
	// blockNumber is the L1 BlockNumber of the batch.
	L1Height uint64 `protobuf:"varint,4,opt,name=l1_height,json=l1Height,proto3" json:"l1_height,omitempty"`
}

BatchContext denotes a range of transactions that belong the same batch. It is used to compress shared fields that would otherwise be repeated for each transaction.

func (*CCBatchHeader) Descriptor 

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

func (*CCBatchHeader) GetL1Height 

func (m *CCBatchHeader) GetL1Height() uint64

func (*CCBatchHeader) GetL2Height 

func (m *CCBatchHeader) GetL2Height() uint64

func (*CCBatchHeader) GetParentHash 

func (m *CCBatchHeader) GetParentHash() []byte

func (*CCBatchHeader) GetTimestamp 

func (m *CCBatchHeader) GetTimestamp() time.Time

func (*CCBatchHeader) Marshal 

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

func (*CCBatchHeader) MarshalTo 

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

func (*CCBatchHeader) MarshalToSizedBuffer 

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

func (*CCBatchHeader) ProtoMessage 

func (*CCBatchHeader) ProtoMessage()

func (*CCBatchHeader) Reset 

func (m *CCBatchHeader) Reset()

func (*CCBatchHeader) Size 

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

func (*CCBatchHeader) String 

func (m *CCBatchHeader) String() string

func (*CCBatchHeader) Unmarshal 

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

func (*CCBatchHeader) XXX_DiscardUnknown 

func (m *CCBatchHeader) XXX_DiscardUnknown()

func (*CCBatchHeader) XXX_Marshal 

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

func (*CCBatchHeader) XXX_Merge 

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

func (*CCBatchHeader) XXX_Size 

func (m *CCBatchHeader) XXX_Size() int

func (*CCBatchHeader) XXX_Unmarshal 

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

type CCRef 

type CCRef struct {
	// Reference for accessing batch data.
	TxHash []byte `protobuf:"bytes,1,opt,name=txhash,proto3" json:"txhash,omitempty"`
	// Reference for accessing batch data.
	MsgIndex uint32 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty"`
	// Total number of batch frames submitted.
	// It is the same as the height of the L2 block submitted so far
	TotalFrames uint64 `protobuf:"varint,3,opt,name=total_frames,json=totalFrames,proto3" json:"total_frames,omitempty"`
	// Number of batch frames in the batch.
	BatchSize uint32 `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Hash of CompressedCCBatch data.
	BatchRoot []byte `protobuf:"bytes,5,opt,name=batch_root,json=batchRoot,proto3" json:"batch_root,omitempty"`
}

CCRef is a data type that forms an element of the reference chain of Rollup Canonical Chain.

func NewCCRef 

func NewCCRef(txhash []byte, msgIdx, batchSize uint32, totalFrames uint64, batchRoot []byte) *CCRef

func (*CCRef) Descriptor 

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

func (*CCRef) GetBatchRoot 

func (m *CCRef) GetBatchRoot() []byte

func (*CCRef) GetBatchSize 

func (m *CCRef) GetBatchSize() uint32

func (*CCRef) GetMsgIndex 

func (m *CCRef) GetMsgIndex() uint32

func (*CCRef) GetTotalFrames 

func (m *CCRef) GetTotalFrames() uint64

func (*CCRef) GetTxHash 

func (m *CCRef) GetTxHash() []byte

func (*CCRef) Marshal 

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

func (*CCRef) MarshalTo 

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

func (*CCRef) MarshalToSizedBuffer 

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

func (*CCRef) ProtoMessage 

func (*CCRef) ProtoMessage()

func (*CCRef) Reset 

func (m *CCRef) Reset()

func (*CCRef) Size 

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

func (*CCRef) String 

func (m *CCRef) String() string

func (*CCRef) Unmarshal 

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

func (*CCRef) XXX_DiscardUnknown 

func (m *CCRef) XXX_DiscardUnknown()

func (*CCRef) XXX_Marshal 

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

func (*CCRef) XXX_Merge 

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

func (*CCRef) XXX_Size 

func (m *CCRef) XXX_Size() int

func (*CCRef) XXX_Unmarshal 

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

type CCState 

type CCState struct {
	// Assumed to contain all contiguous batches between base and height (inclusive).
	// height is the latest batch height.
	Base   uint64 `protobuf:"varint,1,opt,name=base,proto3" json:"base,omitempty"`
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// The latest batch timestamp.
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	// The latest batch L1 blockNumber.
	L1Height uint64 `protobuf:"varint,4,opt,name=l1_height,json=l1Height,proto3" json:"l1_height,omitempty"`
	// processed_l2block is the last l2block height that has been processed by L1.
	ProcessedL2Block uint64 `protobuf:"varint,5,opt,name=processed_l2block,json=processedL2block,proto3" json:"processed_l2block,omitempty"`
}

BatchChainState is the state of target batch chain.

func (*CCState) Descriptor 

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

func (*CCState) GetBase 

func (m *CCState) GetBase() uint64

func (*CCState) GetHeight 

func (m *CCState) GetHeight() uint64

func (*CCState) GetL1Height 

func (m *CCState) GetL1Height() uint64

func (*CCState) GetProcessedL2Block 

func (m *CCState) GetProcessedL2Block() uint64

func (*CCState) GetTimestamp 

func (m *CCState) GetTimestamp() time.Time

func (*CCState) Marshal 

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

func (*CCState) MarshalTo 

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

func (*CCState) MarshalToSizedBuffer 

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

func (*CCState) ProtoMessage 

func (*CCState) ProtoMessage()

func (*CCState) Reset 

func (m *CCState) Reset()

func (*CCState) Size 

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

func (*CCState) String 

func (m *CCState) String() string

func (*CCState) Unmarshal 

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

func (*CCState) XXX_DiscardUnknown 

func (m *CCState) XXX_DiscardUnknown()

func (*CCState) XXX_Marshal 

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

func (*CCState) XXX_Merge 

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

func (*CCState) XXX_Size 

func (m *CCState) XXX_Size() int

func (*CCState) XXX_Unmarshal 

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

type CompressedCCBatch 

type CompressedCCBatch struct {
	// data is a byte array which is generated by compressing CCBatch using the option below.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// compression is the compression algorithm used for the batch.
	Compression CompressionOption `protobuf:"varint,2,opt,name=compression,proto3,enum=finschia.or.da.v1.CompressionOption" json:"compression,omitempty"`
}

// CompressedCCBatch is used when the sequencer submits.

func (*CompressedCCBatch) Descriptor 

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

func (*CompressedCCBatch) GetCompression 

func (m *CompressedCCBatch) GetCompression() CompressionOption

func (*CompressedCCBatch) GetData 

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

func (*CompressedCCBatch) Marshal 

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

func (*CompressedCCBatch) MarshalTo 

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

func (*CompressedCCBatch) MarshalToSizedBuffer 

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

func (*CompressedCCBatch) ProtoMessage 

func (*CompressedCCBatch) ProtoMessage()

func (*CompressedCCBatch) Reset 

func (m *CompressedCCBatch) Reset()

func (*CompressedCCBatch) Size 

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

func (*CompressedCCBatch) String 

func (m *CompressedCCBatch) String() string

func (*CompressedCCBatch) Unmarshal 

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

func (*CompressedCCBatch) XXX_DiscardUnknown 

func (m *CompressedCCBatch) XXX_DiscardUnknown()

func (*CompressedCCBatch) XXX_Marshal 

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

func (*CompressedCCBatch) XXX_Merge 

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

func (*CompressedCCBatch) XXX_Size 

func (m *CompressedCCBatch) XXX_Size() int

func (*CompressedCCBatch) XXX_Unmarshal 

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

type CompressionOption 

type CompressionOption int32
const (
	// COMPRESSION_OPTION_UNSPECIFIED defines a no-op compress option.
	OptionEmpty CompressionOption = 0
	// Go standard library fo zlib compression (RFC 1950).
	OptionZLIB CompressionOption = 1
	// Zstandard is a fast compression algorithm, providing high compression ratios.
	// It also offers a special mode for small data, called dictionary compression.
	OptionZSTD CompressionOption = 2
)

func (CompressionOption) EnumDescriptor 

func (CompressionOption) EnumDescriptor() ([]byte, []int)

func (CompressionOption) String 

func (x CompressionOption) String() string

type EventAppendCCBatch 

type EventAppendCCBatch struct {
	RollupName          string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	BatchIndex          uint64 `protobuf:"varint,2,opt,name=batch_index,json=batchIndex,proto3" json:"batch_index,omitempty"`
	ProcessedQueueIndex uint64 `protobuf:"varint,3,opt,name=processed_queue_index,json=processedQueueIndex,proto3" json:"processed_queue_index,omitempty"`
	TotalFrames         uint64 `protobuf:"varint,4,opt,name=total_frames,json=totalFrames,proto3" json:"total_frames,omitempty"`
	BatchSize           uint32 `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	BatchHash           []byte `protobuf:"bytes,6,opt,name=batch_hash,json=batchHash,proto3" json:"batch_hash,omitempty"`
	// processed_l2block is the last l2block height that has been processed by L1.
	ProcessedL2Block uint64 `protobuf:"varint,7,opt,name=processed_l2block,json=processedL2block,proto3" json:"processed_l2block,omitempty"`
}

func (*EventAppendCCBatch) Descriptor 

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

func (*EventAppendCCBatch) GetBatchHash 

func (m *EventAppendCCBatch) GetBatchHash() []byte

func (*EventAppendCCBatch) GetBatchIndex 

func (m *EventAppendCCBatch) GetBatchIndex() uint64

func (*EventAppendCCBatch) GetBatchSize 

func (m *EventAppendCCBatch) GetBatchSize() uint32

func (*EventAppendCCBatch) GetProcessedL2Block 

func (m *EventAppendCCBatch) GetProcessedL2Block() uint64

func (*EventAppendCCBatch) GetProcessedQueueIndex 

func (m *EventAppendCCBatch) GetProcessedQueueIndex() uint64

func (*EventAppendCCBatch) GetRollupName 

func (m *EventAppendCCBatch) GetRollupName() string

func (*EventAppendCCBatch) GetTotalFrames 

func (m *EventAppendCCBatch) GetTotalFrames() uint64

func (*EventAppendCCBatch) Marshal 

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

func (*EventAppendCCBatch) MarshalTo 

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

func (*EventAppendCCBatch) MarshalToSizedBuffer 

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

func (*EventAppendCCBatch) ProtoMessage 

func (*EventAppendCCBatch) ProtoMessage()

func (*EventAppendCCBatch) Reset 

func (m *EventAppendCCBatch) Reset()

func (*EventAppendCCBatch) Size 

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

func (*EventAppendCCBatch) String 

func (m *EventAppendCCBatch) String() string

func (*EventAppendCCBatch) Unmarshal 

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

func (*EventAppendCCBatch) XXX_DiscardUnknown 

func (m *EventAppendCCBatch) XXX_DiscardUnknown()

func (*EventAppendCCBatch) XXX_Marshal 

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

func (*EventAppendCCBatch) XXX_Merge 

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

func (*EventAppendCCBatch) XXX_Size 

func (m *EventAppendCCBatch) XXX_Size() int

func (*EventAppendCCBatch) XXX_Unmarshal 

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

type EventSaveQueueTx 

type EventSaveQueueTx struct {
	RollupName       string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	NextQueueIndex   uint64 `protobuf:"varint,2,opt,name=next_queue_index,json=nextQueueIndex,proto3" json:"next_queue_index,omitempty"`
	ExtraConsumedGas uint64 `protobuf:"varint,3,opt,name=extra_consumed_gas,json=extraConsumedGas,proto3" json:"extra_consumed_gas,omitempty"`
	L2GasLimit       uint64 `protobuf:"varint,4,opt,name=l2gas_limit,json=l2gasLimit,proto3" json:"l2gas_limit,omitempty"`
}

func (*EventSaveQueueTx) Descriptor 

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

func (*EventSaveQueueTx) GetExtraConsumedGas 

func (m *EventSaveQueueTx) GetExtraConsumedGas() uint64

func (*EventSaveQueueTx) GetL2GasLimit 

func (m *EventSaveQueueTx) GetL2GasLimit() uint64

func (*EventSaveQueueTx) GetNextQueueIndex 

func (m *EventSaveQueueTx) GetNextQueueIndex() uint64

func (*EventSaveQueueTx) GetRollupName 

func (m *EventSaveQueueTx) GetRollupName() string

func (*EventSaveQueueTx) Marshal 

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

func (*EventSaveQueueTx) MarshalTo 

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

func (*EventSaveQueueTx) MarshalToSizedBuffer 

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

func (*EventSaveQueueTx) ProtoMessage 

func (*EventSaveQueueTx) ProtoMessage()

func (*EventSaveQueueTx) Reset 

func (m *EventSaveQueueTx) Reset()

func (*EventSaveQueueTx) Size 

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

func (*EventSaveQueueTx) String 

func (m *EventSaveQueueTx) String() string

func (*EventSaveQueueTx) Unmarshal 

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

func (*EventSaveQueueTx) XXX_DiscardUnknown 

func (m *EventSaveQueueTx) XXX_DiscardUnknown()

func (*EventSaveQueueTx) XXX_Marshal 

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

func (*EventSaveQueueTx) XXX_Merge 

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

func (*EventSaveQueueTx) XXX_Size 

func (m *EventSaveQueueTx) XXX_Size() int

func (*EventSaveQueueTx) XXX_Unmarshal 

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

type EventUpdateParams 

type EventUpdateParams struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

EventUpdateParams is emitted after updating foundation parameters.

func (*EventUpdateParams) Descriptor 

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

func (*EventUpdateParams) GetParams 

func (m *EventUpdateParams) GetParams() Params

func (*EventUpdateParams) Marshal 

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

func (*EventUpdateParams) MarshalTo 

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

func (*EventUpdateParams) MarshalToSizedBuffer 

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

func (*EventUpdateParams) ProtoMessage 

func (*EventUpdateParams) ProtoMessage()

func (*EventUpdateParams) Reset 

func (m *EventUpdateParams) Reset()

func (*EventUpdateParams) Size 

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

func (*EventUpdateParams) String 

func (m *EventUpdateParams) String() string

func (*EventUpdateParams) Unmarshal 

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

func (*EventUpdateParams) XXX_DiscardUnknown 

func (m *EventUpdateParams) XXX_DiscardUnknown()

func (*EventUpdateParams) XXX_Marshal 

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

func (*EventUpdateParams) XXX_Merge 

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

func (*EventUpdateParams) XXX_Size 

func (m *EventUpdateParams) XXX_Size() int

func (*EventUpdateParams) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params  Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	CCList  []CC   `protobuf:"bytes,2,rep,name=cc_list,json=ccList,proto3" json:"cc_list"`
	SCCList []SCC  `protobuf:"bytes,3,rep,name=scc_list,json=sccList,proto3" json:"scc_list"`
}

GenesisState defines the da module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetCCList 

func (m *GenesisState) GetCCList() []CC

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetSCCList 

func (m *GenesisState) GetSCCList() []SCC

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 L1ToL2Queue 

type L1ToL2Queue struct {
	// timestamp is the L1 unix timestamp of the queue tx.
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	// blockNumber is the L1 BlockNumber when this queue tx was submitted.
	// the queue tx will be expired based on this height.
	L1Height int64         `protobuf:"varint,2,opt,name=l1_height,json=l1Height,proto3" json:"l1_height,omitempty"`
	Txraw    []byte        `protobuf:"bytes,3,opt,name=txraw,proto3" json:"txraw,omitempty"`
	Status   QueueTxStatus `protobuf:"varint,4,opt,name=status,proto3,enum=finschia.or.da.v1.QueueTxStatus" json:"status,omitempty"`
}

L1toL2Queue is a queued tx for L2 batch. Sequencer must process this transaction on time in order. Queue index start from 1.

func (*L1ToL2Queue) Descriptor 

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

func (*L1ToL2Queue) GetL1Height 

func (m *L1ToL2Queue) GetL1Height() int64

func (*L1ToL2Queue) GetStatus 

func (m *L1ToL2Queue) GetStatus() QueueTxStatus

func (*L1ToL2Queue) GetTimestamp 

func (m *L1ToL2Queue) GetTimestamp() time.Time

func (*L1ToL2Queue) GetTxraw 

func (m *L1ToL2Queue) GetTxraw() []byte

func (*L1ToL2Queue) Marshal 

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

func (*L1ToL2Queue) MarshalTo 

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

func (*L1ToL2Queue) MarshalToSizedBuffer 

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

func (*L1ToL2Queue) ProtoMessage 

func (*L1ToL2Queue) ProtoMessage()

func (*L1ToL2Queue) Reset 

func (m *L1ToL2Queue) Reset()

func (*L1ToL2Queue) Size 

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

func (*L1ToL2Queue) String 

func (m *L1ToL2Queue) String() string

func (*L1ToL2Queue) Unmarshal 

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

func (*L1ToL2Queue) XXX_DiscardUnknown 

func (m *L1ToL2Queue) XXX_DiscardUnknown()

func (*L1ToL2Queue) XXX_Marshal 

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

func (*L1ToL2Queue) XXX_Merge 

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

func (*L1ToL2Queue) XXX_Size 

func (m *L1ToL2Queue) XXX_Size() int

func (*L1ToL2Queue) XXX_Unmarshal 

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

type L2BatchMap 

type L2BatchMap struct {
	L2Height uint64 `protobuf:"varint,1,opt,name=l2_height,json=l2Height,proto3" json:"l2_height,omitempty"`
	BatchIdx uint64 `protobuf:"varint,2,opt,name=batch_idx,json=batchIdx,proto3" json:"batch_idx,omitempty"`
}

func (*L2BatchMap) Descriptor 

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

func (*L2BatchMap) GetBatchIdx 

func (m *L2BatchMap) GetBatchIdx() uint64

func (*L2BatchMap) GetL2Height 

func (m *L2BatchMap) GetL2Height() uint64

func (*L2BatchMap) Marshal 

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

func (*L2BatchMap) MarshalTo 

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

func (*L2BatchMap) MarshalToSizedBuffer 

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

func (*L2BatchMap) ProtoMessage 

func (*L2BatchMap) ProtoMessage()

func (*L2BatchMap) Reset 

func (m *L2BatchMap) Reset()

func (*L2BatchMap) Size 

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

func (*L2BatchMap) String 

func (m *L2BatchMap) String() string

func (*L2BatchMap) Unmarshal 

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

func (*L2BatchMap) XXX_DiscardUnknown 

func (m *L2BatchMap) XXX_DiscardUnknown()

func (*L2BatchMap) XXX_Marshal 

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

func (*L2BatchMap) XXX_Merge 

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

func (*L2BatchMap) XXX_Size 

func (m *L2BatchMap) XXX_Size() int

func (*L2BatchMap) XXX_Unmarshal 

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

type MsgAppendCCBatch 

type MsgAppendCCBatch struct {
	// this address must be the sequencer address which is registered in L1.
	FromAddress string            `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	RollupName  string            `protobuf:"bytes,2,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	Batch       CompressedCCBatch `protobuf:"bytes,3,opt,name=batch,proto3" json:"batch"`
}

func (*MsgAppendCCBatch) Descriptor 

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

func (*MsgAppendCCBatch) GetBatch 

func (m *MsgAppendCCBatch) GetBatch() CompressedCCBatch

func (*MsgAppendCCBatch) GetFromAddress 

func (m *MsgAppendCCBatch) GetFromAddress() string

func (*MsgAppendCCBatch) GetRollupName 

func (m *MsgAppendCCBatch) GetRollupName() string

func (MsgAppendCCBatch) GetSignBytes 

func (msg MsgAppendCCBatch) GetSignBytes() []byte

func (MsgAppendCCBatch) GetSigners 

func (msg MsgAppendCCBatch) GetSigners() []sdk.AccAddress

func (*MsgAppendCCBatch) Marshal 

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

func (*MsgAppendCCBatch) MarshalTo 

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

func (*MsgAppendCCBatch) MarshalToSizedBuffer 

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

func (*MsgAppendCCBatch) ProtoMessage 

func (*MsgAppendCCBatch) ProtoMessage()

func (*MsgAppendCCBatch) Reset 

func (m *MsgAppendCCBatch) Reset()

func (MsgAppendCCBatch) Route 

func (msg MsgAppendCCBatch) Route() string

func (*MsgAppendCCBatch) Size 

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

func (*MsgAppendCCBatch) String 

func (m *MsgAppendCCBatch) String() string

func (MsgAppendCCBatch) Type 

func (msg MsgAppendCCBatch) Type() string

func (*MsgAppendCCBatch) Unmarshal 

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

func (MsgAppendCCBatch) ValidateBasic 

func (msg MsgAppendCCBatch) ValidateBasic() error

func (*MsgAppendCCBatch) XXX_DiscardUnknown 

func (m *MsgAppendCCBatch) XXX_DiscardUnknown()

func (*MsgAppendCCBatch) XXX_Marshal 

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

func (*MsgAppendCCBatch) XXX_Merge 

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

func (*MsgAppendCCBatch) XXX_Size 

func (m *MsgAppendCCBatch) XXX_Size() int

func (*MsgAppendCCBatch) XXX_Unmarshal 

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

type MsgAppendCCBatchResponse 

type MsgAppendCCBatchResponse struct {
}

func (*MsgAppendCCBatchResponse) Descriptor 

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

func (*MsgAppendCCBatchResponse) Marshal 

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

func (*MsgAppendCCBatchResponse) MarshalTo 

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

func (*MsgAppendCCBatchResponse) MarshalToSizedBuffer 

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

func (*MsgAppendCCBatchResponse) ProtoMessage 

func (*MsgAppendCCBatchResponse) ProtoMessage()

func (*MsgAppendCCBatchResponse) Reset 

func (m *MsgAppendCCBatchResponse) Reset()

func (*MsgAppendCCBatchResponse) Size 

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

func (*MsgAppendCCBatchResponse) String 

func (m *MsgAppendCCBatchResponse) String() string

func (*MsgAppendCCBatchResponse) Unmarshal 

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

func (*MsgAppendCCBatchResponse) XXX_DiscardUnknown 

func (m *MsgAppendCCBatchResponse) XXX_DiscardUnknown()

func (*MsgAppendCCBatchResponse) XXX_Marshal 

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

func (*MsgAppendCCBatchResponse) XXX_Merge 

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

func (*MsgAppendCCBatchResponse) XXX_Size 

func (m *MsgAppendCCBatchResponse) XXX_Size() int

func (*MsgAppendCCBatchResponse) XXX_Unmarshal 

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

type MsgAppendSCCBatch 

type MsgAppendSCCBatch struct {
	FromAddress string   `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	RollupName  string   `protobuf:"bytes,2,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	Batch       SCCBatch `protobuf:"bytes,3,opt,name=batch,proto3" json:"batch"`
}

func (*MsgAppendSCCBatch) Descriptor 

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

func (*MsgAppendSCCBatch) GetBatch 

func (m *MsgAppendSCCBatch) GetBatch() SCCBatch

func (*MsgAppendSCCBatch) GetFromAddress 

func (m *MsgAppendSCCBatch) GetFromAddress() string

func (*MsgAppendSCCBatch) GetRollupName 

func (m *MsgAppendSCCBatch) GetRollupName() string

func (MsgAppendSCCBatch) GetSignBytes 

func (msg MsgAppendSCCBatch) GetSignBytes() []byte

func (MsgAppendSCCBatch) GetSigners 

func (msg MsgAppendSCCBatch) GetSigners() []sdk.AccAddress

func (*MsgAppendSCCBatch) Marshal 

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

func (*MsgAppendSCCBatch) MarshalTo 

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

func (*MsgAppendSCCBatch) MarshalToSizedBuffer 

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

func (*MsgAppendSCCBatch) ProtoMessage 

func (*MsgAppendSCCBatch) ProtoMessage()

func (*MsgAppendSCCBatch) Reset 

func (m *MsgAppendSCCBatch) Reset()

func (MsgAppendSCCBatch) Route 

func (msg MsgAppendSCCBatch) Route() string

func (*MsgAppendSCCBatch) Size 

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

func (*MsgAppendSCCBatch) String 

func (m *MsgAppendSCCBatch) String() string

func (MsgAppendSCCBatch) Type 

func (msg MsgAppendSCCBatch) Type() string

func (*MsgAppendSCCBatch) Unmarshal 

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

func (MsgAppendSCCBatch) ValidateBasic 

func (msg MsgAppendSCCBatch) ValidateBasic() error

func (*MsgAppendSCCBatch) XXX_DiscardUnknown 

func (m *MsgAppendSCCBatch) XXX_DiscardUnknown()

func (*MsgAppendSCCBatch) XXX_Marshal 

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

func (*MsgAppendSCCBatch) XXX_Merge 

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

func (*MsgAppendSCCBatch) XXX_Size 

func (m *MsgAppendSCCBatch) XXX_Size() int

func (*MsgAppendSCCBatch) XXX_Unmarshal 

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

type MsgAppendSCCBatchResponse 

type MsgAppendSCCBatchResponse struct {
}

func (*MsgAppendSCCBatchResponse) Descriptor 

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

func (*MsgAppendSCCBatchResponse) Marshal 

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

func (*MsgAppendSCCBatchResponse) MarshalTo 

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

func (*MsgAppendSCCBatchResponse) MarshalToSizedBuffer 

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

func (*MsgAppendSCCBatchResponse) ProtoMessage 

func (*MsgAppendSCCBatchResponse) ProtoMessage()

func (*MsgAppendSCCBatchResponse) Reset 

func (m *MsgAppendSCCBatchResponse) Reset()

func (*MsgAppendSCCBatchResponse) Size 

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

func (*MsgAppendSCCBatchResponse) String 

func (m *MsgAppendSCCBatchResponse) String() string

func (*MsgAppendSCCBatchResponse) Unmarshal 

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

func (*MsgAppendSCCBatchResponse) XXX_DiscardUnknown 

func (m *MsgAppendSCCBatchResponse) XXX_DiscardUnknown()

func (*MsgAppendSCCBatchResponse) XXX_Marshal 

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

func (*MsgAppendSCCBatchResponse) XXX_Merge 

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

func (*MsgAppendSCCBatchResponse) XXX_Size 

func (m *MsgAppendSCCBatchResponse) XXX_Size() int

func (*MsgAppendSCCBatchResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	// Allow the sequencer to append a batch of transactions.
	AppendCCBatch(ctx context.Context, in *MsgAppendCCBatch, opts ...grpc.CallOption) (*MsgAppendCCBatchResponse, error)
	// Add a L2 transaction to the queue to process forcibly.
	Enqueue(ctx context.Context, in *MsgEnqueue, opts ...grpc.CallOption) (*MsgEnqueueResponse, error)
	// Allow the proposer to append a state batch
	AppendSCCBatch(ctx context.Context, in *MsgAppendSCCBatch, opts ...grpc.CallOption) (*MsgAppendSCCBatchResponse, error)
	// Removes a batch and all subsequent batches from SCC.
	RemoveSCCBatch(ctx context.Context, in *MsgRemoveSCCBatch, opts ...grpc.CallOption) (*MsgRemoveSCCBatchResponse, 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 MsgEnqueue 

type MsgEnqueue struct {
	FromAddress string `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	RollupName  string `protobuf:"bytes,2,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	// When sequencer processes that queue tx, it uses this gas limit and submits tx to L2.
	GasLimit uint64 `protobuf:"varint,3,opt,name=gas_limit,json=gasLimit,proto3" json:"gas_limit,omitempty"`
	Txraw    []byte `protobuf:"bytes,4,opt,name=txraw,proto3" json:"txraw,omitempty"`
}

func (*MsgEnqueue) Descriptor 

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

func (*MsgEnqueue) GetFromAddress 

func (m *MsgEnqueue) GetFromAddress() string

func (*MsgEnqueue) GetGasLimit 

func (m *MsgEnqueue) GetGasLimit() uint64

func (*MsgEnqueue) GetRollupName 

func (m *MsgEnqueue) GetRollupName() string

func (MsgEnqueue) GetSignBytes 

func (msg MsgEnqueue) GetSignBytes() []byte

func (MsgEnqueue) GetSigners 

func (msg MsgEnqueue) GetSigners() []sdk.AccAddress

func (*MsgEnqueue) GetTxraw 

func (m *MsgEnqueue) GetTxraw() []byte

func (*MsgEnqueue) Marshal 

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

func (*MsgEnqueue) MarshalTo 

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

func (*MsgEnqueue) MarshalToSizedBuffer 

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

func (*MsgEnqueue) ProtoMessage 

func (*MsgEnqueue) ProtoMessage()

func (*MsgEnqueue) Reset 

func (m *MsgEnqueue) Reset()

func (MsgEnqueue) Route 

func (msg MsgEnqueue) Route() string

func (*MsgEnqueue) Size 

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

func (*MsgEnqueue) String 

func (m *MsgEnqueue) String() string

func (MsgEnqueue) Type 

func (msg MsgEnqueue) Type() string

func (*MsgEnqueue) Unmarshal 

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

func (MsgEnqueue) ValidateBasic 

func (msg MsgEnqueue) ValidateBasic() error

func (*MsgEnqueue) XXX_DiscardUnknown 

func (m *MsgEnqueue) XXX_DiscardUnknown()

func (*MsgEnqueue) XXX_Marshal 

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

func (*MsgEnqueue) XXX_Merge 

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

func (*MsgEnqueue) XXX_Size 

func (m *MsgEnqueue) XXX_Size() int

func (*MsgEnqueue) XXX_Unmarshal 

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

type MsgEnqueueResponse 

type MsgEnqueueResponse struct {
}

func (*MsgEnqueueResponse) Descriptor 

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

func (*MsgEnqueueResponse) Marshal 

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

func (*MsgEnqueueResponse) MarshalTo 

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

func (*MsgEnqueueResponse) MarshalToSizedBuffer 

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

func (*MsgEnqueueResponse) ProtoMessage 

func (*MsgEnqueueResponse) ProtoMessage()

func (*MsgEnqueueResponse) Reset 

func (m *MsgEnqueueResponse) Reset()

func (*MsgEnqueueResponse) Size 

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

func (*MsgEnqueueResponse) String 

func (m *MsgEnqueueResponse) String() string

func (*MsgEnqueueResponse) Unmarshal 

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

func (*MsgEnqueueResponse) XXX_DiscardUnknown 

func (m *MsgEnqueueResponse) XXX_DiscardUnknown()

func (*MsgEnqueueResponse) XXX_Marshal 

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

func (*MsgEnqueueResponse) XXX_Merge 

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

func (*MsgEnqueueResponse) XXX_Size 

func (m *MsgEnqueueResponse) XXX_Size() int

func (*MsgEnqueueResponse) XXX_Unmarshal 

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

type MsgRemoveSCCBatch 

type MsgRemoveSCCBatch struct {
	// authority must be settlement module address.
	Authority  string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	RollupName string `protobuf:"bytes,2,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	BatchIndex uint64 `protobuf:"varint,3,opt,name=batch_index,json=batchIndex,proto3" json:"batch_index,omitempty"`
}

func (*MsgRemoveSCCBatch) Descriptor 

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

func (*MsgRemoveSCCBatch) GetAuthority 

func (m *MsgRemoveSCCBatch) GetAuthority() string

func (*MsgRemoveSCCBatch) GetBatchIndex 

func (m *MsgRemoveSCCBatch) GetBatchIndex() uint64

func (*MsgRemoveSCCBatch) GetRollupName 

func (m *MsgRemoveSCCBatch) GetRollupName() string

func (MsgRemoveSCCBatch) GetSignBytes 

func (msg MsgRemoveSCCBatch) GetSignBytes() []byte

func (MsgRemoveSCCBatch) GetSigners 

func (msg MsgRemoveSCCBatch) GetSigners() []sdk.AccAddress

func (*MsgRemoveSCCBatch) Marshal 

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

func (*MsgRemoveSCCBatch) MarshalTo 

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

func (*MsgRemoveSCCBatch) MarshalToSizedBuffer 

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

func (*MsgRemoveSCCBatch) ProtoMessage 

func (*MsgRemoveSCCBatch) ProtoMessage()

func (*MsgRemoveSCCBatch) Reset 

func (m *MsgRemoveSCCBatch) Reset()

func (MsgRemoveSCCBatch) Route 

func (msg MsgRemoveSCCBatch) Route() string

func (*MsgRemoveSCCBatch) Size 

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

func (*MsgRemoveSCCBatch) String 

func (m *MsgRemoveSCCBatch) String() string

func (MsgRemoveSCCBatch) Type 

func (msg MsgRemoveSCCBatch) Type() string

func (*MsgRemoveSCCBatch) Unmarshal 

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

func (MsgRemoveSCCBatch) ValidateBasic 

func (msg MsgRemoveSCCBatch) ValidateBasic() error

func (*MsgRemoveSCCBatch) XXX_DiscardUnknown 

func (m *MsgRemoveSCCBatch) XXX_DiscardUnknown()

func (*MsgRemoveSCCBatch) XXX_Marshal 

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

func (*MsgRemoveSCCBatch) XXX_Merge 

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

func (*MsgRemoveSCCBatch) XXX_Size 

func (m *MsgRemoveSCCBatch) XXX_Size() int

func (*MsgRemoveSCCBatch) XXX_Unmarshal 

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

type MsgRemoveSCCBatchResponse 

type MsgRemoveSCCBatchResponse struct {
}

func (*MsgRemoveSCCBatchResponse) Descriptor 

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

func (*MsgRemoveSCCBatchResponse) Marshal 

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

func (*MsgRemoveSCCBatchResponse) MarshalTo 

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

func (*MsgRemoveSCCBatchResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveSCCBatchResponse) ProtoMessage 

func (*MsgRemoveSCCBatchResponse) ProtoMessage()

func (*MsgRemoveSCCBatchResponse) Reset 

func (m *MsgRemoveSCCBatchResponse) Reset()

func (*MsgRemoveSCCBatchResponse) Size 

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

func (*MsgRemoveSCCBatchResponse) String 

func (m *MsgRemoveSCCBatchResponse) String() string

func (*MsgRemoveSCCBatchResponse) Unmarshal 

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

func (*MsgRemoveSCCBatchResponse) XXX_DiscardUnknown 

func (m *MsgRemoveSCCBatchResponse) XXX_DiscardUnknown()

func (*MsgRemoveSCCBatchResponse) XXX_Marshal 

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

func (*MsgRemoveSCCBatchResponse) XXX_Merge 

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

func (*MsgRemoveSCCBatchResponse) XXX_Size 

func (m *MsgRemoveSCCBatchResponse) XXX_Size() int

func (*MsgRemoveSCCBatchResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	// Allow the sequencer to append a batch of transactions.
	AppendCCBatch(context.Context, *MsgAppendCCBatch) (*MsgAppendCCBatchResponse, error)
	// Add a L2 transaction to the queue to process forcibly.
	Enqueue(context.Context, *MsgEnqueue) (*MsgEnqueueResponse, error)
	// Allow the proposer to append a state batch
	AppendSCCBatch(context.Context, *MsgAppendSCCBatch) (*MsgAppendSCCBatchResponse, error)
	// Removes a batch and all subsequent batches from SCC.
	RemoveSCCBatch(context.Context, *MsgRemoveSCCBatch) (*MsgRemoveSCCBatchResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/or/da parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

func NewMsgUpdateParams 

func NewMsgUpdateParams(params Params, authority sdk.AccAddress) *MsgUpdateParams

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (MsgUpdateParams) GetSignBytes 

func (msg MsgUpdateParams) GetSignBytes() []byte

func (MsgUpdateParams) GetSigners 

func (msg MsgUpdateParams) GetSigners() []sdk.AccAddress

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (MsgUpdateParams) Route 

func (msg MsgUpdateParams) Route() string

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (MsgUpdateParams) Type 

func (msg MsgUpdateParams) Type() string

func (*MsgUpdateParams) Unmarshal 

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

func (MsgUpdateParams) ValidateBasic deprecated 

func (msg MsgUpdateParams) ValidateBasic() error

Deprecated: those methods will be removed after merge the upstream. move ValidateBasic to msg server, please refer to https://github.com/cosmos/cosmos-sdk/issues/15648

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// 1. CC-related
	CCBatchMaxBytes uint64 `protobuf:"varint,1,opt,name=cc_batch_max_bytes,json=ccBatchMaxBytes,proto3" json:"cc_batch_max_bytes,omitempty"`
	// max_queue_tx_size is the maximum queue tx size that can be submitted.
	MaxQueueTxSize uint64 `protobuf:"varint,2,opt,name=max_queue_tx_size,json=maxQueueTxSize,proto3" json:"max_queue_tx_size,omitempty"`
	// min_queue_tx_gas is the minimum gas that must be specified for a queue tx.
	MinQueueTxGas uint64 `protobuf:"varint,3,opt,name=min_queue_tx_gas,json=minQueueTxGas,proto3" json:"min_queue_tx_gas,omitempty"`
	// l2gas_discount_divisor is the ratio between the cost of gas on L1 and L2.
	// This is a positive integer, meaning we assume L2 gas is always less costly.
	L2GasDiscountDivisor uint64 `protobuf:"varint,4,opt,name=l2gas_discount_divisor,json=l2gasDiscountDivisor,proto3" json:"l2gas_discount_divisor,omitempty"`
	// enqueue_l2gas_prepaid is the base cost of calling enqueue function.
	EnqueueL2GasPrepaid uint64 `protobuf:"varint,5,opt,name=enqueue_l2gas_prepaid,json=enqueueL2gasPrepaid,proto3" json:"enqueue_l2gas_prepaid,omitempty"`
	// A sequencer must submit a queue tx to L2 before this time.
	QueueTxExpirationWindow uint64 `` /* 135-byte string literal not displayed */
	// 2. SCC-related
	SCCBatchMaxBytes uint64 `protobuf:"varint,7,opt,name=scc_batch_max_bytes,json=sccBatchMaxBytes,proto3" json:"scc_batch_max_bytes,omitempty"`
	// Number of seconds that the verifier is allowed to submit a fraud proof.
	// Currnet scc batch header timestamp + fraud_proof_window = challenge period
	FraudProofWindow uint64 `protobuf:"varint,8,opt,name=fraud_proof_window,json=fraudProofWindow,proto3" json:"fraud_proof_window,omitempty"`
	// Number of seconds that the sequencer is exclusively allowed to post state roots
	SequencerPublishWindow uint64 `` /* 130-byte string literal not displayed */
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	CCBatchMaxBytes uint64,
	MaxQueueTxSize uint64,
	MinQueueTxGas uint64,
	QueueTxExpirationWindow uint64,
	SCCBatchMaxBytes uint64,
	FraudProofWindow uint64,
	SequencerPublishWindow uint64,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetCCBatchMaxBytes 

func (m *Params) GetCCBatchMaxBytes() uint64

func (*Params) GetEnqueueL2GasPrepaid 

func (m *Params) GetEnqueueL2GasPrepaid() uint64

func (*Params) GetFraudProofWindow 

func (m *Params) GetFraudProofWindow() uint64

func (*Params) GetL2GasDiscountDivisor 

func (m *Params) GetL2GasDiscountDivisor() uint64

func (*Params) GetMaxQueueTxSize 

func (m *Params) GetMaxQueueTxSize() uint64

func (*Params) GetMinQueueTxGas 

func (m *Params) GetMinQueueTxGas() uint64

func (*Params) GetQueueTxExpirationWindow 

func (m *Params) GetQueueTxExpirationWindow() uint64

func (*Params) GetSCCBatchMaxBytes 

func (m *Params) GetSCCBatchMaxBytes() uint64

func (*Params) GetSequencerPublishWindow 

func (m *Params) GetSequencerPublishWindow() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryCCRefRequest 

type QueryCCRefRequest struct {
	RollupName  string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	BatchHeight uint64 `protobuf:"varint,2,opt,name=batch_height,json=batchHeight,proto3" json:"batch_height,omitempty"`
}

func (*QueryCCRefRequest) Descriptor 

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

func (*QueryCCRefRequest) GetBatchHeight 

func (m *QueryCCRefRequest) GetBatchHeight() uint64

func (*QueryCCRefRequest) GetRollupName 

func (m *QueryCCRefRequest) GetRollupName() string

func (*QueryCCRefRequest) Marshal 

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

func (*QueryCCRefRequest) MarshalTo 

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

func (*QueryCCRefRequest) MarshalToSizedBuffer 

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

func (*QueryCCRefRequest) ProtoMessage 

func (*QueryCCRefRequest) ProtoMessage()

func (*QueryCCRefRequest) Reset 

func (m *QueryCCRefRequest) Reset()

func (*QueryCCRefRequest) Size 

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

func (*QueryCCRefRequest) String 

func (m *QueryCCRefRequest) String() string

func (*QueryCCRefRequest) Unmarshal 

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

func (*QueryCCRefRequest) XXX_DiscardUnknown 

func (m *QueryCCRefRequest) XXX_DiscardUnknown()

func (*QueryCCRefRequest) XXX_Marshal 

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

func (*QueryCCRefRequest) XXX_Merge 

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

func (*QueryCCRefRequest) XXX_Size 

func (m *QueryCCRefRequest) XXX_Size() int

func (*QueryCCRefRequest) XXX_Unmarshal 

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

type QueryCCRefResponse 

type QueryCCRefResponse struct {
	Ref *CCRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
}

func (*QueryCCRefResponse) Descriptor 

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

func (*QueryCCRefResponse) GetRef 

func (m *QueryCCRefResponse) GetRef() *CCRef

func (*QueryCCRefResponse) Marshal 

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

func (*QueryCCRefResponse) MarshalTo 

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

func (*QueryCCRefResponse) MarshalToSizedBuffer 

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

func (*QueryCCRefResponse) ProtoMessage 

func (*QueryCCRefResponse) ProtoMessage()

func (*QueryCCRefResponse) Reset 

func (m *QueryCCRefResponse) Reset()

func (*QueryCCRefResponse) Size 

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

func (*QueryCCRefResponse) String 

func (m *QueryCCRefResponse) String() string

func (*QueryCCRefResponse) Unmarshal 

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

func (*QueryCCRefResponse) XXX_DiscardUnknown 

func (m *QueryCCRefResponse) XXX_DiscardUnknown()

func (*QueryCCRefResponse) XXX_Marshal 

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

func (*QueryCCRefResponse) XXX_Merge 

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

func (*QueryCCRefResponse) XXX_Size 

func (m *QueryCCRefResponse) XXX_Size() int

func (*QueryCCRefResponse) XXX_Unmarshal 

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

type QueryCCRefsRequest 

type QueryCCRefsRequest struct {
	RollupName string             `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryCCRefsRequest) Descriptor 

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

func (*QueryCCRefsRequest) GetPagination 

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

func (*QueryCCRefsRequest) GetRollupName 

func (m *QueryCCRefsRequest) GetRollupName() string

func (*QueryCCRefsRequest) Marshal 

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

func (*QueryCCRefsRequest) MarshalTo 

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

func (*QueryCCRefsRequest) MarshalToSizedBuffer 

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

func (*QueryCCRefsRequest) ProtoMessage 

func (*QueryCCRefsRequest) ProtoMessage()

func (*QueryCCRefsRequest) Reset 

func (m *QueryCCRefsRequest) Reset()

func (*QueryCCRefsRequest) Size 

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

func (*QueryCCRefsRequest) String 

func (m *QueryCCRefsRequest) String() string

func (*QueryCCRefsRequest) Unmarshal 

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

func (*QueryCCRefsRequest) XXX_DiscardUnknown 

func (m *QueryCCRefsRequest) XXX_DiscardUnknown()

func (*QueryCCRefsRequest) XXX_Marshal 

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

func (*QueryCCRefsRequest) XXX_Merge 

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

func (*QueryCCRefsRequest) XXX_Size 

func (m *QueryCCRefsRequest) XXX_Size() int

func (*QueryCCRefsRequest) XXX_Unmarshal 

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

type QueryCCRefsResponse 

type QueryCCRefsResponse struct {
	Refs       []*CCRef            `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryCCRefsResponse) Descriptor 

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

func (*QueryCCRefsResponse) GetPagination 

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

func (*QueryCCRefsResponse) GetRefs 

func (m *QueryCCRefsResponse) GetRefs() []*CCRef

func (*QueryCCRefsResponse) Marshal 

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

func (*QueryCCRefsResponse) MarshalTo 

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

func (*QueryCCRefsResponse) MarshalToSizedBuffer 

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

func (*QueryCCRefsResponse) ProtoMessage 

func (*QueryCCRefsResponse) ProtoMessage()

func (*QueryCCRefsResponse) Reset 

func (m *QueryCCRefsResponse) Reset()

func (*QueryCCRefsResponse) Size 

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

func (*QueryCCRefsResponse) String 

func (m *QueryCCRefsResponse) String() string

func (*QueryCCRefsResponse) Unmarshal 

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

func (*QueryCCRefsResponse) XXX_DiscardUnknown 

func (m *QueryCCRefsResponse) XXX_DiscardUnknown()

func (*QueryCCRefsResponse) XXX_Marshal 

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

func (*QueryCCRefsResponse) XXX_Merge 

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

func (*QueryCCRefsResponse) XXX_Size 

func (m *QueryCCRefsResponse) XXX_Size() int

func (*QueryCCRefsResponse) XXX_Unmarshal 

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

type QueryCCStateRequest 

type QueryCCStateRequest struct {
	RollupName string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
}

func (*QueryCCStateRequest) Descriptor 

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

func (*QueryCCStateRequest) GetRollupName 

func (m *QueryCCStateRequest) GetRollupName() string

func (*QueryCCStateRequest) Marshal 

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

func (*QueryCCStateRequest) MarshalTo 

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

func (*QueryCCStateRequest) MarshalToSizedBuffer 

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

func (*QueryCCStateRequest) ProtoMessage 

func (*QueryCCStateRequest) ProtoMessage()

func (*QueryCCStateRequest) Reset 

func (m *QueryCCStateRequest) Reset()

func (*QueryCCStateRequest) Size 

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

func (*QueryCCStateRequest) String 

func (m *QueryCCStateRequest) String() string

func (*QueryCCStateRequest) Unmarshal 

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

func (*QueryCCStateRequest) XXX_DiscardUnknown 

func (m *QueryCCStateRequest) XXX_DiscardUnknown()

func (*QueryCCStateRequest) XXX_Marshal 

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

func (*QueryCCStateRequest) XXX_Merge 

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

func (*QueryCCStateRequest) XXX_Size 

func (m *QueryCCStateRequest) XXX_Size() int

func (*QueryCCStateRequest) XXX_Unmarshal 

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

type QueryCCStateResponse 

type QueryCCStateResponse struct {
	State *CCState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
}

func (*QueryCCStateResponse) Descriptor 

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

func (*QueryCCStateResponse) GetState 

func (m *QueryCCStateResponse) GetState() *CCState

func (*QueryCCStateResponse) Marshal 

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

func (*QueryCCStateResponse) MarshalTo 

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

func (*QueryCCStateResponse) MarshalToSizedBuffer 

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

func (*QueryCCStateResponse) ProtoMessage 

func (*QueryCCStateResponse) ProtoMessage()

func (*QueryCCStateResponse) Reset 

func (m *QueryCCStateResponse) Reset()

func (*QueryCCStateResponse) Size 

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

func (*QueryCCStateResponse) String 

func (m *QueryCCStateResponse) String() string

func (*QueryCCStateResponse) Unmarshal 

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

func (*QueryCCStateResponse) XXX_DiscardUnknown 

func (m *QueryCCStateResponse) XXX_DiscardUnknown()

func (*QueryCCStateResponse) XXX_Marshal 

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

func (*QueryCCStateResponse) XXX_Merge 

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

func (*QueryCCStateResponse) XXX_Size 

func (m *QueryCCStateResponse) XXX_Size() int

func (*QueryCCStateResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the parameters of the or/da module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// CCState queries the CC state for specific rollup
	CCState(ctx context.Context, in *QueryCCStateRequest, opts ...grpc.CallOption) (*QueryCCStateResponse, error)
	// CCRef queries the CC batch reference at the given batch height for specific rollup
	CCRef(ctx context.Context, in *QueryCCRefRequest, opts ...grpc.CallOption) (*QueryCCRefResponse, error)
	// CCRefs queries all the CC batch references for specific rollup
	CCRefs(ctx context.Context, in *QueryCCRefsRequest, opts ...grpc.CallOption) (*QueryCCRefsResponse, error)
	// QueueTxState queries the L1-to-L2 queue state
	QueueTxState(ctx context.Context, in *QueryQueueTxStateRequest, opts ...grpc.CallOption) (*QueryQueueTxStateResponse, error)
	// QueueTx queries the L1-to-L2 queue transaction at the given index
	QueueTx(ctx context.Context, in *QueryQueueTxRequest, opts ...grpc.CallOption) (*QueryQueueTxResponse, error)
	// QueueTx queries the L1-to-L2 queue transaction at the given index
	QueueTxs(ctx context.Context, in *QueryQueueTxsRequest, opts ...grpc.CallOption) (*QueryQueueTxsResponse, error)
	// MappedBatch queries the CC batch reference containing the corresponding L2 block height
	MappedBatch(ctx context.Context, in *QueryMappedBatchRequest, opts ...grpc.CallOption) (*QueryMappedBatchResponse, 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 QueryMappedBatchRequest 

type QueryMappedBatchRequest struct {
	RollupName string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	L2Height   uint64 `protobuf:"varint,2,opt,name=l2_height,json=l2Height,proto3" json:"l2_height,omitempty"`
}

func (*QueryMappedBatchRequest) Descriptor 

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

func (*QueryMappedBatchRequest) GetL2Height 

func (m *QueryMappedBatchRequest) GetL2Height() uint64

func (*QueryMappedBatchRequest) GetRollupName 

func (m *QueryMappedBatchRequest) GetRollupName() string

func (*QueryMappedBatchRequest) Marshal 

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

func (*QueryMappedBatchRequest) MarshalTo 

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

func (*QueryMappedBatchRequest) MarshalToSizedBuffer 

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

func (*QueryMappedBatchRequest) ProtoMessage 

func (*QueryMappedBatchRequest) ProtoMessage()

func (*QueryMappedBatchRequest) Reset 

func (m *QueryMappedBatchRequest) Reset()

func (*QueryMappedBatchRequest) Size 

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

func (*QueryMappedBatchRequest) String 

func (m *QueryMappedBatchRequest) String() string

func (*QueryMappedBatchRequest) Unmarshal 

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

func (*QueryMappedBatchRequest) XXX_DiscardUnknown 

func (m *QueryMappedBatchRequest) XXX_DiscardUnknown()

func (*QueryMappedBatchRequest) XXX_Marshal 

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

func (*QueryMappedBatchRequest) XXX_Merge 

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

func (*QueryMappedBatchRequest) XXX_Size 

func (m *QueryMappedBatchRequest) XXX_Size() int

func (*QueryMappedBatchRequest) XXX_Unmarshal 

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

type QueryMappedBatchResponse 

type QueryMappedBatchResponse struct {
	Ref *CCRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
}

func (*QueryMappedBatchResponse) Descriptor 

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

func (*QueryMappedBatchResponse) GetRef 

func (m *QueryMappedBatchResponse) GetRef() *CCRef

func (*QueryMappedBatchResponse) Marshal 

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

func (*QueryMappedBatchResponse) MarshalTo 

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

func (*QueryMappedBatchResponse) MarshalToSizedBuffer 

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

func (*QueryMappedBatchResponse) ProtoMessage 

func (*QueryMappedBatchResponse) ProtoMessage()

func (*QueryMappedBatchResponse) Reset 

func (m *QueryMappedBatchResponse) Reset()

func (*QueryMappedBatchResponse) Size 

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

func (*QueryMappedBatchResponse) String 

func (m *QueryMappedBatchResponse) String() string

func (*QueryMappedBatchResponse) Unmarshal 

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

func (*QueryMappedBatchResponse) XXX_DiscardUnknown 

func (m *QueryMappedBatchResponse) XXX_DiscardUnknown()

func (*QueryMappedBatchResponse) XXX_Marshal 

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

func (*QueryMappedBatchResponse) XXX_Merge 

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

func (*QueryMappedBatchResponse) XXX_Size 

func (m *QueryMappedBatchResponse) XXX_Size() int

func (*QueryMappedBatchResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryQueueTxRequest 

type QueryQueueTxRequest struct {
	RollupName string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	QueueIndex uint64 `protobuf:"varint,2,opt,name=queue_index,json=queueIndex,proto3" json:"queue_index,omitempty"`
}

func (*QueryQueueTxRequest) Descriptor 

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

func (*QueryQueueTxRequest) GetQueueIndex 

func (m *QueryQueueTxRequest) GetQueueIndex() uint64

func (*QueryQueueTxRequest) GetRollupName 

func (m *QueryQueueTxRequest) GetRollupName() string

func (*QueryQueueTxRequest) Marshal 

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

func (*QueryQueueTxRequest) MarshalTo 

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

func (*QueryQueueTxRequest) MarshalToSizedBuffer 

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

func (*QueryQueueTxRequest) ProtoMessage 

func (*QueryQueueTxRequest) ProtoMessage()

func (*QueryQueueTxRequest) Reset 

func (m *QueryQueueTxRequest) Reset()

func (*QueryQueueTxRequest) Size 

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

func (*QueryQueueTxRequest) String 

func (m *QueryQueueTxRequest) String() string

func (*QueryQueueTxRequest) Unmarshal 

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

func (*QueryQueueTxRequest) XXX_DiscardUnknown 

func (m *QueryQueueTxRequest) XXX_DiscardUnknown()

func (*QueryQueueTxRequest) XXX_Marshal 

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

func (*QueryQueueTxRequest) XXX_Merge 

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

func (*QueryQueueTxRequest) XXX_Size 

func (m *QueryQueueTxRequest) XXX_Size() int

func (*QueryQueueTxRequest) XXX_Unmarshal 

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

type QueryQueueTxResponse 

type QueryQueueTxResponse struct {
	Tx *L1ToL2Queue `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
}

func (*QueryQueueTxResponse) Descriptor 

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

func (*QueryQueueTxResponse) GetTx 

func (m *QueryQueueTxResponse) GetTx() *L1ToL2Queue

func (*QueryQueueTxResponse) Marshal 

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

func (*QueryQueueTxResponse) MarshalTo 

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

func (*QueryQueueTxResponse) MarshalToSizedBuffer 

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

func (*QueryQueueTxResponse) ProtoMessage 

func (*QueryQueueTxResponse) ProtoMessage()

func (*QueryQueueTxResponse) Reset 

func (m *QueryQueueTxResponse) Reset()

func (*QueryQueueTxResponse) Size 

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

func (*QueryQueueTxResponse) String 

func (m *QueryQueueTxResponse) String() string

func (*QueryQueueTxResponse) Unmarshal 

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

func (*QueryQueueTxResponse) XXX_DiscardUnknown 

func (m *QueryQueueTxResponse) XXX_DiscardUnknown()

func (*QueryQueueTxResponse) XXX_Marshal 

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

func (*QueryQueueTxResponse) XXX_Merge 

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

func (*QueryQueueTxResponse) XXX_Size 

func (m *QueryQueueTxResponse) XXX_Size() int

func (*QueryQueueTxResponse) XXX_Unmarshal 

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

type QueryQueueTxStateRequest 

type QueryQueueTxStateRequest struct {
	RollupName string `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
}

func (*QueryQueueTxStateRequest) Descriptor 

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

func (*QueryQueueTxStateRequest) GetRollupName 

func (m *QueryQueueTxStateRequest) GetRollupName() string

func (*QueryQueueTxStateRequest) Marshal 

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

func (*QueryQueueTxStateRequest) MarshalTo 

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

func (*QueryQueueTxStateRequest) MarshalToSizedBuffer 

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

func (*QueryQueueTxStateRequest) ProtoMessage 

func (*QueryQueueTxStateRequest) ProtoMessage()

func (*QueryQueueTxStateRequest) Reset 

func (m *QueryQueueTxStateRequest) Reset()

func (*QueryQueueTxStateRequest) Size 

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

func (*QueryQueueTxStateRequest) String 

func (m *QueryQueueTxStateRequest) String() string

func (*QueryQueueTxStateRequest) Unmarshal 

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

func (*QueryQueueTxStateRequest) XXX_DiscardUnknown 

func (m *QueryQueueTxStateRequest) XXX_DiscardUnknown()

func (*QueryQueueTxStateRequest) XXX_Marshal 

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

func (*QueryQueueTxStateRequest) XXX_Merge 

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

func (*QueryQueueTxStateRequest) XXX_Size 

func (m *QueryQueueTxStateRequest) XXX_Size() int

func (*QueryQueueTxStateRequest) XXX_Unmarshal 

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

type QueryQueueTxStateResponse 

type QueryQueueTxStateResponse struct {
	State *QueueTxState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
}

func (*QueryQueueTxStateResponse) Descriptor 

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

func (*QueryQueueTxStateResponse) GetState 

func (m *QueryQueueTxStateResponse) GetState() *QueueTxState

func (*QueryQueueTxStateResponse) Marshal 

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

func (*QueryQueueTxStateResponse) MarshalTo 

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

func (*QueryQueueTxStateResponse) MarshalToSizedBuffer 

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

func (*QueryQueueTxStateResponse) ProtoMessage 

func (*QueryQueueTxStateResponse) ProtoMessage()

func (*QueryQueueTxStateResponse) Reset 

func (m *QueryQueueTxStateResponse) Reset()

func (*QueryQueueTxStateResponse) Size 

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

func (*QueryQueueTxStateResponse) String 

func (m *QueryQueueTxStateResponse) String() string

func (*QueryQueueTxStateResponse) Unmarshal 

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

func (*QueryQueueTxStateResponse) XXX_DiscardUnknown 

func (m *QueryQueueTxStateResponse) XXX_DiscardUnknown()

func (*QueryQueueTxStateResponse) XXX_Marshal 

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

func (*QueryQueueTxStateResponse) XXX_Merge 

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

func (*QueryQueueTxStateResponse) XXX_Size 

func (m *QueryQueueTxStateResponse) XXX_Size() int

func (*QueryQueueTxStateResponse) XXX_Unmarshal 

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

type QueryQueueTxsRequest 

type QueryQueueTxsRequest struct {
	RollupName string             `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryQueueTxsRequest) Descriptor 

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

func (*QueryQueueTxsRequest) GetPagination 

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

func (*QueryQueueTxsRequest) GetRollupName 

func (m *QueryQueueTxsRequest) GetRollupName() string

func (*QueryQueueTxsRequest) Marshal 

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

func (*QueryQueueTxsRequest) MarshalTo 

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

func (*QueryQueueTxsRequest) MarshalToSizedBuffer 

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

func (*QueryQueueTxsRequest) ProtoMessage 

func (*QueryQueueTxsRequest) ProtoMessage()

func (*QueryQueueTxsRequest) Reset 

func (m *QueryQueueTxsRequest) Reset()

func (*QueryQueueTxsRequest) Size 

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

func (*QueryQueueTxsRequest) String 

func (m *QueryQueueTxsRequest) String() string

func (*QueryQueueTxsRequest) Unmarshal 

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

func (*QueryQueueTxsRequest) XXX_DiscardUnknown 

func (m *QueryQueueTxsRequest) XXX_DiscardUnknown()

func (*QueryQueueTxsRequest) XXX_Marshal 

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

func (*QueryQueueTxsRequest) XXX_Merge 

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

func (*QueryQueueTxsRequest) XXX_Size 

func (m *QueryQueueTxsRequest) XXX_Size() int

func (*QueryQueueTxsRequest) XXX_Unmarshal 

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

type QueryQueueTxsResponse 

type QueryQueueTxsResponse struct {
	Txs        []*L1ToL2Queue      `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryQueueTxsResponse) Descriptor 

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

func (*QueryQueueTxsResponse) GetPagination 

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

func (*QueryQueueTxsResponse) GetTxs 

func (m *QueryQueueTxsResponse) GetTxs() []*L1ToL2Queue

func (*QueryQueueTxsResponse) Marshal 

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

func (*QueryQueueTxsResponse) MarshalTo 

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

func (*QueryQueueTxsResponse) MarshalToSizedBuffer 

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

func (*QueryQueueTxsResponse) ProtoMessage 

func (*QueryQueueTxsResponse) ProtoMessage()

func (*QueryQueueTxsResponse) Reset 

func (m *QueryQueueTxsResponse) Reset()

func (*QueryQueueTxsResponse) Size 

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

func (*QueryQueueTxsResponse) String 

func (m *QueryQueueTxsResponse) String() string

func (*QueryQueueTxsResponse) Unmarshal 

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

func (*QueryQueueTxsResponse) XXX_DiscardUnknown 

func (m *QueryQueueTxsResponse) XXX_DiscardUnknown()

func (*QueryQueueTxsResponse) XXX_Marshal 

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

func (*QueryQueueTxsResponse) XXX_Merge 

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

func (*QueryQueueTxsResponse) XXX_Size 

func (m *QueryQueueTxsResponse) XXX_Size() int

func (*QueryQueueTxsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the parameters of the or/da module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// CCState queries the CC state for specific rollup
	CCState(context.Context, *QueryCCStateRequest) (*QueryCCStateResponse, error)
	// CCRef queries the CC batch reference at the given batch height for specific rollup
	CCRef(context.Context, *QueryCCRefRequest) (*QueryCCRefResponse, error)
	// CCRefs queries all the CC batch references for specific rollup
	CCRefs(context.Context, *QueryCCRefsRequest) (*QueryCCRefsResponse, error)
	// QueueTxState queries the L1-to-L2 queue state
	QueueTxState(context.Context, *QueryQueueTxStateRequest) (*QueryQueueTxStateResponse, error)
	// QueueTx queries the L1-to-L2 queue transaction at the given index
	QueueTx(context.Context, *QueryQueueTxRequest) (*QueryQueueTxResponse, error)
	// QueueTx queries the L1-to-L2 queue transaction at the given index
	QueueTxs(context.Context, *QueryQueueTxsRequest) (*QueryQueueTxsResponse, error)
	// MappedBatch queries the CC batch reference containing the corresponding L2 block height
	MappedBatch(context.Context, *QueryMappedBatchRequest) (*QueryMappedBatchResponse, error)
}

QueryServer is the server API for Query service.

type QueueTxState 

type QueueTxState struct {
	// Index of the processed queue element.
	// Queue elements up to this index were submitted via CC batch or timeout.
	ProcessedQueueIndex uint64 `protobuf:"varint,1,opt,name=processed_queue_index,json=processedQueueIndex,proto3" json:"processed_queue_index,omitempty"`
	// Index of the next queue element.
	NextQueueIndex uint64 `protobuf:"varint,2,opt,name=next_queue_index,json=nextQueueIndex,proto3" json:"next_queue_index,omitempty"`
}

func (*QueueTxState) Descriptor 

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

func (*QueueTxState) GetNextQueueIndex 

func (m *QueueTxState) GetNextQueueIndex() uint64

func (*QueueTxState) GetProcessedQueueIndex 

func (m *QueueTxState) GetProcessedQueueIndex() uint64

func (*QueueTxState) Marshal 

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

func (*QueueTxState) MarshalTo 

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

func (*QueueTxState) MarshalToSizedBuffer 

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

func (*QueueTxState) ProtoMessage 

func (*QueueTxState) ProtoMessage()

func (*QueueTxState) Reset 

func (m *QueueTxState) Reset()

func (*QueueTxState) Size 

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

func (*QueueTxState) String 

func (m *QueueTxState) String() string

func (*QueueTxState) Unmarshal 

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

func (*QueueTxState) XXX_DiscardUnknown 

func (m *QueueTxState) XXX_DiscardUnknown()

func (*QueueTxState) XXX_Marshal 

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

func (*QueueTxState) XXX_Merge 

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

func (*QueueTxState) XXX_Size 

func (m *QueueTxState) XXX_Size() int

func (*QueueTxState) XXX_Unmarshal 

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

type QueueTxStatus 

type QueueTxStatus int32
const (
	// QUEUE_TX_PENDING defines the status where the Tx has not been submitted to L1 batch yet.
	QUEUE_TX_PENDING QueueTxStatus = 0
	// QUEUE_TX_SUBMITTED defines the status where the Tx has been submitted to L1 batch.
	QUEUE_TX_SUBMITTED QueueTxStatus = 1
	// QUEUE_TX_EXPIRED defines the status where the Tx has not been submitted until the expiration deadline.
	// Sequencers get penalty if queued txs reach this status.
	QUEUE_TX_EXPIRED QueueTxStatus = 2
)

func (QueueTxStatus) EnumDescriptor 

func (QueueTxStatus) EnumDescriptor() ([]byte, []int)

func (QueueTxStatus) String 

func (x QueueTxStatus) String() string

type RollupInfo 

type RollupInfo struct {
	ID string

	// The ratio between the cost of gas on L1 and L2.
	// This is a positive integer.
	L1ToL2GasRatio uint64
}

type RollupKeeper 

type RollupKeeper interface {
	GetRollup(ctx sdk.Context, name string) (rolluptypes.Rollup, bool)
	GetRegisteredRollups(ctx sdk.Context) []string
}

type SCC 

type SCC struct {
	RollupName string   `protobuf:"bytes,1,opt,name=rollup_name,json=rollupName,proto3" json:"rollup_name,omitempty"`
	State      SCCState `protobuf:"bytes,2,opt,name=state,proto3" json:"state"`
	History    []SCCRef `protobuf:"bytes,3,rep,name=history,proto3" json:"history"`
}

func (*SCC) Descriptor 

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

func (*SCC) GetHistory 

func (m *SCC) GetHistory() []SCCRef

func (*SCC) GetRollupName 

func (m *SCC) GetRollupName() string

func (*SCC) GetState 

func (m *SCC) GetState() SCCState

func (*SCC) Marshal 

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

func (*SCC) MarshalTo 

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

func (*SCC) MarshalToSizedBuffer 

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

func (*SCC) ProtoMessage 

func (*SCC) ProtoMessage()

func (*SCC) Reset 

func (m *SCC) Reset()

func (*SCC) Size 

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

func (*SCC) String 

func (m *SCC) String() string

func (*SCC) Unmarshal 

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

func (*SCC) XXX_DiscardUnknown 

func (m *SCC) XXX_DiscardUnknown()

func (*SCC) XXX_Marshal 

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

func (*SCC) XXX_Merge 

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

func (*SCC) XXX_Size 

func (m *SCC) XXX_Size() int

func (*SCC) XXX_Unmarshal 

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

type SCCBatch 

type SCCBatch struct {
	// previous total batch frames.
	ShouldStartAtFrame uint64 `protobuf:"varint,1,opt,name=should_start_at_frame,json=shouldStartAtFrame,proto3" json:"should_start_at_frame,omitempty"`
	// IntermediateStateRoots for a specific range of CCs.
	// len(IntermediateStateRoots) = len(CCBatchFrame) * (len(CCBatchElement) + 2)
	// BeginBlock + DeliverTX for each CCBatchElement + EndBlock
	IntermediateStateRoots [][]byte `protobuf:"bytes,2,rep,name=IntermediateStateRoots,proto3" json:"IntermediateStateRoots,omitempty"`
}

Proposer use SCCBatch when they submit.

func (*SCCBatch) Descriptor 

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

func (*SCCBatch) GetIntermediateStateRoots 

func (m *SCCBatch) GetIntermediateStateRoots() [][]byte

func (*SCCBatch) GetShouldStartAtFrame 

func (m *SCCBatch) GetShouldStartAtFrame() uint64

func (*SCCBatch) Marshal 

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

func (*SCCBatch) MarshalTo 

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

func (*SCCBatch) MarshalToSizedBuffer 

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

func (*SCCBatch) ProtoMessage 

func (*SCCBatch) ProtoMessage()

func (*SCCBatch) Reset 

func (m *SCCBatch) Reset()

func (*SCCBatch) Size 

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

func (*SCCBatch) String 

func (m *SCCBatch) String() string

func (*SCCBatch) Unmarshal 

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

func (*SCCBatch) XXX_DiscardUnknown 

func (m *SCCBatch) XXX_DiscardUnknown()

func (*SCCBatch) XXX_Marshal 

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

func (*SCCBatch) XXX_Merge 

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

func (*SCCBatch) XXX_Size 

func (m *SCCBatch) XXX_Size() int

func (*SCCBatch) XXX_Unmarshal 

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

type SCCRef 

type SCCRef struct {
	// Reference for accessing batch data.
	TotalFrames uint64 `protobuf:"varint,1,opt,name=total_frames,json=totalFrames,proto3" json:"total_frames,omitempty"`
	// Number of batch frames in the batch.
	BatchSize uint32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// timestamp is data to determine if this batch is within the challenge period.
	Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	// Merkle Root of IntermediateStateRoots.
	BatchRoot              []byte   `protobuf:"bytes,4,opt,name=batch_root,json=batchRoot,proto3" json:"batch_root,omitempty"`
	IntermediateStateRoots [][]byte `protobuf:"bytes,5,rep,name=IntermediateStateRoots,proto3" json:"IntermediateStateRoots,omitempty"`
}

SCCRef is a data type that forms an element of State Commitment Chain.

func (*SCCRef) Descriptor 

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

func (*SCCRef) GetBatchRoot 

func (m *SCCRef) GetBatchRoot() []byte

func (*SCCRef) GetBatchSize 

func (m *SCCRef) GetBatchSize() uint32

func (*SCCRef) GetIntermediateStateRoots 

func (m *SCCRef) GetIntermediateStateRoots() [][]byte

func (*SCCRef) GetTimestamp 

func (m *SCCRef) GetTimestamp() time.Time

func (*SCCRef) GetTotalFrames 

func (m *SCCRef) GetTotalFrames() uint64

func (*SCCRef) Marshal 

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

func (*SCCRef) MarshalTo 

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

func (*SCCRef) MarshalToSizedBuffer 

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

func (*SCCRef) ProtoMessage 

func (*SCCRef) ProtoMessage()

func (*SCCRef) Reset 

func (m *SCCRef) Reset()

func (*SCCRef) Size 

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

func (*SCCRef) String 

func (m *SCCRef) String() string

func (*SCCRef) Unmarshal 

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

func (*SCCRef) XXX_DiscardUnknown 

func (m *SCCRef) XXX_DiscardUnknown()

func (*SCCRef) XXX_Marshal 

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

func (*SCCRef) XXX_Merge 

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

func (*SCCRef) XXX_Size 

func (m *SCCRef) XXX_Size() int

func (*SCCRef) XXX_Unmarshal 

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

type SCCState 

type SCCState struct {
	// Assumed to contain all contiguous batches between base and height (inclusive).
	Base   uint64 `protobuf:"varint,1,opt,name=base,proto3" json:"base,omitempty"`
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// The latest batch timestamp when the sequencer submits.
	LastSequencerSubmit time.Time `protobuf:"bytes,3,opt,name=last_sequencer_submit,json=lastSequencerSubmit,proto3,stdtime" json:"last_sequencer_submit"`
}

BatchChainState is the state of target batch chain.

func (*SCCState) Descriptor 

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

func (*SCCState) GetBase 

func (m *SCCState) GetBase() uint64

func (*SCCState) GetHeight 

func (m *SCCState) GetHeight() uint64

func (*SCCState) GetLastSequencerSubmit 

func (m *SCCState) GetLastSequencerSubmit() time.Time

func (*SCCState) Marshal 

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

func (*SCCState) MarshalTo 

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

func (*SCCState) MarshalToSizedBuffer 

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

func (*SCCState) ProtoMessage 

func (*SCCState) ProtoMessage()

func (*SCCState) Reset 

func (m *SCCState) Reset()

func (*SCCState) Size 

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

func (*SCCState) String 

func (m *SCCState) String() string

func (*SCCState) Unmarshal 

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

func (*SCCState) XXX_DiscardUnknown 

func (m *SCCState) XXX_DiscardUnknown()

func (*SCCState) XXX_Marshal 

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

func (*SCCState) XXX_Merge 

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

func (*SCCState) XXX_Size 

func (m *SCCState) XXX_Size() int

func (*SCCState) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AppendCCBatch 

func (*UnimplementedMsgServer) AppendCCBatch(ctx context.Context, req *MsgAppendCCBatch) (*MsgAppendCCBatchResponse, error)

func (*UnimplementedMsgServer) AppendSCCBatch 

func (*UnimplementedMsgServer) AppendSCCBatch(ctx context.Context, req *MsgAppendSCCBatch) (*MsgAppendSCCBatchResponse, error)

func (*UnimplementedMsgServer) Enqueue 

func (*UnimplementedMsgServer) Enqueue(ctx context.Context, req *MsgEnqueue) (*MsgEnqueueResponse, error)

func (*UnimplementedMsgServer) RemoveSCCBatch 

func (*UnimplementedMsgServer) RemoveSCCBatch(ctx context.Context, req *MsgRemoveSCCBatch) (*MsgRemoveSCCBatchResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CCRef 

func (*UnimplementedQueryServer) CCRef(ctx context.Context, req *QueryCCRefRequest) (*QueryCCRefResponse, error)

func (*UnimplementedQueryServer) CCRefs 

func (*UnimplementedQueryServer) CCRefs(ctx context.Context, req *QueryCCRefsRequest) (*QueryCCRefsResponse, error)

func (*UnimplementedQueryServer) CCState 

func (*UnimplementedQueryServer) CCState(ctx context.Context, req *QueryCCStateRequest) (*QueryCCStateResponse, error)

func (*UnimplementedQueryServer) MappedBatch 

func (*UnimplementedQueryServer) MappedBatch(ctx context.Context, req *QueryMappedBatchRequest) (*QueryMappedBatchResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) QueueTx 

func (*UnimplementedQueryServer) QueueTx(ctx context.Context, req *QueryQueueTxRequest) (*QueryQueueTxResponse, error)

func (*UnimplementedQueryServer) QueueTxState 

func (*UnimplementedQueryServer) QueueTxState(ctx context.Context, req *QueryQueueTxStateRequest) (*QueryQueueTxStateResponse, error)

func (*UnimplementedQueryServer) QueueTxs 

func (*UnimplementedQueryServer) QueueTxs(ctx context.Context, req *QueryQueueTxsRequest) (*QueryQueueTxsResponse, 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.