Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterLinkServer(s grpc.ServiceRegistrar, srv LinkServer)
- type LinkClient
- type LinkServer
- type Link_WatchLocalLinksClient
- type Link_WatchLocalLinksServer
- type SimulateLinkStateRequest
- func (*SimulateLinkStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SimulateLinkStateRequest) GetDisabled() bool
- func (x *SimulateLinkStateRequest) GetJitter() int64
- func (x *SimulateLinkStateRequest) GetLocalRegion() string
- func (x *SimulateLinkStateRequest) GetPacketLoss() float64
- func (x *SimulateLinkStateRequest) GetRemoteRegion() string
- func (x *SimulateLinkStateRequest) GetRtt() int64
- func (x *SimulateLinkStateRequest) GetTimeout() int64
- func (*SimulateLinkStateRequest) ProtoMessage()
- func (x *SimulateLinkStateRequest) ProtoReflect() protoreflect.Message
- func (x *SimulateLinkStateRequest) Reset()
- func (x *SimulateLinkStateRequest) String() string
- type SimulateLinkStateResponse
- type UnimplementedLinkServer
- type UnsafeLinkServer
- type WatchLocalLinksRequest
- type WatchLocalLinksResponse
- func (*WatchLocalLinksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchLocalLinksResponse) GetDisabled() bool
- func (x *WatchLocalLinksResponse) GetJitter() int64
- func (x *WatchLocalLinksResponse) GetLastRead() *timestamppb.Timestamp
- func (x *WatchLocalLinksResponse) GetLocalRegion() string
- func (x *WatchLocalLinksResponse) GetPacketLoss() float64
- func (x *WatchLocalLinksResponse) GetRemoteRegion() string
- func (x *WatchLocalLinksResponse) GetRtt() int64
- func (*WatchLocalLinksResponse) ProtoMessage()
- func (x *WatchLocalLinksResponse) ProtoReflect() protoreflect.Message
- func (x *WatchLocalLinksResponse) Reset()
- func (x *WatchLocalLinksResponse) String() string
Constants ¶
const ( Link_WatchLocalLinks_FullMethodName = "/rpc.Link/WatchLocalLinks" Link_SimulateLinkState_FullMethodName = "/rpc.Link/SimulateLinkState" )
Variables ¶
var File_infra_link_proto protoreflect.FileDescriptor
var Link_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rpc.Link", HandlerType: (*LinkServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SimulateLinkState", Handler: _Link_SimulateLinkState_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchLocalLinks", Handler: _Link_WatchLocalLinks_Handler, ServerStreams: true, }, }, Metadata: "infra/link.proto", }
Link_ServiceDesc is the grpc.ServiceDesc for Link service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLinkServer ¶
func RegisterLinkServer(s grpc.ServiceRegistrar, srv LinkServer)
Types ¶
type LinkClient ¶
type LinkClient interface { WatchLocalLinks(ctx context.Context, in *WatchLocalLinksRequest, opts ...grpc.CallOption) (Link_WatchLocalLinksClient, error) SimulateLinkState(ctx context.Context, in *SimulateLinkStateRequest, opts ...grpc.CallOption) (*SimulateLinkStateResponse, error) }
LinkClient is the client API for Link 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 NewLinkClient ¶
func NewLinkClient(cc grpc.ClientConnInterface) LinkClient
type LinkServer ¶
type LinkServer interface { WatchLocalLinks(*WatchLocalLinksRequest, Link_WatchLocalLinksServer) error SimulateLinkState(context.Context, *SimulateLinkStateRequest) (*SimulateLinkStateResponse, error) // contains filtered or unexported methods }
LinkServer is the server API for Link service. All implementations must embed UnimplementedLinkServer for forward compatibility
type Link_WatchLocalLinksClient ¶
type Link_WatchLocalLinksClient interface { Recv() (*WatchLocalLinksResponse, error) grpc.ClientStream }
type Link_WatchLocalLinksServer ¶
type Link_WatchLocalLinksServer interface { Send(*WatchLocalLinksResponse) error grpc.ServerStream }
type SimulateLinkStateRequest ¶
type SimulateLinkStateRequest struct { LocalRegion string `protobuf:"bytes,1,opt,name=local_region,json=localRegion,proto3" json:"local_region,omitempty"` RemoteRegion string `protobuf:"bytes,2,opt,name=remote_region,json=remoteRegion,proto3" json:"remote_region,omitempty"` Rtt *int64 `protobuf:"varint,3,opt,name=rtt,proto3,oneof" json:"rtt,omitempty"` Jitter *int64 `protobuf:"varint,4,opt,name=jitter,proto3,oneof" json:"jitter,omitempty"` PacketLoss *float64 `protobuf:"fixed64,5,opt,name=packet_loss,json=packetLoss,proto3,oneof" json:"packet_loss,omitempty"` Disabled *bool `protobuf:"varint,6,opt,name=disabled,proto3,oneof" json:"disabled,omitempty"` Timeout int64 `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*SimulateLinkStateRequest) Descriptor
deprecated
func (*SimulateLinkStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimulateLinkStateRequest.ProtoReflect.Descriptor instead.
func (*SimulateLinkStateRequest) GetDisabled ¶
func (x *SimulateLinkStateRequest) GetDisabled() bool
func (*SimulateLinkStateRequest) GetJitter ¶
func (x *SimulateLinkStateRequest) GetJitter() int64
func (*SimulateLinkStateRequest) GetLocalRegion ¶
func (x *SimulateLinkStateRequest) GetLocalRegion() string
func (*SimulateLinkStateRequest) GetPacketLoss ¶
func (x *SimulateLinkStateRequest) GetPacketLoss() float64
func (*SimulateLinkStateRequest) GetRemoteRegion ¶
func (x *SimulateLinkStateRequest) GetRemoteRegion() string
func (*SimulateLinkStateRequest) GetRtt ¶
func (x *SimulateLinkStateRequest) GetRtt() int64
func (*SimulateLinkStateRequest) GetTimeout ¶
func (x *SimulateLinkStateRequest) GetTimeout() int64
func (*SimulateLinkStateRequest) ProtoMessage ¶
func (*SimulateLinkStateRequest) ProtoMessage()
func (*SimulateLinkStateRequest) ProtoReflect ¶
func (x *SimulateLinkStateRequest) ProtoReflect() protoreflect.Message
func (*SimulateLinkStateRequest) Reset ¶
func (x *SimulateLinkStateRequest) Reset()
func (*SimulateLinkStateRequest) String ¶
func (x *SimulateLinkStateRequest) String() string
type SimulateLinkStateResponse ¶
type SimulateLinkStateResponse struct {
// contains filtered or unexported fields
}
func (*SimulateLinkStateResponse) Descriptor
deprecated
func (*SimulateLinkStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use SimulateLinkStateResponse.ProtoReflect.Descriptor instead.
func (*SimulateLinkStateResponse) ProtoMessage ¶
func (*SimulateLinkStateResponse) ProtoMessage()
func (*SimulateLinkStateResponse) ProtoReflect ¶
func (x *SimulateLinkStateResponse) ProtoReflect() protoreflect.Message
func (*SimulateLinkStateResponse) Reset ¶
func (x *SimulateLinkStateResponse) Reset()
func (*SimulateLinkStateResponse) String ¶
func (x *SimulateLinkStateResponse) String() string
type UnimplementedLinkServer ¶
type UnimplementedLinkServer struct { }
UnimplementedLinkServer must be embedded to have forward compatible implementations.
func (UnimplementedLinkServer) SimulateLinkState ¶
func (UnimplementedLinkServer) SimulateLinkState(context.Context, *SimulateLinkStateRequest) (*SimulateLinkStateResponse, error)
func (UnimplementedLinkServer) WatchLocalLinks ¶
func (UnimplementedLinkServer) WatchLocalLinks(*WatchLocalLinksRequest, Link_WatchLocalLinksServer) error
type UnsafeLinkServer ¶
type UnsafeLinkServer interface {
// contains filtered or unexported methods
}
UnsafeLinkServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LinkServer will result in compilation errors.
type WatchLocalLinksRequest ¶
type WatchLocalLinksRequest struct {
// contains filtered or unexported fields
}
func (*WatchLocalLinksRequest) Descriptor
deprecated
func (*WatchLocalLinksRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchLocalLinksRequest.ProtoReflect.Descriptor instead.
func (*WatchLocalLinksRequest) ProtoMessage ¶
func (*WatchLocalLinksRequest) ProtoMessage()
func (*WatchLocalLinksRequest) ProtoReflect ¶
func (x *WatchLocalLinksRequest) ProtoReflect() protoreflect.Message
func (*WatchLocalLinksRequest) Reset ¶
func (x *WatchLocalLinksRequest) Reset()
func (*WatchLocalLinksRequest) String ¶
func (x *WatchLocalLinksRequest) String() string
type WatchLocalLinksResponse ¶
type WatchLocalLinksResponse struct { LocalRegion string `protobuf:"bytes,1,opt,name=local_region,json=localRegion,proto3" json:"local_region,omitempty"` RemoteRegion string `protobuf:"bytes,2,opt,name=remote_region,json=remoteRegion,proto3" json:"remote_region,omitempty"` Rtt int64 `protobuf:"varint,3,opt,name=rtt,proto3" json:"rtt,omitempty"` Jitter int64 `protobuf:"varint,4,opt,name=jitter,proto3" json:"jitter,omitempty"` PacketLoss float64 `protobuf:"fixed64,5,opt,name=packet_loss,json=packetLoss,proto3" json:"packet_loss,omitempty"` Disabled bool `protobuf:"varint,6,opt,name=disabled,proto3" json:"disabled,omitempty"` LastRead *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_read,json=lastRead,proto3" json:"last_read,omitempty"` // contains filtered or unexported fields }
func (*WatchLocalLinksResponse) Descriptor
deprecated
func (*WatchLocalLinksResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchLocalLinksResponse.ProtoReflect.Descriptor instead.
func (*WatchLocalLinksResponse) GetDisabled ¶
func (x *WatchLocalLinksResponse) GetDisabled() bool
func (*WatchLocalLinksResponse) GetJitter ¶
func (x *WatchLocalLinksResponse) GetJitter() int64
func (*WatchLocalLinksResponse) GetLastRead ¶ added in v1.9.3
func (x *WatchLocalLinksResponse) GetLastRead() *timestamppb.Timestamp
func (*WatchLocalLinksResponse) GetLocalRegion ¶
func (x *WatchLocalLinksResponse) GetLocalRegion() string
func (*WatchLocalLinksResponse) GetPacketLoss ¶
func (x *WatchLocalLinksResponse) GetPacketLoss() float64
func (*WatchLocalLinksResponse) GetRemoteRegion ¶
func (x *WatchLocalLinksResponse) GetRemoteRegion() string
func (*WatchLocalLinksResponse) GetRtt ¶
func (x *WatchLocalLinksResponse) GetRtt() int64
func (*WatchLocalLinksResponse) ProtoMessage ¶
func (*WatchLocalLinksResponse) ProtoMessage()
func (*WatchLocalLinksResponse) ProtoReflect ¶
func (x *WatchLocalLinksResponse) ProtoReflect() protoreflect.Message
func (*WatchLocalLinksResponse) Reset ¶
func (x *WatchLocalLinksResponse) Reset()
func (*WatchLocalLinksResponse) String ¶
func (x *WatchLocalLinksResponse) String() string