kdiag

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_kdiag_api_proto protoreflect.FileDescriptor
View Source 
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) GetIp 

func (x *Address) GetIp() string

func (*Address) GetPort 

func (x *Address) GetPort() uint32

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

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://pkg.go.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) GetPid 

func (x *PprofRequest) GetPid() uint64

func (*PprofRequest) ProtoMessage 

func (*PprofRequest) ProtoMessage()

func (*PprofRequest) ProtoReflect 

func (x *PprofRequest) ProtoReflect() protoreflect.Message

func (*PprofRequest) Reset 

func (x *PprofRequest) Reset()

func (*PprofRequest) String 

func (x *PprofRequest) String() string

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) GetPort 

func (x *PprofResponse) GetPort() uint32

func (*PprofResponse) ProtoMessage 

func (*PprofResponse) ProtoMessage()

func (*PprofResponse) ProtoReflect 

func (x *PprofResponse) ProtoReflect() protoreflect.Message

func (*PprofResponse) Reset 

func (x *PprofResponse) Reset()

func (*PprofResponse) String 

func (x *PprofResponse) String() string

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

func (*PsRequest) Reset 

func (x *PsRequest) Reset()

func (*PsRequest) String 

func (x *PsRequest) String() string

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

func (*PsResponse) Reset 

func (x *PsResponse) Reset()

func (*PsResponse) String 

func (x *PsResponse) String() string

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) GetName 

func (x *PsResponse_ProcessInfo) GetName() string

func (*PsResponse_ProcessInfo) GetPid 

func (x *PsResponse_ProcessInfo) GetPid() uint64

func (*PsResponse_ProcessInfo) GetPpid 

func (x *PsResponse_ProcessInfo) GetPpid() uint64

func (*PsResponse_ProcessInfo) ProtoMessage 

func (*PsResponse_ProcessInfo) ProtoMessage()

func (*PsResponse_ProcessInfo) ProtoReflect 

func (x *PsResponse_ProcessInfo) ProtoReflect() protoreflect.Message

func (*PsResponse_ProcessInfo) Reset 

func (x *PsResponse_ProcessInfo) Reset()

func (*PsResponse_ProcessInfo) String 

func (x *PsResponse_ProcessInfo) String() string

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) GetPort 

func (x *RedirectRequest) GetPort() uint32

func (*RedirectRequest) ProtoMessage 

func (*RedirectRequest) ProtoMessage()

func (*RedirectRequest) ProtoReflect 

func (x *RedirectRequest) ProtoReflect() protoreflect.Message

func (*RedirectRequest) Reset 

func (x *RedirectRequest) Reset()

func (*RedirectRequest) String 

func (x *RedirectRequest) String() string

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) GetPort 

func (x *RedirectResponse) GetPort() uint32

func (*RedirectResponse) ProtoMessage 

func (*RedirectResponse) ProtoMessage()

func (*RedirectResponse) ProtoReflect 

func (x *RedirectResponse) ProtoReflect() protoreflect.Message

func (*RedirectResponse) Reset 

func (x *RedirectResponse) Reset()

func (*RedirectResponse) String 

func (x *RedirectResponse) String() string

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)

func (UnimplementedManagerServer) Ps 

func (UnimplementedManagerServer) Ps(context.Context, *PsRequest) (*PsResponse, error)

func (UnimplementedManagerServer) Redirect 

func (UnimplementedManagerServer) Redirect(*RedirectRequest, Manager_RedirectServer) 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.

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.