profilerpb

Documentation

Index

• Variables
• func RegisterProfilerServer(s grpc.ServiceRegistrar, srv ProfilerServer)
• type Op
  • func (Op) Descriptor() protoreflect.EnumDescriptor
  • func (x Op) Enum() *Op
  • func (Op) EnumDescriptor() ([]byte, []int)
  • func (x Op) Number() protoreflect.EnumNumber
  • func (x Op) String() string
  • func (Op) Type() protoreflect.EnumType
• type ProfilerClient
  • func NewProfilerClient(cc grpc.ClientConnInterface) ProfilerClient
• type ProfilerOPRequest
  • func (*ProfilerOPRequest) Descriptor() ([]byte, []int)
  • func (x *ProfilerOPRequest) GetPortNumber() int32
  • func (x *ProfilerOPRequest) GetRequestOp() Op
  • func (*ProfilerOPRequest) ProtoMessage()
  • func (x *ProfilerOPRequest) ProtoReflect() protoreflect.Message
  • func (x *ProfilerOPRequest) Reset()
  • func (x *ProfilerOPRequest) String() string
• type ProfilerOPResponse
  • func (*ProfilerOPResponse) Descriptor() ([]byte, []int)
  • func (x *ProfilerOPResponse) GetProfilerAddr() string
  • func (*ProfilerOPResponse) ProtoMessage()
  • func (x *ProfilerOPResponse) ProtoReflect() protoreflect.Message
  • func (x *ProfilerOPResponse) Reset()
  • func (x *ProfilerOPResponse) String() string
• type ProfilerServer
• type UnimplementedProfilerServer
  • func (UnimplementedProfilerServer) ProfilerOP(context.Context, *ProfilerOPRequest) (*ProfilerOPResponse, error)
• type UnsafeProfilerServer

Variables

var (
	Op_name = map[int32]string{
		0: "SHOW",
		1: "ENABLE",
		2: "DISABLE",
	}
	Op_value = map[string]int32{
		"SHOW":    0,
		"ENABLE":  1,
		"DISABLE": 2,
	}
)

Enum value maps for Op.

var File_profiler_proto protoreflect.FileDescriptor

var Profiler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "longhorn.common.profiler.Profiler",
	HandlerType: (*ProfilerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProfilerOP",
			Handler:    _Profiler_ProfilerOP_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "profiler.proto",
}

Profiler_ServiceDesc is the grpc.ServiceDesc for Profiler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterProfilerServer

func RegisterProfilerServer(s grpc.ServiceRegistrar, srv ProfilerServer)

Types

type Op

type Op int32

const (
	Op_SHOW    Op = 0
	Op_ENABLE  Op = 1
	Op_DISABLE Op = 2
)

func (Op) Descriptor

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum

func (x Op) Enum() *Op

func (Op) EnumDescriptor

func (Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use Op.Descriptor instead.

func (Op) Number

func (x Op) Number() protoreflect.EnumNumber

func (Op) String

func (x Op) String() string

func (Op) Type

func (Op) Type() protoreflect.EnumType

type ProfilerClient

type ProfilerClient interface {
	ProfilerOP(ctx context.Context, in *ProfilerOPRequest, opts ...grpc.CallOption) (*ProfilerOPResponse, error)
}

ProfilerClient is the client API for Profiler 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 NewProfilerClient

func NewProfilerClient(cc grpc.ClientConnInterface) ProfilerClient

type ProfilerOPRequest

type ProfilerOPRequest struct {
	RequestOp  Op    `protobuf:"varint,1,opt,name=request_op,json=requestOp,proto3,enum=longhorn.common.profiler.Op" json:"request_op,omitempty"`
	PortNumber int32 `protobuf:"varint,2,opt,name=port_number,json=portNumber,proto3" json:"port_number,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfilerOPRequest) Descriptor

func (*ProfilerOPRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProfilerOPRequest.ProtoReflect.Descriptor instead.

func (*ProfilerOPRequest) GetPortNumber

func (x *ProfilerOPRequest) GetPortNumber() int32

func (*ProfilerOPRequest) GetRequestOp

func (x *ProfilerOPRequest) GetRequestOp() Op

func (*ProfilerOPRequest) ProtoMessage

func (*ProfilerOPRequest) ProtoMessage()

func (*ProfilerOPRequest) ProtoReflect

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

func (*ProfilerOPRequest) Reset

func (x *ProfilerOPRequest) Reset()

func (*ProfilerOPRequest) String

func (x *ProfilerOPRequest) String() string

type ProfilerOPResponse

type ProfilerOPResponse struct {
	ProfilerAddr string `protobuf:"bytes,1,opt,name=profiler_addr,json=profilerAddr,proto3" json:"profiler_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfilerOPResponse) Descriptor

func (*ProfilerOPResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProfilerOPResponse.ProtoReflect.Descriptor instead.

func (*ProfilerOPResponse) GetProfilerAddr

func (x *ProfilerOPResponse) GetProfilerAddr() string

func (*ProfilerOPResponse) ProtoMessage

func (*ProfilerOPResponse) ProtoMessage()

func (*ProfilerOPResponse) ProtoReflect

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

func (*ProfilerOPResponse) Reset

func (x *ProfilerOPResponse) Reset()

func (*ProfilerOPResponse) String

func (x *ProfilerOPResponse) String() string

type ProfilerServer

type ProfilerServer interface {
	ProfilerOP(context.Context, *ProfilerOPRequest) (*ProfilerOPResponse, error)
	// contains filtered or unexported methods
}

ProfilerServer is the server API for Profiler service. All implementations must embed UnimplementedProfilerServer for forward compatibility

type UnimplementedProfilerServer

type UnimplementedProfilerServer struct {
}

UnimplementedProfilerServer must be embedded to have forward compatible implementations.

func (UnimplementedProfilerServer) ProfilerOP

func (UnimplementedProfilerServer) ProfilerOP(context.Context, *ProfilerOPRequest) (*ProfilerOPResponse, error)

type UnsafeProfilerServer

type UnsafeProfilerServer interface {
	// contains filtered or unexported methods
}

UnsafeProfilerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProfilerServer will result in compilation errors.