dalc

package
v0.8.1-pre Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDalc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDalc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDalc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var StatusCode_name = map[int32]string{
	0: "STATUS_CODE_UNSPECIFIED",
	1: "STATUS_CODE_SUCCESS",
	2: "STATUS_CODE_TIMEOUT",
	3: "STATUS_CODE_ERROR",
}
View Source 
var StatusCode_value = map[string]int32{
	"STATUS_CODE_UNSPECIFIED": 0,
	"STATUS_CODE_SUCCESS":     1,
	"STATUS_CODE_TIMEOUT":     2,
	"STATUS_CODE_ERROR":       3,
}

Functions

func RegisterDALCServiceServer 

func RegisterDALCServiceServer(s *grpc.Server, srv DALCServiceServer)

Types

type CheckBlockAvailabilityRequest 

type CheckBlockAvailabilityRequest struct {
	DAHeight uint64 `protobuf:"varint,1,opt,name=da_height,json=daHeight,proto3" json:"da_height,omitempty"`
}

func (*CheckBlockAvailabilityRequest) Descriptor 

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

func (*CheckBlockAvailabilityRequest) GetDAHeight 

func (m *CheckBlockAvailabilityRequest) GetDAHeight() uint64

func (*CheckBlockAvailabilityRequest) Marshal 

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

func (*CheckBlockAvailabilityRequest) MarshalTo 

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

func (*CheckBlockAvailabilityRequest) MarshalToSizedBuffer 

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

func (*CheckBlockAvailabilityRequest) ProtoMessage 

func (*CheckBlockAvailabilityRequest) ProtoMessage()

func (*CheckBlockAvailabilityRequest) Reset 

func (m *CheckBlockAvailabilityRequest) Reset()

func (*CheckBlockAvailabilityRequest) Size 

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

func (*CheckBlockAvailabilityRequest) String 

func (m *CheckBlockAvailabilityRequest) String() string

func (*CheckBlockAvailabilityRequest) Unmarshal 

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

func (*CheckBlockAvailabilityRequest) XXX_DiscardUnknown 

func (m *CheckBlockAvailabilityRequest) XXX_DiscardUnknown()

func (*CheckBlockAvailabilityRequest) XXX_Marshal 

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

func (*CheckBlockAvailabilityRequest) XXX_Merge 

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

func (*CheckBlockAvailabilityRequest) XXX_Size 

func (m *CheckBlockAvailabilityRequest) XXX_Size() int

func (*CheckBlockAvailabilityRequest) XXX_Unmarshal 

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

type CheckBlockAvailabilityResponse 

type CheckBlockAvailabilityResponse struct {
	Result        *DAResponse `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	DataAvailable bool        `protobuf:"varint,2,opt,name=data_available,json=dataAvailable,proto3" json:"data_available,omitempty"`
}

func (*CheckBlockAvailabilityResponse) Descriptor 

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

func (*CheckBlockAvailabilityResponse) GetDataAvailable 

func (m *CheckBlockAvailabilityResponse) GetDataAvailable() bool

func (*CheckBlockAvailabilityResponse) GetResult 

func (m *CheckBlockAvailabilityResponse) GetResult() *DAResponse

func (*CheckBlockAvailabilityResponse) Marshal 

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

func (*CheckBlockAvailabilityResponse) MarshalTo 

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

func (*CheckBlockAvailabilityResponse) MarshalToSizedBuffer 

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

func (*CheckBlockAvailabilityResponse) ProtoMessage 

func (*CheckBlockAvailabilityResponse) ProtoMessage()

func (*CheckBlockAvailabilityResponse) Reset 

func (m *CheckBlockAvailabilityResponse) Reset()

func (*CheckBlockAvailabilityResponse) Size 

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

func (*CheckBlockAvailabilityResponse) String 

func (m *CheckBlockAvailabilityResponse) String() string

func (*CheckBlockAvailabilityResponse) Unmarshal 

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

func (*CheckBlockAvailabilityResponse) XXX_DiscardUnknown 

func (m *CheckBlockAvailabilityResponse) XXX_DiscardUnknown()

func (*CheckBlockAvailabilityResponse) XXX_Marshal 

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

func (*CheckBlockAvailabilityResponse) XXX_Merge 

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

func (*CheckBlockAvailabilityResponse) XXX_Size 

func (m *CheckBlockAvailabilityResponse) XXX_Size() int

func (*CheckBlockAvailabilityResponse) XXX_Unmarshal 

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

type DALCServiceClient 

type DALCServiceClient interface {
	SubmitBlock(ctx context.Context, in *SubmitBlockRequest, opts ...grpc.CallOption) (*SubmitBlockResponse, error)
	CheckBlockAvailability(ctx context.Context, in *CheckBlockAvailabilityRequest, opts ...grpc.CallOption) (*CheckBlockAvailabilityResponse, error)
	RetrieveBlocks(ctx context.Context, in *RetrieveBlocksRequest, opts ...grpc.CallOption) (*RetrieveBlocksResponse, error)
}

DALCServiceClient is the client API for DALCService service.

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

func NewDALCServiceClient 

func NewDALCServiceClient(cc *grpc.ClientConn) DALCServiceClient

type DALCServiceServer 

type DALCServiceServer interface {
	SubmitBlock(context.Context, *SubmitBlockRequest) (*SubmitBlockResponse, error)
	CheckBlockAvailability(context.Context, *CheckBlockAvailabilityRequest) (*CheckBlockAvailabilityResponse, error)
	RetrieveBlocks(context.Context, *RetrieveBlocksRequest) (*RetrieveBlocksResponse, error)
}

DALCServiceServer is the server API for DALCService service.

type DAResponse 

type DAResponse struct {
	Code     StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=dalc.StatusCode" json:"code,omitempty"`
	Message  string     `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DAHeight uint64     `protobuf:"varint,3,opt,name=da_height,json=daHeight,proto3" json:"da_height,omitempty"`
}

func (*DAResponse) Descriptor 

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

func (*DAResponse) GetCode 

func (m *DAResponse) GetCode() StatusCode

func (*DAResponse) GetDAHeight 

func (m *DAResponse) GetDAHeight() uint64

func (*DAResponse) GetMessage 

func (m *DAResponse) GetMessage() string

func (*DAResponse) Marshal 

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

func (*DAResponse) MarshalTo 

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

func (*DAResponse) MarshalToSizedBuffer 

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

func (*DAResponse) ProtoMessage 

func (*DAResponse) ProtoMessage()

func (*DAResponse) Reset 

func (m *DAResponse) Reset()

func (*DAResponse) Size 

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

func (*DAResponse) String 

func (m *DAResponse) String() string

func (*DAResponse) Unmarshal 

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

func (*DAResponse) XXX_DiscardUnknown 

func (m *DAResponse) XXX_DiscardUnknown()

func (*DAResponse) XXX_Marshal 

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

func (*DAResponse) XXX_Merge 

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

func (*DAResponse) XXX_Size 

func (m *DAResponse) XXX_Size() int

func (*DAResponse) XXX_Unmarshal 

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

type RetrieveBlocksRequest 

type RetrieveBlocksRequest struct {
	DAHeight uint64 `protobuf:"varint,1,opt,name=da_height,json=daHeight,proto3" json:"da_height,omitempty"`
}

func (*RetrieveBlocksRequest) Descriptor 

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

func (*RetrieveBlocksRequest) GetDAHeight 

func (m *RetrieveBlocksRequest) GetDAHeight() uint64

func (*RetrieveBlocksRequest) Marshal 

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

func (*RetrieveBlocksRequest) MarshalTo 

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

func (*RetrieveBlocksRequest) MarshalToSizedBuffer 

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

func (*RetrieveBlocksRequest) ProtoMessage 

func (*RetrieveBlocksRequest) ProtoMessage()

func (*RetrieveBlocksRequest) Reset 

func (m *RetrieveBlocksRequest) Reset()

func (*RetrieveBlocksRequest) Size 

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

func (*RetrieveBlocksRequest) String 

func (m *RetrieveBlocksRequest) String() string

func (*RetrieveBlocksRequest) Unmarshal 

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

func (*RetrieveBlocksRequest) XXX_DiscardUnknown 

func (m *RetrieveBlocksRequest) XXX_DiscardUnknown()

func (*RetrieveBlocksRequest) XXX_Marshal 

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

func (*RetrieveBlocksRequest) XXX_Merge 

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

func (*RetrieveBlocksRequest) XXX_Size 

func (m *RetrieveBlocksRequest) XXX_Size() int

func (*RetrieveBlocksRequest) XXX_Unmarshal 

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

type RetrieveBlocksResponse 

type RetrieveBlocksResponse struct {
	Result *DAResponse      `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Blocks []*rollkit.Block `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

func (*RetrieveBlocksResponse) Descriptor 

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

func (*RetrieveBlocksResponse) GetBlocks 

func (m *RetrieveBlocksResponse) GetBlocks() []*rollkit.Block

func (*RetrieveBlocksResponse) GetResult 

func (m *RetrieveBlocksResponse) GetResult() *DAResponse

func (*RetrieveBlocksResponse) Marshal 

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

func (*RetrieveBlocksResponse) MarshalTo 

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

func (*RetrieveBlocksResponse) MarshalToSizedBuffer 

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

func (*RetrieveBlocksResponse) ProtoMessage 

func (*RetrieveBlocksResponse) ProtoMessage()

func (*RetrieveBlocksResponse) Reset 

func (m *RetrieveBlocksResponse) Reset()

func (*RetrieveBlocksResponse) Size 

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

func (*RetrieveBlocksResponse) String 

func (m *RetrieveBlocksResponse) String() string

func (*RetrieveBlocksResponse) Unmarshal 

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

func (*RetrieveBlocksResponse) XXX_DiscardUnknown 

func (m *RetrieveBlocksResponse) XXX_DiscardUnknown()

func (*RetrieveBlocksResponse) XXX_Marshal 

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

func (*RetrieveBlocksResponse) XXX_Merge 

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

func (*RetrieveBlocksResponse) XXX_Size 

func (m *RetrieveBlocksResponse) XXX_Size() int

func (*RetrieveBlocksResponse) XXX_Unmarshal 

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

type StatusCode 

type StatusCode int32
const (
	StatusCode_STATUS_CODE_UNSPECIFIED StatusCode = 0
	StatusCode_STATUS_CODE_SUCCESS     StatusCode = 1
	StatusCode_STATUS_CODE_TIMEOUT     StatusCode = 2
	StatusCode_STATUS_CODE_ERROR       StatusCode = 3
)

func (StatusCode) EnumDescriptor 

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

func (StatusCode) String 

func (x StatusCode) String() string

type SubmitBlockRequest 

type SubmitBlockRequest struct {
	Block *rollkit.Block `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
}

func (*SubmitBlockRequest) Descriptor 

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

func (*SubmitBlockRequest) GetBlock 

func (m *SubmitBlockRequest) GetBlock() *rollkit.Block

func (*SubmitBlockRequest) Marshal 

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

func (*SubmitBlockRequest) MarshalTo 

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

func (*SubmitBlockRequest) MarshalToSizedBuffer 

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

func (*SubmitBlockRequest) ProtoMessage 

func (*SubmitBlockRequest) ProtoMessage()

func (*SubmitBlockRequest) Reset 

func (m *SubmitBlockRequest) Reset()

func (*SubmitBlockRequest) Size 

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

func (*SubmitBlockRequest) String 

func (m *SubmitBlockRequest) String() string

func (*SubmitBlockRequest) Unmarshal 

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

func (*SubmitBlockRequest) XXX_DiscardUnknown 

func (m *SubmitBlockRequest) XXX_DiscardUnknown()

func (*SubmitBlockRequest) XXX_Marshal 

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

func (*SubmitBlockRequest) XXX_Merge 

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

func (*SubmitBlockRequest) XXX_Size 

func (m *SubmitBlockRequest) XXX_Size() int

func (*SubmitBlockRequest) XXX_Unmarshal 

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

type SubmitBlockResponse 

type SubmitBlockResponse struct {
	Result *DAResponse `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*SubmitBlockResponse) Descriptor 

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

func (*SubmitBlockResponse) GetResult 

func (m *SubmitBlockResponse) GetResult() *DAResponse

func (*SubmitBlockResponse) Marshal 

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

func (*SubmitBlockResponse) MarshalTo 

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

func (*SubmitBlockResponse) MarshalToSizedBuffer 

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

func (*SubmitBlockResponse) ProtoMessage 

func (*SubmitBlockResponse) ProtoMessage()

func (*SubmitBlockResponse) Reset 

func (m *SubmitBlockResponse) Reset()

func (*SubmitBlockResponse) Size 

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

func (*SubmitBlockResponse) String 

func (m *SubmitBlockResponse) String() string

func (*SubmitBlockResponse) Unmarshal 

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

func (*SubmitBlockResponse) XXX_DiscardUnknown 

func (m *SubmitBlockResponse) XXX_DiscardUnknown()

func (*SubmitBlockResponse) XXX_Marshal 

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

func (*SubmitBlockResponse) XXX_Merge 

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

func (*SubmitBlockResponse) XXX_Size 

func (m *SubmitBlockResponse) XXX_Size() int

func (*SubmitBlockResponse) XXX_Unmarshal 

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

type UnimplementedDALCServiceServer 

type UnimplementedDALCServiceServer struct {
}

UnimplementedDALCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDALCServiceServer) CheckBlockAvailability 

func (*UnimplementedDALCServiceServer) CheckBlockAvailability(ctx context.Context, req *CheckBlockAvailabilityRequest) (*CheckBlockAvailabilityResponse, error)

func (*UnimplementedDALCServiceServer) RetrieveBlocks 

func (*UnimplementedDALCServiceServer) RetrieveBlocks(ctx context.Context, req *RetrieveBlocksRequest) (*RetrieveBlocksResponse, error)

func (*UnimplementedDALCServiceServer) SubmitBlock 

func (*UnimplementedDALCServiceServer) SubmitBlock(ctx context.Context, req *SubmitBlockRequest) (*SubmitBlockResponse, 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.