da

package
v0.5.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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")
)

Functions

func RegisterDAServiceServer 

func RegisterDAServiceServer(s *grpc.Server, srv DAServiceServer)

Types

type Blob 

type Blob struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

Blob is the data submitted/received from DA interface.

func (*Blob) Descriptor 

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

func (*Blob) GetValue 

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

func (*Blob) Marshal 

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

func (*Blob) MarshalTo 

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

func (*Blob) MarshalToSizedBuffer 

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

func (*Blob) ProtoMessage 

func (*Blob) ProtoMessage()

func (*Blob) Reset 

func (m *Blob) Reset()

func (*Blob) Size 

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

func (*Blob) String 

func (m *Blob) String() string

func (*Blob) Unmarshal 

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

func (*Blob) XXX_DiscardUnknown 

func (m *Blob) XXX_DiscardUnknown()

func (*Blob) XXX_Marshal 

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

func (*Blob) XXX_Merge 

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

func (*Blob) XXX_Size 

func (m *Blob) XXX_Size() int

func (*Blob) XXX_Unmarshal 

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

type CommitRequest 

type CommitRequest struct {
	Blobs     []*Blob    `protobuf:"bytes,1,rep,name=blobs,proto3" json:"blobs,omitempty"`
	Namespace *Namespace `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

CommitRequest is the request type for the Commit rpc method.

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetBlobs 

func (m *CommitRequest) GetBlobs() []*Blob

func (*CommitRequest) GetNamespace added in v0.4.0 

func (m *CommitRequest) GetNamespace() *Namespace

func (*CommitRequest) Marshal 

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

func (*CommitRequest) MarshalTo 

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

func (*CommitRequest) MarshalToSizedBuffer 

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

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) Size 

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

func (*CommitRequest) String 

func (m *CommitRequest) String() string

func (*CommitRequest) Unmarshal 

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

func (*CommitRequest) XXX_DiscardUnknown 

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal 

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

func (*CommitRequest) XXX_Merge 

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

func (*CommitRequest) XXX_Size 

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal 

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

type CommitResponse 

type CommitResponse struct {
	Commitments []*Commitment `protobuf:"bytes,1,rep,name=commitments,proto3" json:"commitments,omitempty"`
}

CommitResponse is the response type for the Commit rpc method.

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) GetCommitments 

func (m *CommitResponse) GetCommitments() []*Commitment

func (*CommitResponse) Marshal 

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

func (*CommitResponse) MarshalTo 

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

func (*CommitResponse) MarshalToSizedBuffer 

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

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) Size 

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

func (*CommitResponse) String 

func (m *CommitResponse) String() string

func (*CommitResponse) Unmarshal 

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

func (*CommitResponse) XXX_DiscardUnknown 

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal 

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

func (*CommitResponse) XXX_Merge 

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

func (*CommitResponse) XXX_Size 

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal 

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

type Commitment 

type Commitment struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

Commitment should contain serialized cryptographic commitment to Blob value.

func (*Commitment) Descriptor 

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

func (*Commitment) GetValue 

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

func (*Commitment) Marshal 

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

func (*Commitment) MarshalTo 

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

func (*Commitment) MarshalToSizedBuffer 

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

func (*Commitment) ProtoMessage 

func (*Commitment) ProtoMessage()

func (*Commitment) Reset 

func (m *Commitment) Reset()

func (*Commitment) Size 

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

func (*Commitment) String 

func (m *Commitment) String() string

func (*Commitment) Unmarshal 

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

func (*Commitment) XXX_DiscardUnknown 

func (m *Commitment) XXX_DiscardUnknown()

func (*Commitment) XXX_Marshal 

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

func (*Commitment) XXX_Merge 

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

func (*Commitment) XXX_Size 

func (m *Commitment) XXX_Size() int

func (*Commitment) XXX_Unmarshal 

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

type DAServiceClient 

type DAServiceClient interface {
	// MaxBlobSize returns the maximum blob size
	MaxBlobSize(ctx context.Context, in *MaxBlobSizeRequest, opts ...grpc.CallOption) (*MaxBlobSizeResponse, error)
	// Get returns Blob for each given ID, or an error.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// GetIDs returns IDs of all Blobs located in DA at given height.
	GetIDs(ctx context.Context, in *GetIDsRequest, opts ...grpc.CallOption) (*GetIDsResponse, error)
	// GetProofs returns inclusion Proofs for all Blobs located in DA at given height.
	GetProofs(ctx context.Context, in *GetProofsRequest, opts ...grpc.CallOption) (*GetProofsResponse, error)
	// Commit creates a Commitment for each given Blob.
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	// Submit submits the given Blobs to Data Availability layer.
	Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
	// Validate validates Commitments against corresponding Proofs. This should be possible without retrieving Blob.
	Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error)
}

DAServiceClient is the client API for DAService service.

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

func NewDAServiceClient 

func NewDAServiceClient(cc *grpc.ClientConn) DAServiceClient

type DAServiceServer 

type DAServiceServer interface {
	// MaxBlobSize returns the maximum blob size
	MaxBlobSize(context.Context, *MaxBlobSizeRequest) (*MaxBlobSizeResponse, error)
	// Get returns Blob for each given ID, or an error.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// GetIDs returns IDs of all Blobs located in DA at given height.
	GetIDs(context.Context, *GetIDsRequest) (*GetIDsResponse, error)
	// GetProofs returns inclusion Proofs for all Blobs located in DA at given height.
	GetProofs(context.Context, *GetProofsRequest) (*GetProofsResponse, error)
	// Commit creates a Commitment for each given Blob.
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	// Submit submits the given Blobs to Data Availability layer.
	Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
	// Validate validates Commitments against corresponding Proofs. This should be possible without retrieving Blob.
	Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
}

DAServiceServer is the server API for DAService service.

type GetIDsRequest 

type GetIDsRequest struct {
	Height    uint64     `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Namespace *Namespace `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

GetIDsRequest is the request type for the GetIDs rpc method.

func (*GetIDsRequest) Descriptor 

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

func (*GetIDsRequest) GetHeight 

func (m *GetIDsRequest) GetHeight() uint64

func (*GetIDsRequest) GetNamespace added in v0.4.0 

func (m *GetIDsRequest) GetNamespace() *Namespace

func (*GetIDsRequest) Marshal 

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

func (*GetIDsRequest) MarshalTo 

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

func (*GetIDsRequest) MarshalToSizedBuffer 

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

func (*GetIDsRequest) ProtoMessage 

func (*GetIDsRequest) ProtoMessage()

func (*GetIDsRequest) Reset 

func (m *GetIDsRequest) Reset()

func (*GetIDsRequest) Size 

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

func (*GetIDsRequest) String 

func (m *GetIDsRequest) String() string

func (*GetIDsRequest) Unmarshal 

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

func (*GetIDsRequest) XXX_DiscardUnknown 

func (m *GetIDsRequest) XXX_DiscardUnknown()

func (*GetIDsRequest) XXX_Marshal 

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

func (*GetIDsRequest) XXX_Merge 

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

func (*GetIDsRequest) XXX_Size 

func (m *GetIDsRequest) XXX_Size() int

func (*GetIDsRequest) XXX_Unmarshal 

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

type GetIDsResponse 

type GetIDsResponse struct {
	Ids []*ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
}

GetIDsResponse is the response type for the GetIDs rpc method.

func (*GetIDsResponse) Descriptor 

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

func (*GetIDsResponse) GetIds 

func (m *GetIDsResponse) GetIds() []*ID

func (*GetIDsResponse) Marshal 

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

func (*GetIDsResponse) MarshalTo 

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

func (*GetIDsResponse) MarshalToSizedBuffer 

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

func (*GetIDsResponse) ProtoMessage 

func (*GetIDsResponse) ProtoMessage()

func (*GetIDsResponse) Reset 

func (m *GetIDsResponse) Reset()

func (*GetIDsResponse) Size 

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

func (*GetIDsResponse) String 

func (m *GetIDsResponse) String() string

func (*GetIDsResponse) Unmarshal 

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

func (*GetIDsResponse) XXX_DiscardUnknown 

func (m *GetIDsResponse) XXX_DiscardUnknown()

func (*GetIDsResponse) XXX_Marshal 

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

func (*GetIDsResponse) XXX_Merge 

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

func (*GetIDsResponse) XXX_Size 

func (m *GetIDsResponse) XXX_Size() int

func (*GetIDsResponse) XXX_Unmarshal 

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

type GetProofsRequest added in v0.4.0 

type GetProofsRequest struct {
	Ids       []*ID      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Namespace *Namespace `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

GetProofsRequest is the request type for the GetProofs rpc method.

func (*GetProofsRequest) Descriptor added in v0.4.0 

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

func (*GetProofsRequest) GetIds added in v0.4.0 

func (m *GetProofsRequest) GetIds() []*ID

func (*GetProofsRequest) GetNamespace added in v0.4.0 

func (m *GetProofsRequest) GetNamespace() *Namespace

func (*GetProofsRequest) Marshal added in v0.4.0 

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

func (*GetProofsRequest) MarshalTo added in v0.4.0 

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

func (*GetProofsRequest) MarshalToSizedBuffer added in v0.4.0 

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

func (*GetProofsRequest) ProtoMessage added in v0.4.0 

func (*GetProofsRequest) ProtoMessage()

func (*GetProofsRequest) Reset added in v0.4.0 

func (m *GetProofsRequest) Reset()

func (*GetProofsRequest) Size added in v0.4.0 

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

func (*GetProofsRequest) String added in v0.4.0 

func (m *GetProofsRequest) String() string

func (*GetProofsRequest) Unmarshal added in v0.4.0 

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

func (*GetProofsRequest) XXX_DiscardUnknown added in v0.4.0 

func (m *GetProofsRequest) XXX_DiscardUnknown()

func (*GetProofsRequest) XXX_Marshal added in v0.4.0 

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

func (*GetProofsRequest) XXX_Merge added in v0.4.0 

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

func (*GetProofsRequest) XXX_Size added in v0.4.0 

func (m *GetProofsRequest) XXX_Size() int

func (*GetProofsRequest) XXX_Unmarshal added in v0.4.0 

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

type GetProofsResponse added in v0.4.0 

type GetProofsResponse struct {
	Proofs []*Proof `protobuf:"bytes,1,rep,name=proofs,proto3" json:"proofs,omitempty"`
}

GetProofsResponse is the response type for the GetProofs rpc method.

func (*GetProofsResponse) Descriptor added in v0.4.0 

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

func (*GetProofsResponse) GetProofs added in v0.4.0 

func (m *GetProofsResponse) GetProofs() []*Proof

func (*GetProofsResponse) Marshal added in v0.4.0 

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

func (*GetProofsResponse) MarshalTo added in v0.4.0 

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

func (*GetProofsResponse) MarshalToSizedBuffer added in v0.4.0 

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

func (*GetProofsResponse) ProtoMessage added in v0.4.0 

func (*GetProofsResponse) ProtoMessage()

func (*GetProofsResponse) Reset added in v0.4.0 

func (m *GetProofsResponse) Reset()

func (*GetProofsResponse) Size added in v0.4.0 

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

func (*GetProofsResponse) String added in v0.4.0 

func (m *GetProofsResponse) String() string

func (*GetProofsResponse) Unmarshal added in v0.4.0 

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

func (*GetProofsResponse) XXX_DiscardUnknown added in v0.4.0 

func (m *GetProofsResponse) XXX_DiscardUnknown()

func (*GetProofsResponse) XXX_Marshal added in v0.4.0 

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

func (*GetProofsResponse) XXX_Merge added in v0.4.0 

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

func (*GetProofsResponse) XXX_Size added in v0.4.0 

func (m *GetProofsResponse) XXX_Size() int

func (*GetProofsResponse) XXX_Unmarshal added in v0.4.0 

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

type GetRequest 

type GetRequest struct {
	Ids       []*ID      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Namespace *Namespace `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

GetRequest is the request type for the Get rpc method.

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetIds 

func (m *GetRequest) GetIds() []*ID

func (*GetRequest) GetNamespace added in v0.4.0 

func (m *GetRequest) GetNamespace() *Namespace

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	Blobs []*Blob `protobuf:"bytes,1,rep,name=blobs,proto3" json:"blobs,omitempty"`
}

GetResponse is the response type for the Get rpc method.

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetBlobs 

func (m *GetResponse) GetBlobs() []*Blob

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type ID 

type ID struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

ID should contain serialized data required by the implementation to find blob in Data Availability layer.

func (*ID) Descriptor 

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

func (*ID) GetValue 

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

func (*ID) Marshal 

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

func (*ID) MarshalTo 

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

func (*ID) MarshalToSizedBuffer 

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

func (*ID) ProtoMessage 

func (*ID) ProtoMessage()

func (*ID) Reset 

func (m *ID) Reset()

func (*ID) Size 

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

func (*ID) String 

func (m *ID) String() string

func (*ID) Unmarshal 

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

func (*ID) XXX_DiscardUnknown 

func (m *ID) XXX_DiscardUnknown()

func (*ID) XXX_Marshal 

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

func (*ID) XXX_Merge 

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

func (*ID) XXX_Size 

func (m *ID) XXX_Size() int

func (*ID) XXX_Unmarshal 

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

type MaxBlobSizeRequest 

type MaxBlobSizeRequest struct {
}

MaxBlobSizeRequest is the request type for the MaxBlobSize rpc method.

func (*MaxBlobSizeRequest) Descriptor 

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

func (*MaxBlobSizeRequest) Marshal 

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

func (*MaxBlobSizeRequest) MarshalTo 

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

func (*MaxBlobSizeRequest) MarshalToSizedBuffer 

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

func (*MaxBlobSizeRequest) ProtoMessage 

func (*MaxBlobSizeRequest) ProtoMessage()

func (*MaxBlobSizeRequest) Reset 

func (m *MaxBlobSizeRequest) Reset()

func (*MaxBlobSizeRequest) Size 

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

func (*MaxBlobSizeRequest) String 

func (m *MaxBlobSizeRequest) String() string

func (*MaxBlobSizeRequest) Unmarshal 

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

func (*MaxBlobSizeRequest) XXX_DiscardUnknown 

func (m *MaxBlobSizeRequest) XXX_DiscardUnknown()

func (*MaxBlobSizeRequest) XXX_Marshal 

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

func (*MaxBlobSizeRequest) XXX_Merge 

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

func (*MaxBlobSizeRequest) XXX_Size 

func (m *MaxBlobSizeRequest) XXX_Size() int

func (*MaxBlobSizeRequest) XXX_Unmarshal 

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

type MaxBlobSizeResponse 

type MaxBlobSizeResponse struct {
	MaxBlobSize uint64 `protobuf:"varint,1,opt,name=max_blob_size,json=maxBlobSize,proto3" json:"max_blob_size,omitempty"`
}

MaxBlobSizeResponse is the response type for the MaxBlobSize rpc method.

func (*MaxBlobSizeResponse) Descriptor 

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

func (*MaxBlobSizeResponse) GetMaxBlobSize 

func (m *MaxBlobSizeResponse) GetMaxBlobSize() uint64

func (*MaxBlobSizeResponse) Marshal 

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

func (*MaxBlobSizeResponse) MarshalTo 

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

func (*MaxBlobSizeResponse) MarshalToSizedBuffer 

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

func (*MaxBlobSizeResponse) ProtoMessage 

func (*MaxBlobSizeResponse) ProtoMessage()

func (*MaxBlobSizeResponse) Reset 

func (m *MaxBlobSizeResponse) Reset()

func (*MaxBlobSizeResponse) Size 

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

func (*MaxBlobSizeResponse) String 

func (m *MaxBlobSizeResponse) String() string

func (*MaxBlobSizeResponse) Unmarshal 

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

func (*MaxBlobSizeResponse) XXX_DiscardUnknown 

func (m *MaxBlobSizeResponse) XXX_DiscardUnknown()

func (*MaxBlobSizeResponse) XXX_Marshal 

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

func (*MaxBlobSizeResponse) XXX_Merge 

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

func (*MaxBlobSizeResponse) XXX_Size 

func (m *MaxBlobSizeResponse) XXX_Size() int

func (*MaxBlobSizeResponse) XXX_Unmarshal 

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

type Namespace added in v0.3.0 

type Namespace struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

Namespace is the location for the blob to be submitted to, if supported by the DA layer.

func (*Namespace) Descriptor added in v0.3.0 

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

func (*Namespace) GetValue added in v0.3.0 

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

func (*Namespace) Marshal added in v0.3.0 

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

func (*Namespace) MarshalTo added in v0.3.0 

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

func (*Namespace) MarshalToSizedBuffer added in v0.3.0 

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

func (*Namespace) ProtoMessage added in v0.3.0 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset added in v0.3.0 

func (m *Namespace) Reset()

func (*Namespace) Size added in v0.3.0 

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

func (*Namespace) String added in v0.3.0 

func (m *Namespace) String() string

func (*Namespace) Unmarshal added in v0.3.0 

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

func (*Namespace) XXX_DiscardUnknown added in v0.3.0 

func (m *Namespace) XXX_DiscardUnknown()

func (*Namespace) XXX_Marshal added in v0.3.0 

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

func (*Namespace) XXX_Merge added in v0.3.0 

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

func (*Namespace) XXX_Size added in v0.3.0 

func (m *Namespace) XXX_Size() int

func (*Namespace) XXX_Unmarshal added in v0.3.0 

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

type Proof 

type Proof struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

Proof should contain serialized proof of inclusion (publication) of Blob in Data Availability layer.

func (*Proof) Descriptor 

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

func (*Proof) GetValue 

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

func (*Proof) Marshal 

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

func (*Proof) MarshalTo 

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

func (*Proof) MarshalToSizedBuffer 

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

func (*Proof) ProtoMessage 

func (*Proof) ProtoMessage()

func (*Proof) Reset 

func (m *Proof) Reset()

func (*Proof) Size 

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

func (*Proof) String 

func (m *Proof) String() string

func (*Proof) Unmarshal 

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

func (*Proof) XXX_DiscardUnknown 

func (m *Proof) XXX_DiscardUnknown()

func (*Proof) XXX_Marshal 

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

func (*Proof) XXX_Merge 

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

func (*Proof) XXX_Size 

func (m *Proof) XXX_Size() int

func (*Proof) XXX_Unmarshal 

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

type SubmitRequest 

type SubmitRequest struct {
	Blobs     []*Blob    `protobuf:"bytes,1,rep,name=blobs,proto3" json:"blobs,omitempty"`
	GasPrice  float64    `protobuf:"fixed64,2,opt,name=gas_price,json=gasPrice,proto3" json:"gas_price,omitempty"`
	Namespace *Namespace `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

SubmitRequest is the request type for the Submit rpc method.

func (*SubmitRequest) Descriptor 

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

func (*SubmitRequest) GetBlobs 

func (m *SubmitRequest) GetBlobs() []*Blob

func (*SubmitRequest) GetGasPrice added in v0.1.0 

func (m *SubmitRequest) GetGasPrice() float64

func (*SubmitRequest) GetNamespace added in v0.3.0 

func (m *SubmitRequest) GetNamespace() *Namespace

func (*SubmitRequest) Marshal 

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

func (*SubmitRequest) MarshalTo 

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

func (*SubmitRequest) MarshalToSizedBuffer 

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

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset 

func (m *SubmitRequest) Reset()

func (*SubmitRequest) Size 

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

func (*SubmitRequest) String 

func (m *SubmitRequest) String() string

func (*SubmitRequest) Unmarshal 

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

func (*SubmitRequest) XXX_DiscardUnknown 

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal 

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

func (*SubmitRequest) XXX_Merge 

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

func (*SubmitRequest) XXX_Size 

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal 

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

type SubmitResponse 

type SubmitResponse struct {
	Ids []*ID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
}

SubmitResponse is the response type for the Submit rpc method.

func (*SubmitResponse) Descriptor 

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

func (*SubmitResponse) GetIds 

func (m *SubmitResponse) GetIds() []*ID

func (*SubmitResponse) Marshal 

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

func (*SubmitResponse) MarshalTo 

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

func (*SubmitResponse) MarshalToSizedBuffer 

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

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset 

func (m *SubmitResponse) Reset()

func (*SubmitResponse) Size 

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

func (*SubmitResponse) String 

func (m *SubmitResponse) String() string

func (*SubmitResponse) Unmarshal 

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

func (*SubmitResponse) XXX_DiscardUnknown 

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal 

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

func (*SubmitResponse) XXX_Merge 

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

func (*SubmitResponse) XXX_Size 

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal 

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

type UnimplementedDAServiceServer 

type UnimplementedDAServiceServer struct {
}

UnimplementedDAServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDAServiceServer) Commit 

func (*UnimplementedDAServiceServer) Commit(ctx context.Context, req *CommitRequest) (*CommitResponse, error)

func (*UnimplementedDAServiceServer) Get 

func (*UnimplementedDAServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedDAServiceServer) GetIDs 

func (*UnimplementedDAServiceServer) GetIDs(ctx context.Context, req *GetIDsRequest) (*GetIDsResponse, error)

func (*UnimplementedDAServiceServer) GetProofs added in v0.4.0 

func (*UnimplementedDAServiceServer) GetProofs(ctx context.Context, req *GetProofsRequest) (*GetProofsResponse, error)

func (*UnimplementedDAServiceServer) MaxBlobSize 

func (*UnimplementedDAServiceServer) MaxBlobSize(ctx context.Context, req *MaxBlobSizeRequest) (*MaxBlobSizeResponse, error)

func (*UnimplementedDAServiceServer) Submit 

func (*UnimplementedDAServiceServer) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)

func (*UnimplementedDAServiceServer) Validate 

func (*UnimplementedDAServiceServer) Validate(ctx context.Context, req *ValidateRequest) (*ValidateResponse, error)

type ValidateRequest 

type ValidateRequest struct {
	Ids       []*ID      `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Proofs    []*Proof   `protobuf:"bytes,2,rep,name=proofs,proto3" json:"proofs,omitempty"`
	Namespace *Namespace `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

ValidateRequest is the request type for the Validate rpc method.

func (*ValidateRequest) Descriptor 

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

func (*ValidateRequest) GetIds 

func (m *ValidateRequest) GetIds() []*ID

func (*ValidateRequest) GetNamespace added in v0.4.0 

func (m *ValidateRequest) GetNamespace() *Namespace

func (*ValidateRequest) GetProofs 

func (m *ValidateRequest) GetProofs() []*Proof

func (*ValidateRequest) Marshal 

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

func (*ValidateRequest) MarshalTo 

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

func (*ValidateRequest) MarshalToSizedBuffer 

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

func (*ValidateRequest) ProtoMessage 

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) Reset 

func (m *ValidateRequest) Reset()

func (*ValidateRequest) Size 

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

func (*ValidateRequest) String 

func (m *ValidateRequest) String() string

func (*ValidateRequest) Unmarshal 

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

func (*ValidateRequest) XXX_DiscardUnknown 

func (m *ValidateRequest) XXX_DiscardUnknown()

func (*ValidateRequest) XXX_Marshal 

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

func (*ValidateRequest) XXX_Merge 

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

func (*ValidateRequest) XXX_Size 

func (m *ValidateRequest) XXX_Size() int

func (*ValidateRequest) XXX_Unmarshal 

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

type ValidateResponse 

type ValidateResponse struct {
	Results []bool `protobuf:"varint,1,rep,packed,name=results,proto3" json:"results,omitempty"`
}

ValidateResponse is the response type for the Validate rpc method.

func (*ValidateResponse) Descriptor 

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

func (*ValidateResponse) GetResults 

func (m *ValidateResponse) GetResults() []bool

func (*ValidateResponse) Marshal 

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

func (*ValidateResponse) MarshalTo 

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

func (*ValidateResponse) MarshalToSizedBuffer 

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

func (*ValidateResponse) ProtoMessage 

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) Reset 

func (m *ValidateResponse) Reset()

func (*ValidateResponse) Size 

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

func (*ValidateResponse) String 

func (m *ValidateResponse) String() string

func (*ValidateResponse) Unmarshal 

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

func (*ValidateResponse) XXX_DiscardUnknown 

func (m *ValidateResponse) XXX_DiscardUnknown()

func (*ValidateResponse) XXX_Marshal 

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

func (*ValidateResponse) XXX_Merge 

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

func (*ValidateResponse) XXX_Size 

func (m *ValidateResponse) XXX_Size() int

func (*ValidateResponse) XXX_Unmarshal 

func (m *ValidateResponse) 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.