dalc

package
v0.5.0-zeta Latest Latest
Warning

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

 Go to latest Published: May 12, 2023 License: Apache-2.0 Imports: 10 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 CheckBatchAvailabilityRequest 

type CheckBatchAvailabilityRequest struct {
	DataLayerHeight uint64 `protobuf:"varint,1,opt,name=data_layer_height,json=dataLayerHeight,proto3" json:"data_layer_height,omitempty"`
}

func (*CheckBatchAvailabilityRequest) Descriptor 

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

func (*CheckBatchAvailabilityRequest) GetDataLayerHeight 

func (m *CheckBatchAvailabilityRequest) GetDataLayerHeight() uint64

func (*CheckBatchAvailabilityRequest) Marshal 

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

func (*CheckBatchAvailabilityRequest) MarshalTo 

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

func (*CheckBatchAvailabilityRequest) MarshalToSizedBuffer 

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

func (*CheckBatchAvailabilityRequest) ProtoMessage 

func (*CheckBatchAvailabilityRequest) ProtoMessage()

func (*CheckBatchAvailabilityRequest) Reset 

func (m *CheckBatchAvailabilityRequest) Reset()

func (*CheckBatchAvailabilityRequest) Size 

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

func (*CheckBatchAvailabilityRequest) String 

func (m *CheckBatchAvailabilityRequest) String() string

func (*CheckBatchAvailabilityRequest) Unmarshal 

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

func (*CheckBatchAvailabilityRequest) XXX_DiscardUnknown 

func (m *CheckBatchAvailabilityRequest) XXX_DiscardUnknown()

func (*CheckBatchAvailabilityRequest) XXX_Marshal 

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

func (*CheckBatchAvailabilityRequest) XXX_Merge 

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

func (*CheckBatchAvailabilityRequest) XXX_Size 

func (m *CheckBatchAvailabilityRequest) XXX_Size() int

func (*CheckBatchAvailabilityRequest) XXX_Unmarshal 

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

type CheckBatchAvailabilityResponse 

type CheckBatchAvailabilityResponse 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 (*CheckBatchAvailabilityResponse) Descriptor 

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

func (*CheckBatchAvailabilityResponse) GetDataAvailable 

func (m *CheckBatchAvailabilityResponse) GetDataAvailable() bool

func (*CheckBatchAvailabilityResponse) GetResult 

func (m *CheckBatchAvailabilityResponse) GetResult() *DAResponse

func (*CheckBatchAvailabilityResponse) Marshal 

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

func (*CheckBatchAvailabilityResponse) MarshalTo 

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

func (*CheckBatchAvailabilityResponse) MarshalToSizedBuffer 

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

func (*CheckBatchAvailabilityResponse) ProtoMessage 

func (*CheckBatchAvailabilityResponse) ProtoMessage()

func (*CheckBatchAvailabilityResponse) Reset 

func (m *CheckBatchAvailabilityResponse) Reset()

func (*CheckBatchAvailabilityResponse) Size 

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

func (*CheckBatchAvailabilityResponse) String 

func (m *CheckBatchAvailabilityResponse) String() string

func (*CheckBatchAvailabilityResponse) Unmarshal 

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

func (*CheckBatchAvailabilityResponse) XXX_DiscardUnknown 

func (m *CheckBatchAvailabilityResponse) XXX_DiscardUnknown()

func (*CheckBatchAvailabilityResponse) XXX_Marshal 

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

func (*CheckBatchAvailabilityResponse) XXX_Merge 

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

func (*CheckBatchAvailabilityResponse) XXX_Size 

func (m *CheckBatchAvailabilityResponse) XXX_Size() int

func (*CheckBatchAvailabilityResponse) XXX_Unmarshal 

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

type DALCServiceClient 

type DALCServiceClient interface {
	SubmitBatch(ctx context.Context, in *SubmitBatchRequest, opts ...grpc.CallOption) (*SubmitBatchResponse, error)
	CheckBatchAvailability(ctx context.Context, in *CheckBatchAvailabilityRequest, opts ...grpc.CallOption) (*CheckBatchAvailabilityResponse, error)
	RetrieveBatches(ctx context.Context, in *RetrieveBatchesRequest, opts ...grpc.CallOption) (*RetrieveBatchesResponse, 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 {
	SubmitBatch(context.Context, *SubmitBatchRequest) (*SubmitBatchResponse, error)
	CheckBatchAvailability(context.Context, *CheckBatchAvailabilityRequest) (*CheckBatchAvailabilityResponse, error)
	RetrieveBatches(context.Context, *RetrieveBatchesRequest) (*RetrieveBatchesResponse, 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"`
	DataLayerHeight uint64     `protobuf:"varint,3,opt,name=data_layer_height,json=dataLayerHeight,proto3" json:"data_layer_height,omitempty"`
}

func (*DAResponse) Descriptor 

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

func (*DAResponse) GetCode 

func (m *DAResponse) GetCode() StatusCode

func (*DAResponse) GetDataLayerHeight 

func (m *DAResponse) GetDataLayerHeight() 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 RetrieveBatchesRequest 

type RetrieveBatchesRequest struct {
	DataLayerHeight uint64 `protobuf:"varint,1,opt,name=data_layer_height,json=dataLayerHeight,proto3" json:"data_layer_height,omitempty"`
}

func (*RetrieveBatchesRequest) Descriptor 

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

func (*RetrieveBatchesRequest) GetDataLayerHeight 

func (m *RetrieveBatchesRequest) GetDataLayerHeight() uint64

func (*RetrieveBatchesRequest) Marshal 

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

func (*RetrieveBatchesRequest) MarshalTo 

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

func (*RetrieveBatchesRequest) MarshalToSizedBuffer 

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

func (*RetrieveBatchesRequest) ProtoMessage 

func (*RetrieveBatchesRequest) ProtoMessage()

func (*RetrieveBatchesRequest) Reset 

func (m *RetrieveBatchesRequest) Reset()

func (*RetrieveBatchesRequest) Size 

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

func (*RetrieveBatchesRequest) String 

func (m *RetrieveBatchesRequest) String() string

func (*RetrieveBatchesRequest) Unmarshal 

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

func (*RetrieveBatchesRequest) XXX_DiscardUnknown 

func (m *RetrieveBatchesRequest) XXX_DiscardUnknown()

func (*RetrieveBatchesRequest) XXX_Marshal 

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

func (*RetrieveBatchesRequest) XXX_Merge 

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

func (*RetrieveBatchesRequest) XXX_Size 

func (m *RetrieveBatchesRequest) XXX_Size() int

func (*RetrieveBatchesRequest) XXX_Unmarshal 

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

type RetrieveBatchesResponse 

type RetrieveBatchesResponse struct {
	Result  *DAResponse      `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Batches []*furyint.Batch `protobuf:"bytes,2,rep,name=batches,proto3" json:"batches,omitempty"`
}

func (*RetrieveBatchesResponse) Descriptor 

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

func (*RetrieveBatchesResponse) GetBatches 

func (m *RetrieveBatchesResponse) GetBatches() []*furyint.Batch

func (*RetrieveBatchesResponse) GetResult 

func (m *RetrieveBatchesResponse) GetResult() *DAResponse

func (*RetrieveBatchesResponse) Marshal 

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

func (*RetrieveBatchesResponse) MarshalTo 

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

func (*RetrieveBatchesResponse) MarshalToSizedBuffer 

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

func (*RetrieveBatchesResponse) ProtoMessage 

func (*RetrieveBatchesResponse) ProtoMessage()

func (*RetrieveBatchesResponse) Reset 

func (m *RetrieveBatchesResponse) Reset()

func (*RetrieveBatchesResponse) Size 

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

func (*RetrieveBatchesResponse) String 

func (m *RetrieveBatchesResponse) String() string

func (*RetrieveBatchesResponse) Unmarshal 

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

func (*RetrieveBatchesResponse) XXX_DiscardUnknown 

func (m *RetrieveBatchesResponse) XXX_DiscardUnknown()

func (*RetrieveBatchesResponse) XXX_Marshal 

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

func (*RetrieveBatchesResponse) XXX_Merge 

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

func (*RetrieveBatchesResponse) XXX_Size 

func (m *RetrieveBatchesResponse) XXX_Size() int

func (*RetrieveBatchesResponse) XXX_Unmarshal 

func (m *RetrieveBatchesResponse) 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 SubmitBatchRequest 

type SubmitBatchRequest struct {
	Batch *furyint.Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
}

func (*SubmitBatchRequest) Descriptor 

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

func (*SubmitBatchRequest) GetBatch 

func (m *SubmitBatchRequest) GetBatch() *furyint.Batch

func (*SubmitBatchRequest) Marshal 

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

func (*SubmitBatchRequest) MarshalTo 

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

func (*SubmitBatchRequest) MarshalToSizedBuffer 

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

func (*SubmitBatchRequest) ProtoMessage 

func (*SubmitBatchRequest) ProtoMessage()

func (*SubmitBatchRequest) Reset 

func (m *SubmitBatchRequest) Reset()

func (*SubmitBatchRequest) Size 

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

func (*SubmitBatchRequest) String 

func (m *SubmitBatchRequest) String() string

func (*SubmitBatchRequest) Unmarshal 

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

func (*SubmitBatchRequest) XXX_DiscardUnknown 

func (m *SubmitBatchRequest) XXX_DiscardUnknown()

func (*SubmitBatchRequest) XXX_Marshal 

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

func (*SubmitBatchRequest) XXX_Merge 

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

func (*SubmitBatchRequest) XXX_Size 

func (m *SubmitBatchRequest) XXX_Size() int

func (*SubmitBatchRequest) XXX_Unmarshal 

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

type SubmitBatchResponse 

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

func (*SubmitBatchResponse) Descriptor 

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

func (*SubmitBatchResponse) GetResult 

func (m *SubmitBatchResponse) GetResult() *DAResponse

func (*SubmitBatchResponse) Marshal 

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

func (*SubmitBatchResponse) MarshalTo 

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

func (*SubmitBatchResponse) MarshalToSizedBuffer 

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

func (*SubmitBatchResponse) ProtoMessage 

func (*SubmitBatchResponse) ProtoMessage()

func (*SubmitBatchResponse) Reset 

func (m *SubmitBatchResponse) Reset()

func (*SubmitBatchResponse) Size 

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

func (*SubmitBatchResponse) String 

func (m *SubmitBatchResponse) String() string

func (*SubmitBatchResponse) Unmarshal 

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

func (*SubmitBatchResponse) XXX_DiscardUnknown 

func (m *SubmitBatchResponse) XXX_DiscardUnknown()

func (*SubmitBatchResponse) XXX_Marshal 

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

func (*SubmitBatchResponse) XXX_Merge 

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

func (*SubmitBatchResponse) XXX_Size 

func (m *SubmitBatchResponse) XXX_Size() int

func (*SubmitBatchResponse) XXX_Unmarshal 

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

type UnimplementedDALCServiceServer 

type UnimplementedDALCServiceServer struct {
}

UnimplementedDALCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDALCServiceServer) CheckBatchAvailability 

func (*UnimplementedDALCServiceServer) CheckBatchAvailability(ctx context.Context, req *CheckBatchAvailabilityRequest) (*CheckBatchAvailabilityResponse, error)

func (*UnimplementedDALCServiceServer) RetrieveBatches 

func (*UnimplementedDALCServiceServer) RetrieveBatches(ctx context.Context, req *RetrieveBatchesRequest) (*RetrieveBatchesResponse, error)

func (*UnimplementedDALCServiceServer) SubmitBatch 

func (*UnimplementedDALCServiceServer) SubmitBatch(ctx context.Context, req *SubmitBatchRequest) (*SubmitBatchResponse, 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.