dalc

package
v0.11.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 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 DALCServiceClient 

type DALCServiceClient interface {
	SubmitBlocks(ctx context.Context, in *SubmitBlocksRequest, opts ...grpc.CallOption) (*SubmitBlocksResponse, 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 {
	SubmitBlocks(context.Context, *SubmitBlocksRequest) (*SubmitBlocksResponse, 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 SubmitBlocksRequest added in v0.10.0 

type SubmitBlocksRequest struct {
	Blocks []*rollkit.Block `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

func (*SubmitBlocksRequest) Descriptor added in v0.10.0 

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

func (*SubmitBlocksRequest) GetBlocks added in v0.10.0 

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

func (*SubmitBlocksRequest) Marshal added in v0.10.0 

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

func (*SubmitBlocksRequest) MarshalTo added in v0.10.0 

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

func (*SubmitBlocksRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*SubmitBlocksRequest) ProtoMessage added in v0.10.0 

func (*SubmitBlocksRequest) ProtoMessage()

func (*SubmitBlocksRequest) Reset added in v0.10.0 

func (m *SubmitBlocksRequest) Reset()

func (*SubmitBlocksRequest) Size added in v0.10.0 

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

func (*SubmitBlocksRequest) String added in v0.10.0 

func (m *SubmitBlocksRequest) String() string

func (*SubmitBlocksRequest) Unmarshal added in v0.10.0 

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

func (*SubmitBlocksRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *SubmitBlocksRequest) XXX_DiscardUnknown()

func (*SubmitBlocksRequest) XXX_Marshal added in v0.10.0 

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

func (*SubmitBlocksRequest) XXX_Merge added in v0.10.0 

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

func (*SubmitBlocksRequest) XXX_Size added in v0.10.0 

func (m *SubmitBlocksRequest) XXX_Size() int

func (*SubmitBlocksRequest) XXX_Unmarshal added in v0.10.0 

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

type SubmitBlocksResponse added in v0.10.0 

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

func (*SubmitBlocksResponse) Descriptor added in v0.10.0 

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

func (*SubmitBlocksResponse) GetResult added in v0.10.0 

func (m *SubmitBlocksResponse) GetResult() *DAResponse

func (*SubmitBlocksResponse) Marshal added in v0.10.0 

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

func (*SubmitBlocksResponse) MarshalTo added in v0.10.0 

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

func (*SubmitBlocksResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*SubmitBlocksResponse) ProtoMessage added in v0.10.0 

func (*SubmitBlocksResponse) ProtoMessage()

func (*SubmitBlocksResponse) Reset added in v0.10.0 

func (m *SubmitBlocksResponse) Reset()

func (*SubmitBlocksResponse) Size added in v0.10.0 

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

func (*SubmitBlocksResponse) String added in v0.10.0 

func (m *SubmitBlocksResponse) String() string

func (*SubmitBlocksResponse) Unmarshal added in v0.10.0 

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

func (*SubmitBlocksResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *SubmitBlocksResponse) XXX_DiscardUnknown()

func (*SubmitBlocksResponse) XXX_Marshal added in v0.10.0 

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

func (*SubmitBlocksResponse) XXX_Merge added in v0.10.0 

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

func (*SubmitBlocksResponse) XXX_Size added in v0.10.0 

func (m *SubmitBlocksResponse) XXX_Size() int

func (*SubmitBlocksResponse) XXX_Unmarshal added in v0.10.0 

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

type UnimplementedDALCServiceServer 

type UnimplementedDALCServiceServer struct {
}

UnimplementedDALCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDALCServiceServer) RetrieveBlocks 

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

func (*UnimplementedDALCServiceServer) SubmitBlocks added in v0.10.0 

func (*UnimplementedDALCServiceServer) SubmitBlocks(ctx context.Context, req *SubmitBlocksRequest) (*SubmitBlocksResponse, 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.