sequencing

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSequencing        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSequencing          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSequencing = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BatchVerifier_serviceDesc = _BatchVerifier_serviceDesc
View Source 
var SequencerInput_serviceDesc = _SequencerInput_serviceDesc
View Source 
var SequencerOutput_serviceDesc = _SequencerOutput_serviceDesc

Functions

func RegisterBatchVerifierServer 

func RegisterBatchVerifierServer(s grpc1.Server, srv BatchVerifierServer)

func RegisterSequencerInputServer 

func RegisterSequencerInputServer(s grpc1.Server, srv SequencerInputServer)

func RegisterSequencerOutputServer 

func RegisterSequencerOutputServer(s grpc1.Server, srv SequencerOutputServer)

Types

type Batch 

type Batch struct {
	Transactions [][]byte `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
}

Batch holds a list of transactions

func (*Batch) Descriptor 

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

func (*Batch) GetTransactions 

func (m *Batch) GetTransactions() [][]byte

func (*Batch) Marshal 

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

func (*Batch) MarshalTo 

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

func (*Batch) MarshalToSizedBuffer 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) Size 

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

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) Unmarshal 

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

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type BatchVerifierClient 

type BatchVerifierClient interface {
	// VerifyBatch ...
	VerifyBatch(ctx context.Context, in *VerifyBatchRequest, opts ...grpc.CallOption) (*VerifyBatchResponse, error)
}

BatchVerifierClient is the client API for BatchVerifier service.

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

func NewBatchVerifierClient 

func NewBatchVerifierClient(cc grpc1.ClientConn) BatchVerifierClient

type BatchVerifierServer 

type BatchVerifierServer interface {
	// VerifyBatch ...
	VerifyBatch(context.Context, *VerifyBatchRequest) (*VerifyBatchResponse, error)
}

BatchVerifierServer is the server API for BatchVerifier service.

type GetNextBatchRequest 

type GetNextBatchRequest struct {
	// Merkle tree hash of the last batch
	LastBatchHash []byte `protobuf:"bytes,1,opt,name=last_batch_hash,json=lastBatchHash,proto3" json:"last_batch_hash,omitempty"`
}

GetNextBatchRequest ...

func (*GetNextBatchRequest) Descriptor 

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

func (*GetNextBatchRequest) GetLastBatchHash 

func (m *GetNextBatchRequest) GetLastBatchHash() []byte

func (*GetNextBatchRequest) Marshal 

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

func (*GetNextBatchRequest) MarshalTo 

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

func (*GetNextBatchRequest) MarshalToSizedBuffer 

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

func (*GetNextBatchRequest) ProtoMessage 

func (*GetNextBatchRequest) ProtoMessage()

func (*GetNextBatchRequest) Reset 

func (m *GetNextBatchRequest) Reset()

func (*GetNextBatchRequest) Size 

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

func (*GetNextBatchRequest) String 

func (m *GetNextBatchRequest) String() string

func (*GetNextBatchRequest) Unmarshal 

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

func (*GetNextBatchRequest) XXX_DiscardUnknown 

func (m *GetNextBatchRequest) XXX_DiscardUnknown()

func (*GetNextBatchRequest) XXX_Marshal 

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

func (*GetNextBatchRequest) XXX_Merge 

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

func (*GetNextBatchRequest) XXX_Size 

func (m *GetNextBatchRequest) XXX_Size() int

func (*GetNextBatchRequest) XXX_Unmarshal 

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

type GetNextBatchResponse 

type GetNextBatchResponse struct {
	Batch     *Batch           `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

GetNextBatchResponse ...

func (*GetNextBatchResponse) Descriptor 

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

func (*GetNextBatchResponse) GetBatch 

func (m *GetNextBatchResponse) GetBatch() *Batch

func (*GetNextBatchResponse) GetTimestamp 

func (m *GetNextBatchResponse) GetTimestamp() *types.Timestamp

func (*GetNextBatchResponse) Marshal 

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

func (*GetNextBatchResponse) MarshalTo 

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

func (*GetNextBatchResponse) MarshalToSizedBuffer 

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

func (*GetNextBatchResponse) ProtoMessage 

func (*GetNextBatchResponse) ProtoMessage()

func (*GetNextBatchResponse) Reset 

func (m *GetNextBatchResponse) Reset()

func (*GetNextBatchResponse) Size 

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

func (*GetNextBatchResponse) String 

func (m *GetNextBatchResponse) String() string

func (*GetNextBatchResponse) Unmarshal 

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

func (*GetNextBatchResponse) XXX_DiscardUnknown 

func (m *GetNextBatchResponse) XXX_DiscardUnknown()

func (*GetNextBatchResponse) XXX_Marshal 

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

func (*GetNextBatchResponse) XXX_Merge 

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

func (*GetNextBatchResponse) XXX_Size 

func (m *GetNextBatchResponse) XXX_Size() int

func (*GetNextBatchResponse) XXX_Unmarshal 

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

type SequencerInputClient 

type SequencerInputClient interface {
	// SubmitRollupTransaction ...
	SubmitRollupTransaction(ctx context.Context, in *SubmitRollupTransactionRequest, opts ...grpc.CallOption) (*SubmitRollupTransactionResponse, error)
}

SequencerInputClient is the client API for SequencerInput service.

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

func NewSequencerInputClient 

func NewSequencerInputClient(cc grpc1.ClientConn) SequencerInputClient

type SequencerInputServer 

type SequencerInputServer interface {
	// SubmitRollupTransaction ...
	SubmitRollupTransaction(context.Context, *SubmitRollupTransactionRequest) (*SubmitRollupTransactionResponse, error)
}

SequencerInputServer is the server API for SequencerInput service.

type SequencerOutputClient 

type SequencerOutputClient interface {
	// GetNextBatch ...
	GetNextBatch(ctx context.Context, in *GetNextBatchRequest, opts ...grpc.CallOption) (*GetNextBatchResponse, error)
}

SequencerOutputClient is the client API for SequencerOutput service.

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

func NewSequencerOutputClient 

func NewSequencerOutputClient(cc grpc1.ClientConn) SequencerOutputClient

type SequencerOutputServer 

type SequencerOutputServer interface {
	// GetNextBatch ...
	GetNextBatch(context.Context, *GetNextBatchRequest) (*GetNextBatchResponse, error)
}

SequencerOutputServer is the server API for SequencerOutput service.

type SubmitRollupTransactionRequest 

type SubmitRollupTransactionRequest struct {
	// the unhashed rollup id
	RollupId []byte `protobuf:"bytes,1,opt,name=rollup_id,json=rollupId,proto3" json:"rollup_id,omitempty"`
	// the raw data bytes of the rollup transaction
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

SubmitRollupTransactionRequest ...

func (*SubmitRollupTransactionRequest) Descriptor 

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

func (*SubmitRollupTransactionRequest) GetData 

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

func (*SubmitRollupTransactionRequest) GetRollupId 

func (m *SubmitRollupTransactionRequest) GetRollupId() []byte

func (*SubmitRollupTransactionRequest) Marshal 

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

func (*SubmitRollupTransactionRequest) MarshalTo 

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

func (*SubmitRollupTransactionRequest) MarshalToSizedBuffer 

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

func (*SubmitRollupTransactionRequest) ProtoMessage 

func (*SubmitRollupTransactionRequest) ProtoMessage()

func (*SubmitRollupTransactionRequest) Reset 

func (m *SubmitRollupTransactionRequest) Reset()

func (*SubmitRollupTransactionRequest) Size 

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

func (*SubmitRollupTransactionRequest) String 

func (m *SubmitRollupTransactionRequest) String() string

func (*SubmitRollupTransactionRequest) Unmarshal 

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

func (*SubmitRollupTransactionRequest) XXX_DiscardUnknown 

func (m *SubmitRollupTransactionRequest) XXX_DiscardUnknown()

func (*SubmitRollupTransactionRequest) XXX_Marshal 

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

func (*SubmitRollupTransactionRequest) XXX_Merge 

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

func (*SubmitRollupTransactionRequest) XXX_Size 

func (m *SubmitRollupTransactionRequest) XXX_Size() int

func (*SubmitRollupTransactionRequest) XXX_Unmarshal 

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

type SubmitRollupTransactionResponse 

type SubmitRollupTransactionResponse struct {
}

SubmitRollupTransactionResponse ...

func (*SubmitRollupTransactionResponse) Descriptor 

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

func (*SubmitRollupTransactionResponse) Marshal 

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

func (*SubmitRollupTransactionResponse) MarshalTo 

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

func (*SubmitRollupTransactionResponse) MarshalToSizedBuffer 

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

func (*SubmitRollupTransactionResponse) ProtoMessage 

func (*SubmitRollupTransactionResponse) ProtoMessage()

func (*SubmitRollupTransactionResponse) Reset 

func (m *SubmitRollupTransactionResponse) Reset()

func (*SubmitRollupTransactionResponse) Size 

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

func (*SubmitRollupTransactionResponse) String 

func (m *SubmitRollupTransactionResponse) String() string

func (*SubmitRollupTransactionResponse) Unmarshal 

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

func (*SubmitRollupTransactionResponse) XXX_DiscardUnknown 

func (m *SubmitRollupTransactionResponse) XXX_DiscardUnknown()

func (*SubmitRollupTransactionResponse) XXX_Marshal 

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

func (*SubmitRollupTransactionResponse) XXX_Merge 

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

func (*SubmitRollupTransactionResponse) XXX_Size 

func (m *SubmitRollupTransactionResponse) XXX_Size() int

func (*SubmitRollupTransactionResponse) XXX_Unmarshal 

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

type UnimplementedBatchVerifierServer 

type UnimplementedBatchVerifierServer struct {
}

UnimplementedBatchVerifierServer can be embedded to have forward compatible implementations.

func (*UnimplementedBatchVerifierServer) VerifyBatch 

func (*UnimplementedBatchVerifierServer) VerifyBatch(ctx context.Context, req *VerifyBatchRequest) (*VerifyBatchResponse, error)

type UnimplementedSequencerInputServer 

type UnimplementedSequencerInputServer struct {
}

UnimplementedSequencerInputServer can be embedded to have forward compatible implementations.

func (*UnimplementedSequencerInputServer) SubmitRollupTransaction 

func (*UnimplementedSequencerInputServer) SubmitRollupTransaction(ctx context.Context, req *SubmitRollupTransactionRequest) (*SubmitRollupTransactionResponse, error)

type UnimplementedSequencerOutputServer 

type UnimplementedSequencerOutputServer struct {
}

UnimplementedSequencerOutputServer can be embedded to have forward compatible implementations.

func (*UnimplementedSequencerOutputServer) GetNextBatch 

func (*UnimplementedSequencerOutputServer) GetNextBatch(ctx context.Context, req *GetNextBatchRequest) (*GetNextBatchResponse, error)

type VerifyBatchRequest 

type VerifyBatchRequest struct {
	// Merkle tree hash of the batch
	BatchHash []byte `protobuf:"bytes,1,opt,name=batch_hash,json=batchHash,proto3" json:"batch_hash,omitempty"`
}

VerifyBatchRequest ...

func (*VerifyBatchRequest) Descriptor 

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

func (*VerifyBatchRequest) GetBatchHash 

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

func (*VerifyBatchRequest) Marshal 

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

func (*VerifyBatchRequest) MarshalTo 

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

func (*VerifyBatchRequest) MarshalToSizedBuffer 

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

func (*VerifyBatchRequest) ProtoMessage 

func (*VerifyBatchRequest) ProtoMessage()

func (*VerifyBatchRequest) Reset 

func (m *VerifyBatchRequest) Reset()

func (*VerifyBatchRequest) Size 

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

func (*VerifyBatchRequest) String 

func (m *VerifyBatchRequest) String() string

func (*VerifyBatchRequest) Unmarshal 

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

func (*VerifyBatchRequest) XXX_DiscardUnknown 

func (m *VerifyBatchRequest) XXX_DiscardUnknown()

func (*VerifyBatchRequest) XXX_Marshal 

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

func (*VerifyBatchRequest) XXX_Merge 

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

func (*VerifyBatchRequest) XXX_Size 

func (m *VerifyBatchRequest) XXX_Size() int

func (*VerifyBatchRequest) XXX_Unmarshal 

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

type VerifyBatchResponse 

type VerifyBatchResponse struct {
	// status indicates the verification results
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
}

VerifyBatchResponse

func (*VerifyBatchResponse) Descriptor 

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

func (*VerifyBatchResponse) GetStatus 

func (m *VerifyBatchResponse) GetStatus() bool

func (*VerifyBatchResponse) Marshal 

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

func (*VerifyBatchResponse) MarshalTo 

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

func (*VerifyBatchResponse) MarshalToSizedBuffer 

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

func (*VerifyBatchResponse) ProtoMessage 

func (*VerifyBatchResponse) ProtoMessage()

func (*VerifyBatchResponse) Reset 

func (m *VerifyBatchResponse) Reset()

func (*VerifyBatchResponse) Size 

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

func (*VerifyBatchResponse) String 

func (m *VerifyBatchResponse) String() string

func (*VerifyBatchResponse) Unmarshal 

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

func (*VerifyBatchResponse) XXX_DiscardUnknown 

func (m *VerifyBatchResponse) XXX_DiscardUnknown()

func (*VerifyBatchResponse) XXX_Marshal 

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

func (*VerifyBatchResponse) XXX_Merge 

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

func (*VerifyBatchResponse) XXX_Size 

func (m *VerifyBatchResponse) XXX_Size() int

func (*VerifyBatchResponse) XXX_Unmarshal 

func (m *VerifyBatchResponse) XXX_Unmarshal(b []byte) 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.