Documentation
¶
Index ¶
- Variables
- func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
- type Address
- type ManagerClient
- type ManagerServer
- type Manager_RedirectClient
- type Manager_RedirectServer
- type PprofRequest
- type PprofResponse
- type PsRequest
- type PsResponse
- type PsResponse_ProcessInfo
- func (*PsResponse_ProcessInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PsResponse_ProcessInfo) GetListenAddresses() []*Address
- func (x *PsResponse_ProcessInfo) GetName() string
- func (x *PsResponse_ProcessInfo) GetPid() uint64
- func (x *PsResponse_ProcessInfo) GetPpid() uint64
- func (*PsResponse_ProcessInfo) ProtoMessage()
- func (x *PsResponse_ProcessInfo) ProtoReflect() protoreflect.Message
- func (x *PsResponse_ProcessInfo) Reset()
- func (x *PsResponse_ProcessInfo) String() string
- type RedirectRequest
- func (*RedirectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RedirectRequest) GetOutgoing() bool
- func (x *RedirectRequest) GetPort() uint32
- func (*RedirectRequest) ProtoMessage()
- func (x *RedirectRequest) ProtoReflect() protoreflect.Message
- func (x *RedirectRequest) Reset()
- func (x *RedirectRequest) String() string
- type RedirectResponse
- type UnimplementedManagerServer
- type UnsafeManagerServer
Constants ¶
This section is empty.
Variables ¶
var File_kdiag_api_proto protoreflect.FileDescriptor
var Manager_ServiceDesc = grpc.ServiceDesc{
ServiceName: "kdiag.solo.io.Manager",
HandlerType: (*ManagerServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Ps",
Handler: _Manager_Ps_Handler,
},
{
MethodName: "Pprof",
Handler: _Manager_Pprof_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "Redirect",
Handler: _Manager_Redirect_Handler,
ServerStreams: true,
},
},
Metadata: "kdiag/api.proto",
}
Manager_ServiceDesc is the grpc.ServiceDesc for Manager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServer ¶
func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)
Types ¶
type Address ¶
type Address struct {
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*Address) Descriptor
deprecated
func (*Address) Descriptor() ([]byte, []int)
Deprecated: Use Address.ProtoReflect.Descriptor instead.
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
type ManagerClient ¶
type ManagerClient interface {
// Stream Envoy access logs as they are captured.
Redirect(ctx context.Context, in *RedirectRequest, opts ...grpc.CallOption) (Manager_RedirectClient, error)
Ps(ctx context.Context, in *PsRequest, opts ...grpc.CallOption) (*PsResponse, error)
Pprof(ctx context.Context, in *PprofRequest, opts ...grpc.CallOption) (*PprofResponse, error)
}
ManagerClient is the client API for Manager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewManagerClient ¶
func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient
type ManagerServer ¶
type ManagerServer interface {
// Stream Envoy access logs as they are captured.
Redirect(*RedirectRequest, Manager_RedirectServer) error
Ps(context.Context, *PsRequest) (*PsResponse, error)
Pprof(context.Context, *PprofRequest) (*PprofResponse, error)
// contains filtered or unexported methods
}
ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility
type Manager_RedirectClient ¶
type Manager_RedirectClient interface {
Recv() (*RedirectResponse, error)
grpc.ClientStream
}
type Manager_RedirectServer ¶
type Manager_RedirectServer interface {
Send(*RedirectResponse) error
grpc.ServerStream
}
type PprofRequest ¶
type PprofRequest struct {
Pid uint64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
// contains filtered or unexported fields
}
func (*PprofRequest) Descriptor
deprecated
func (*PprofRequest) Descriptor() ([]byte, []int)
Deprecated: Use PprofRequest.ProtoReflect.Descriptor instead.
func (*PprofRequest) ProtoMessage ¶
func (*PprofRequest) ProtoMessage()
func (*PprofRequest) ProtoReflect ¶
func (x *PprofRequest) ProtoReflect() protoreflect.Message
type PprofResponse ¶
type PprofResponse struct {
// port to connect to and get the profile
Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*PprofResponse) Descriptor
deprecated
func (*PprofResponse) Descriptor() ([]byte, []int)
Deprecated: Use PprofResponse.ProtoReflect.Descriptor instead.
func (*PprofResponse) ProtoMessage ¶
func (*PprofResponse) ProtoMessage()
func (*PprofResponse) ProtoReflect ¶
func (x *PprofResponse) ProtoReflect() protoreflect.Message
type PsRequest ¶
type PsRequest struct {
// contains filtered or unexported fields
}
func (*PsRequest) Descriptor
deprecated
func (*PsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PsRequest.ProtoReflect.Descriptor instead.
func (*PsRequest) ProtoMessage ¶
func (*PsRequest) ProtoMessage()
func (*PsRequest) ProtoReflect ¶
func (x *PsRequest) ProtoReflect() protoreflect.Message
type PsResponse ¶
type PsResponse struct {
Processes []*PsResponse_ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
// contains filtered or unexported fields
}
func (*PsResponse) Descriptor
deprecated
func (*PsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PsResponse.ProtoReflect.Descriptor instead.
func (*PsResponse) GetProcesses ¶
func (x *PsResponse) GetProcesses() []*PsResponse_ProcessInfo
func (*PsResponse) ProtoMessage ¶
func (*PsResponse) ProtoMessage()
func (*PsResponse) ProtoReflect ¶
func (x *PsResponse) ProtoReflect() protoreflect.Message
type PsResponse_ProcessInfo ¶
type PsResponse_ProcessInfo struct {
Pid uint64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
Ppid uint64 `protobuf:"varint,2,opt,name=ppid,proto3" json:"ppid,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
ListenAddresses []*Address `protobuf:"bytes,5,rep,name=listen_addresses,json=listenAddresses,proto3" json:"listen_addresses,omitempty"`
// contains filtered or unexported fields
}
func (*PsResponse_ProcessInfo) Descriptor
deprecated
func (*PsResponse_ProcessInfo) Descriptor() ([]byte, []int)
Deprecated: Use PsResponse_ProcessInfo.ProtoReflect.Descriptor instead.
func (*PsResponse_ProcessInfo) GetListenAddresses ¶
func (x *PsResponse_ProcessInfo) GetListenAddresses() []*Address
func (*PsResponse_ProcessInfo) ProtoMessage ¶
func (*PsResponse_ProcessInfo) ProtoMessage()
func (*PsResponse_ProcessInfo) ProtoReflect ¶
func (x *PsResponse_ProcessInfo) ProtoReflect() protoreflect.Message
type RedirectRequest ¶
type RedirectRequest struct {
Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
Outgoing bool `protobuf:"varint,2,opt,name=outgoing,proto3" json:"outgoing,omitempty"`
// contains filtered or unexported fields
}
func (*RedirectRequest) Descriptor
deprecated
func (*RedirectRequest) Descriptor() ([]byte, []int)
Deprecated: Use RedirectRequest.ProtoReflect.Descriptor instead.
func (*RedirectRequest) GetOutgoing ¶
func (x *RedirectRequest) GetOutgoing() bool
func (*RedirectRequest) ProtoMessage ¶
func (*RedirectRequest) ProtoMessage()
func (*RedirectRequest) ProtoReflect ¶
func (x *RedirectRequest) ProtoReflect() protoreflect.Message
type RedirectResponse ¶
type RedirectResponse struct {
Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*RedirectResponse) Descriptor
deprecated
func (*RedirectResponse) Descriptor() ([]byte, []int)
Deprecated: Use RedirectResponse.ProtoReflect.Descriptor instead.
func (*RedirectResponse) ProtoMessage ¶
func (*RedirectResponse) ProtoMessage()
func (*RedirectResponse) ProtoReflect ¶
func (x *RedirectResponse) ProtoReflect() protoreflect.Message
type UnimplementedManagerServer ¶
type UnimplementedManagerServer struct {
}
UnimplementedManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedManagerServer) Pprof ¶
func (UnimplementedManagerServer) Pprof(context.Context, *PprofRequest) (*PprofResponse, error)
type UnsafeManagerServer ¶
type UnsafeManagerServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServer will result in compilation errors.