Versions in this module Expand all Collapse all v1 v1.0.0 Nov 28, 2024 Changes in this version + const Relayer_GetTpuConfigs_FullMethodName + const Relayer_SubscribePackets_FullMethodName + var File_relayer_proto protoreflect.FileDescriptor + var Relayer_ServiceDesc = grpc.ServiceDesc + func RegisterRelayerServer(s grpc.ServiceRegistrar, srv RelayerServer) + type GetTpuConfigsRequest struct + func (*GetTpuConfigsRequest) Descriptor() ([]byte, []int) + func (*GetTpuConfigsRequest) ProtoMessage() + func (x *GetTpuConfigsRequest) ProtoReflect() protoreflect.Message + func (x *GetTpuConfigsRequest) Reset() + func (x *GetTpuConfigsRequest) String() string + type GetTpuConfigsResponse struct + Tpu *shared.Socket + TpuForward *shared.Socket + func (*GetTpuConfigsResponse) Descriptor() ([]byte, []int) + func (*GetTpuConfigsResponse) ProtoMessage() + func (x *GetTpuConfigsResponse) GetTpu() *shared.Socket + func (x *GetTpuConfigsResponse) GetTpuForward() *shared.Socket + func (x *GetTpuConfigsResponse) ProtoReflect() protoreflect.Message + func (x *GetTpuConfigsResponse) Reset() + func (x *GetTpuConfigsResponse) String() string + type RelayerClient interface + GetTpuConfigs func(ctx context.Context, in *GetTpuConfigsRequest, opts ...grpc.CallOption) (*GetTpuConfigsResponse, error) + SubscribePackets func(ctx context.Context, in *SubscribePacketsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribePacketsResponse], error) + func NewRelayerClient(cc grpc.ClientConnInterface) RelayerClient + type RelayerServer interface + GetTpuConfigs func(context.Context, *GetTpuConfigsRequest) (*GetTpuConfigsResponse, error) + SubscribePackets func(*SubscribePacketsRequest, grpc.ServerStreamingServer[SubscribePacketsResponse]) error + type Relayer_SubscribePacketsClient = grpc.ServerStreamingClient[SubscribePacketsResponse] + type Relayer_SubscribePacketsServer = grpc.ServerStreamingServer[SubscribePacketsResponse] + type SubscribePacketsRequest struct + func (*SubscribePacketsRequest) Descriptor() ([]byte, []int) + func (*SubscribePacketsRequest) ProtoMessage() + func (x *SubscribePacketsRequest) ProtoReflect() protoreflect.Message + func (x *SubscribePacketsRequest) Reset() + func (x *SubscribePacketsRequest) String() string + type SubscribePacketsResponse struct + Header *shared.Header + Msg isSubscribePacketsResponse_Msg + func (*SubscribePacketsResponse) Descriptor() ([]byte, []int) + func (*SubscribePacketsResponse) ProtoMessage() + func (m *SubscribePacketsResponse) GetMsg() isSubscribePacketsResponse_Msg + func (x *SubscribePacketsResponse) GetBatch() *packet.PacketBatch + func (x *SubscribePacketsResponse) GetHeader() *shared.Header + func (x *SubscribePacketsResponse) GetHeartbeat() *shared.Heartbeat + func (x *SubscribePacketsResponse) ProtoReflect() protoreflect.Message + func (x *SubscribePacketsResponse) Reset() + func (x *SubscribePacketsResponse) String() string + type SubscribePacketsResponse_Batch struct + Batch *packet.PacketBatch + type SubscribePacketsResponse_Heartbeat struct + Heartbeat *shared.Heartbeat + type UnimplementedRelayerServer struct + func (UnimplementedRelayerServer) GetTpuConfigs(context.Context, *GetTpuConfigsRequest) (*GetTpuConfigsResponse, error) + func (UnimplementedRelayerServer) SubscribePackets(*SubscribePacketsRequest, grpc.ServerStreamingServer[SubscribePacketsResponse]) error + type UnsafeRelayerServer interface
Go to main page