infra

package
v1.9.8 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Link_WatchLocalLinks_FullMethodName   = "/rpc.Link/WatchLocalLinks"
	Link_SimulateLinkState_FullMethodName = "/rpc.Link/SimulateLinkState"
)

Variables

View Source 
var File_infra_link_proto protoreflect.FileDescriptor
View Source 
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 interface {
	Recv() (*WatchLocalLinksResponse, error)
	grpc.ClientStream
}
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(*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

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.