v1

package
v0.3.4 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SyncService_StreamBlocks_FullMethodName = "/blobcast.syncapis.v1.SyncService/StreamBlocks"
)

Variables

View Source 
var File_blobcast_syncapis_v1_chunk_with_hash_proto protoreflect.FileDescriptor
View Source 
var File_blobcast_syncapis_v1_stream_blocks_request_proto protoreflect.FileDescriptor
View Source 
var File_blobcast_syncapis_v1_stream_blocks_response_proto protoreflect.FileDescriptor
View Source 
var File_blobcast_syncapis_v1_sync_service_proto protoreflect.FileDescriptor
View Source 
var SyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "blobcast.syncapis.v1.SyncService",
	HandlerType: (*SyncServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamBlocks",
			Handler:       _SyncService_StreamBlocks_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "blobcast/syncapis/v1/sync_service.proto",
}

SyncService_ServiceDesc is the grpc.ServiceDesc for SyncService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSyncServiceServer 

func RegisterSyncServiceServer(s grpc.ServiceRegistrar, srv SyncServiceServer)

Types

type ChunkWithHash 

type ChunkWithHash struct {
	ChunkData []byte `protobuf:"bytes,1,opt,name=chunk_data,json=chunkData,proto3" json:"chunk_data,omitempty"`
	ChunkHash []byte `protobuf:"bytes,2,opt,name=chunk_hash,json=chunkHash,proto3" json:"chunk_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkWithHash) Descriptor deprecated 

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

Deprecated: Use ChunkWithHash.ProtoReflect.Descriptor instead.

func (*ChunkWithHash) GetChunkData 

func (x *ChunkWithHash) GetChunkData() []byte

func (*ChunkWithHash) GetChunkHash 

func (x *ChunkWithHash) GetChunkHash() []byte

func (*ChunkWithHash) ProtoMessage 

func (*ChunkWithHash) ProtoMessage()

func (*ChunkWithHash) ProtoReflect 

func (x *ChunkWithHash) ProtoReflect() protoreflect.Message

func (*ChunkWithHash) Reset 

func (x *ChunkWithHash) Reset()

func (*ChunkWithHash) String 

func (x *ChunkWithHash) String() string

type StreamBlocksRequest 

type StreamBlocksRequest struct {
	StartHeight uint64 `protobuf:"varint,1,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
	EndHeight   uint64 `protobuf:"varint,2,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"`
	BatchSize   uint32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamBlocksRequest) Descriptor deprecated 

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

Deprecated: Use StreamBlocksRequest.ProtoReflect.Descriptor instead.

func (*StreamBlocksRequest) GetBatchSize 

func (x *StreamBlocksRequest) GetBatchSize() uint32

func (*StreamBlocksRequest) GetEndHeight 

func (x *StreamBlocksRequest) GetEndHeight() uint64

func (*StreamBlocksRequest) GetStartHeight 

func (x *StreamBlocksRequest) GetStartHeight() uint64

func (*StreamBlocksRequest) ProtoMessage 

func (*StreamBlocksRequest) ProtoMessage()

func (*StreamBlocksRequest) ProtoReflect 

func (x *StreamBlocksRequest) ProtoReflect() protoreflect.Message

func (*StreamBlocksRequest) Reset 

func (x *StreamBlocksRequest) Reset()

func (*StreamBlocksRequest) String 

func (x *StreamBlocksRequest) String() string

type StreamBlocksResponse 

type StreamBlocksResponse struct {
	Block       *v1.Block                `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	Chunks      []*ChunkWithHash         `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"`
	Files       []*v11.FileManifest      `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"`
	Dirs        []*v11.DirectoryManifest `protobuf:"bytes,4,rep,name=dirs,proto3" json:"dirs,omitempty"`
	MmrSnapshot []byte                   `protobuf:"bytes,5,opt,name=mmr_snapshot,json=mmrSnapshot,proto3" json:"mmr_snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamBlocksResponse) Descriptor deprecated 

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

Deprecated: Use StreamBlocksResponse.ProtoReflect.Descriptor instead.

func (*StreamBlocksResponse) GetBlock 

func (x *StreamBlocksResponse) GetBlock() *v1.Block

func (*StreamBlocksResponse) GetChunks 

func (x *StreamBlocksResponse) GetChunks() []*ChunkWithHash

func (*StreamBlocksResponse) GetDirs 

func (x *StreamBlocksResponse) GetDirs() []*v11.DirectoryManifest

func (*StreamBlocksResponse) GetFiles 

func (x *StreamBlocksResponse) GetFiles() []*v11.FileManifest

func (*StreamBlocksResponse) GetMmrSnapshot 

func (x *StreamBlocksResponse) GetMmrSnapshot() []byte

func (*StreamBlocksResponse) ProtoMessage 

func (*StreamBlocksResponse) ProtoMessage()

func (*StreamBlocksResponse) ProtoReflect 

func (x *StreamBlocksResponse) ProtoReflect() protoreflect.Message

func (*StreamBlocksResponse) Reset 

func (x *StreamBlocksResponse) Reset()

func (*StreamBlocksResponse) String 

func (x *StreamBlocksResponse) String() string

type SyncServiceClient 

type SyncServiceClient interface {
	StreamBlocks(ctx context.Context, in *StreamBlocksRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamBlocksResponse], error)
}

SyncServiceClient is the client API for SyncService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSyncServiceClient 

func NewSyncServiceClient(cc grpc.ClientConnInterface) SyncServiceClient

type SyncServiceServer 

type SyncServiceServer interface {
	StreamBlocks(*StreamBlocksRequest, grpc.ServerStreamingServer[StreamBlocksResponse]) error
	// contains filtered or unexported methods
}

SyncServiceServer is the server API for SyncService service. All implementations must embed UnimplementedSyncServiceServer for forward compatibility.

type SyncService_StreamBlocksClient 

type SyncService_StreamBlocksClient = grpc.ServerStreamingClient[StreamBlocksResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SyncService_StreamBlocksServer 

type SyncService_StreamBlocksServer = grpc.ServerStreamingServer[StreamBlocksResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedSyncServiceServer 

type UnimplementedSyncServiceServer struct{}

UnimplementedSyncServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSyncServiceServer) StreamBlocks 

func (UnimplementedSyncServiceServer) StreamBlocks(*StreamBlocksRequest, grpc.ServerStreamingServer[StreamBlocksResponse]) error

type UnsafeSyncServiceServer 

type UnsafeSyncServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSyncServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncServiceServer will result in compilation errors.

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.