dalc

package
v0.0.0-...-568787c Latest Latest
Warning

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

Go to latest
Published: Dec 29, 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 (*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 (*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 (*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

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 []*dymint.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() []*dymint.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 *dymint.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() *dymint.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) RetrieveBatches

func (*UnimplementedDALCServiceServer) SubmitBatch

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL