da

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2024 License: Apache-2.0 Imports: 12 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")
)
View Source 
var DAService_serviceDesc = _DAService_serviceDesc
View Source 
var ErrorCode_name = map[int32]string{
	0:     "ERROR_CODE_UNSPECIFIED",
	32001: "ERROR_CODE_BLOB_NOT_FOUND",
	32002: "ERROR_CODE_BLOB_SIZE_OVER_LIMIT",
	32003: "ERROR_CODE_TX_TIMED_OUT",
	32004: "ERROR_CODE_TX_ALREADY_IN_MEMPOOL",
	32005: "ERROR_CODE_TX_INCORRECT_ACCOUNT_SEQUENCE",
	32006: "ERROR_CODE_TX_TOO_LARGE",
	32007: "ERROR_CODE_CONTEXT_DEADLINE",
	32008: "ERROR_CODE_FUTURE_HEIGHT",
}
View Source 
var ErrorCode_value = map[string]int32{
	"ERROR_CODE_UNSPECIFIED":                   0,
	"ERROR_CODE_BLOB_NOT_FOUND":                32001,
	"ERROR_CODE_BLOB_SIZE_OVER_LIMIT":          32002,
	"ERROR_CODE_TX_TIMED_OUT":                  32003,
	"ERROR_CODE_TX_ALREADY_IN_MEMPOOL":         32004,
	"ERROR_CODE_TX_INCORRECT_ACCOUNT_SEQUENCE": 32005,
	"ERROR_CODE_TX_TOO_LARGE":                  32006,
	"ERROR_CODE_CONTEXT_DEADLINE":              32007,
	"ERROR_CODE_FUTURE_HEIGHT":                 32008,
}

Functions

func RegisterDAServiceServer 

func RegisterDAServiceServer(s grpc1.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 grpc1.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 ErrorCode added in v0.9.0 

type ErrorCode int32
const (
	ErrorCode_ERROR_CODE_UNSPECIFIED                   ErrorCode = 0
	ErrorCode_ERROR_CODE_BLOB_NOT_FOUND                ErrorCode = 32001
	ErrorCode_ERROR_CODE_BLOB_SIZE_OVER_LIMIT          ErrorCode = 32002
	ErrorCode_ERROR_CODE_TX_TIMED_OUT                  ErrorCode = 32003
	ErrorCode_ERROR_CODE_TX_ALREADY_IN_MEMPOOL         ErrorCode = 32004
	ErrorCode_ERROR_CODE_TX_INCORRECT_ACCOUNT_SEQUENCE ErrorCode = 32005
	ErrorCode_ERROR_CODE_TX_TOO_LARGE                  ErrorCode = 32006
	ErrorCode_ERROR_CODE_CONTEXT_DEADLINE              ErrorCode = 32007
	ErrorCode_ERROR_CODE_FUTURE_HEIGHT                 ErrorCode = 32008
)

func (ErrorCode) EnumDescriptor added in v0.9.0 

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

func (ErrorCode) String added in v0.9.0 

func (x ErrorCode) String() string

type ErrorDetails added in v0.9.0 

type ErrorDetails struct {
	Code ErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=da.ErrorCode" json:"code,omitempty"`
}

func (*ErrorDetails) Descriptor added in v0.9.0 

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

func (*ErrorDetails) GetCode added in v0.9.0 

func (m *ErrorDetails) GetCode() ErrorCode

func (*ErrorDetails) Marshal added in v0.9.0 

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

func (*ErrorDetails) MarshalTo added in v0.9.0 

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

func (*ErrorDetails) MarshalToSizedBuffer added in v0.9.0 

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

func (*ErrorDetails) ProtoMessage added in v0.9.0 

func (*ErrorDetails) ProtoMessage()

func (*ErrorDetails) Reset added in v0.9.0 

func (m *ErrorDetails) Reset()

func (*ErrorDetails) Size added in v0.9.0 

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

func (*ErrorDetails) String added in v0.9.0 

func (m *ErrorDetails) String() string

func (*ErrorDetails) Unmarshal added in v0.9.0 

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

func (*ErrorDetails) XXX_DiscardUnknown added in v0.9.0 

func (m *ErrorDetails) XXX_DiscardUnknown()

func (*ErrorDetails) XXX_Marshal added in v0.9.0 

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

func (*ErrorDetails) XXX_Merge added in v0.9.0 

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

func (*ErrorDetails) XXX_Size added in v0.9.0 

func (m *ErrorDetails) XXX_Size() int

func (*ErrorDetails) XXX_Unmarshal added in v0.9.0 

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

type GetIdsRequest added in v0.6.1 

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 added in v0.6.1 

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

func (*GetIdsRequest) GetHeight added in v0.6.1 

func (m *GetIdsRequest) GetHeight() uint64

func (*GetIdsRequest) GetNamespace added in v0.6.1 

func (m *GetIdsRequest) GetNamespace() *Namespace

func (*GetIdsRequest) Marshal added in v0.6.1 

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

func (*GetIdsRequest) MarshalTo added in v0.6.1 

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

func (*GetIdsRequest) MarshalToSizedBuffer added in v0.6.1 

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

func (*GetIdsRequest) ProtoMessage added in v0.6.1 

func (*GetIdsRequest) ProtoMessage()

func (*GetIdsRequest) Reset added in v0.6.1 

func (m *GetIdsRequest) Reset()

func (*GetIdsRequest) Size added in v0.6.1 

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

func (*GetIdsRequest) String added in v0.6.1 

func (m *GetIdsRequest) String() string

func (*GetIdsRequest) Unmarshal added in v0.6.1 

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

func (*GetIdsRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *GetIdsRequest) XXX_DiscardUnknown()

func (*GetIdsRequest) XXX_Marshal added in v0.6.1 

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

func (*GetIdsRequest) XXX_Merge added in v0.6.1 

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

func (*GetIdsRequest) XXX_Size added in v0.6.1 

func (m *GetIdsRequest) XXX_Size() int

func (*GetIdsRequest) XXX_Unmarshal added in v0.6.1 

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

type GetIdsResponse added in v0.6.1 

type GetIdsResponse struct {
	Ids       []*ID            `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

GetIdsResponse is the response type for the GetIds rpc method.

func (*GetIdsResponse) Descriptor added in v0.6.1 

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

func (*GetIdsResponse) GetIds added in v0.6.1 

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

func (*GetIdsResponse) GetTimestamp added in v0.6.1 

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

func (*GetIdsResponse) Marshal added in v0.6.1 

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

func (*GetIdsResponse) MarshalTo added in v0.6.1 

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

func (*GetIdsResponse) MarshalToSizedBuffer added in v0.6.1 

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

func (*GetIdsResponse) ProtoMessage added in v0.6.1 

func (*GetIdsResponse) ProtoMessage()

func (*GetIdsResponse) Reset added in v0.6.1 

func (m *GetIdsResponse) Reset()

func (*GetIdsResponse) Size added in v0.6.1 

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

func (*GetIdsResponse) String added in v0.6.1 

func (m *GetIdsResponse) String() string

func (*GetIdsResponse) Unmarshal added in v0.6.1 

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

func (*GetIdsResponse) XXX_DiscardUnknown added in v0.6.1 

func (m *GetIdsResponse) XXX_DiscardUnknown()

func (*GetIdsResponse) XXX_Marshal added in v0.6.1 

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

func (*GetIdsResponse) XXX_Merge added in v0.6.1 

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

func (*GetIdsResponse) XXX_Size added in v0.6.1 

func (m *GetIdsResponse) XXX_Size() int

func (*GetIdsResponse) XXX_Unmarshal added in v0.6.1 

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"`
	Options   []byte     `protobuf:"bytes,4,opt,name=options,proto3" json:"options,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) GetOptions 

func (m *SubmitRequest) GetOptions() []byte

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 added in v0.6.1 

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.