Versions in this module Expand all Collapse all v1 v1.0.0 Nov 28, 2024 Changes in this version + const Shredstream_SendHeartbeat_FullMethodName + var File_shredstream_proto protoreflect.FileDescriptor + var Shredstream_ServiceDesc = grpc.ServiceDesc + func RegisterShredstreamServer(s grpc.ServiceRegistrar, srv ShredstreamServer) + type Heartbeat struct + Regions []string + Socket *shared.Socket + func (*Heartbeat) Descriptor() ([]byte, []int) + func (*Heartbeat) ProtoMessage() + func (x *Heartbeat) GetRegions() []string + func (x *Heartbeat) GetSocket() *shared.Socket + func (x *Heartbeat) ProtoReflect() protoreflect.Message + func (x *Heartbeat) Reset() + func (x *Heartbeat) String() string + type HeartbeatResponse struct + TtlMs uint32 + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (x *HeartbeatResponse) GetTtlMs() uint32 + func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatResponse) Reset() + func (x *HeartbeatResponse) String() string + type ShredstreamClient interface + SendHeartbeat func(ctx context.Context, in *Heartbeat, opts ...grpc.CallOption) (*HeartbeatResponse, error) + func NewShredstreamClient(cc grpc.ClientConnInterface) ShredstreamClient + type ShredstreamServer interface + SendHeartbeat func(context.Context, *Heartbeat) (*HeartbeatResponse, error) + type UnimplementedShredstreamServer struct + func (UnimplementedShredstreamServer) SendHeartbeat(context.Context, *Heartbeat) (*HeartbeatResponse, error) + type UnsafeShredstreamServer interface
Go to main page