debug

package
v2.6.0-nightly.20230425 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDebug        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDebug          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDebug = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var SetLogLevelRequest_LogLevel_name = map[int32]string{
	0: "UNKNOWN",
	1: "DEBUG",
	2: "INFO",
	3: "ERROR",
	4: "OFF",
}
View Source 
var SetLogLevelRequest_LogLevel_value = map[string]int32{
	"UNKNOWN": 0,
	"DEBUG":   1,
	"INFO":    2,
	"ERROR":   3,
	"OFF":     4,
}

Functions

func RegisterDebugServer 

func RegisterDebugServer(s *grpc.Server, srv DebugServer)

Types

type BinaryRequest 

type BinaryRequest struct {
	Filter               *Filter  `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BinaryRequest) Descriptor 

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

func (*BinaryRequest) GetFilter 

func (m *BinaryRequest) GetFilter() *Filter

func (*BinaryRequest) Marshal 

func (m *BinaryRequest) Marshal() (dAtA []byte, err error)

func (*BinaryRequest) MarshalLogObject 

func (x *BinaryRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*BinaryRequest) MarshalTo 

func (m *BinaryRequest) MarshalTo(dAtA []byte) (int, error)

func (*BinaryRequest) MarshalToSizedBuffer 

func (m *BinaryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BinaryRequest) ProtoMessage 

func (*BinaryRequest) ProtoMessage()

func (*BinaryRequest) Reset 

func (m *BinaryRequest) Reset()

func (*BinaryRequest) Size 

func (m *BinaryRequest) Size() (n int)

func (*BinaryRequest) String 

func (m *BinaryRequest) String() string

func (*BinaryRequest) Unmarshal 

func (m *BinaryRequest) Unmarshal(dAtA []byte) error

func (*BinaryRequest) XXX_DiscardUnknown 

func (m *BinaryRequest) XXX_DiscardUnknown()

func (*BinaryRequest) XXX_Marshal 

func (m *BinaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BinaryRequest) XXX_Merge 

func (m *BinaryRequest) XXX_Merge(src proto.Message)

func (*BinaryRequest) XXX_Size 

func (m *BinaryRequest) XXX_Size() int

func (*BinaryRequest) XXX_Unmarshal 

func (m *BinaryRequest) XXX_Unmarshal(b []byte) error

type DebugClient 

type DebugClient interface {
	Profile(ctx context.Context, in *ProfileRequest, opts ...grpc.CallOption) (Debug_ProfileClient, error)
	Binary(ctx context.Context, in *BinaryRequest, opts ...grpc.CallOption) (Debug_BinaryClient, error)
	Dump(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (Debug_DumpClient, error)
	SetLogLevel(ctx context.Context, in *SetLogLevelRequest, opts ...grpc.CallOption) (*SetLogLevelResponse, error)
}

DebugClient is the client API for Debug service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDebugClient 

func NewDebugClient(cc *grpc.ClientConn) DebugClient

type DebugServer 

type DebugServer interface {
	Profile(*ProfileRequest, Debug_ProfileServer) error
	Binary(*BinaryRequest, Debug_BinaryServer) error
	Dump(*DumpRequest, Debug_DumpServer) error
	SetLogLevel(context.Context, *SetLogLevelRequest) (*SetLogLevelResponse, error)
}

DebugServer is the server API for Debug service.

type Debug_BinaryClient 

type Debug_BinaryClient interface {
	Recv() (*types.BytesValue, error)
	grpc.ClientStream
}

type Debug_BinaryServer 

type Debug_BinaryServer interface {
	Send(*types.BytesValue) error
	grpc.ServerStream
}

type Debug_DumpClient 

type Debug_DumpClient interface {
	Recv() (*types.BytesValue, error)
	grpc.ClientStream
}

type Debug_DumpServer 

type Debug_DumpServer interface {
	Send(*types.BytesValue) error
	grpc.ServerStream
}

type Debug_ProfileClient 

type Debug_ProfileClient interface {
	Recv() (*types.BytesValue, error)
	grpc.ClientStream
}

type Debug_ProfileServer 

type Debug_ProfileServer interface {
	Send(*types.BytesValue) error
	grpc.ServerStream
}

type DumpRequest 

type DumpRequest struct {
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// Limit sets the limit for the number of commits / jobs that are returned for each repo / pipeline in the dump.
	Limit                int64    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DumpRequest) Descriptor 

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

func (*DumpRequest) GetFilter 

func (m *DumpRequest) GetFilter() *Filter

func (*DumpRequest) GetLimit 

func (m *DumpRequest) GetLimit() int64

func (*DumpRequest) Marshal 

func (m *DumpRequest) Marshal() (dAtA []byte, err error)

func (*DumpRequest) MarshalLogObject 

func (x *DumpRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DumpRequest) MarshalTo 

func (m *DumpRequest) MarshalTo(dAtA []byte) (int, error)

func (*DumpRequest) MarshalToSizedBuffer 

func (m *DumpRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DumpRequest) ProtoMessage 

func (*DumpRequest) ProtoMessage()

func (*DumpRequest) Reset 

func (m *DumpRequest) Reset()

func (*DumpRequest) Size 

func (m *DumpRequest) Size() (n int)

func (*DumpRequest) String 

func (m *DumpRequest) String() string

func (*DumpRequest) Unmarshal 

func (m *DumpRequest) Unmarshal(dAtA []byte) error

func (*DumpRequest) XXX_DiscardUnknown 

func (m *DumpRequest) XXX_DiscardUnknown()

func (*DumpRequest) XXX_Marshal 

func (m *DumpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DumpRequest) XXX_Merge 

func (m *DumpRequest) XXX_Merge(src proto.Message)

func (*DumpRequest) XXX_Size 

func (m *DumpRequest) XXX_Size() int

func (*DumpRequest) XXX_Unmarshal 

func (m *DumpRequest) XXX_Unmarshal(b []byte) error

type Filter 

type Filter struct {
	// Types that are valid to be assigned to Filter:
	//	*Filter_Pachd
	//	*Filter_Pipeline
	//	*Filter_Worker
	//	*Filter_Database
	Filter               isFilter_Filter `protobuf_oneof:"filter"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetDatabase 

func (m *Filter) GetDatabase() bool

func (*Filter) GetFilter 

func (m *Filter) GetFilter() isFilter_Filter

func (*Filter) GetPachd 

func (m *Filter) GetPachd() bool

func (*Filter) GetPipeline 

func (m *Filter) GetPipeline() *pps.Pipeline

func (*Filter) GetWorker 

func (m *Filter) GetWorker() *Worker

func (*Filter) Marshal 

func (m *Filter) Marshal() (dAtA []byte, err error)

func (*Filter) MarshalLogObject 

func (x *Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Filter) MarshalTo 

func (m *Filter) MarshalTo(dAtA []byte) (int, error)

func (*Filter) MarshalToSizedBuffer 

func (m *Filter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) Size 

func (m *Filter) Size() (n int)

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) Unmarshal 

func (m *Filter) Unmarshal(dAtA []byte) error

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_OneofWrappers 

func (*Filter) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

type Filter_Database 

type Filter_Database struct {
	Database bool `protobuf:"varint,4,opt,name=database,proto3,oneof" json:"database,omitempty"`
}

func (*Filter_Database) MarshalTo 

func (m *Filter_Database) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Database) MarshalToSizedBuffer 

func (m *Filter_Database) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Database) Size 

func (m *Filter_Database) Size() (n int)

type Filter_Pachd 

type Filter_Pachd struct {
	Pachd bool `protobuf:"varint,1,opt,name=pachd,proto3,oneof" json:"pachd,omitempty"`
}

func (*Filter_Pachd) MarshalTo 

func (m *Filter_Pachd) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Pachd) MarshalToSizedBuffer 

func (m *Filter_Pachd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Pachd) Size 

func (m *Filter_Pachd) Size() (n int)

type Filter_Pipeline 

type Filter_Pipeline struct {
	Pipeline *pps.Pipeline `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof" json:"pipeline,omitempty"`
}

func (*Filter_Pipeline) MarshalTo 

func (m *Filter_Pipeline) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Pipeline) MarshalToSizedBuffer 

func (m *Filter_Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Pipeline) Size 

func (m *Filter_Pipeline) Size() (n int)

type Filter_Worker 

type Filter_Worker struct {
	Worker *Worker `protobuf:"bytes,3,opt,name=worker,proto3,oneof" json:"worker,omitempty"`
}

func (*Filter_Worker) MarshalTo 

func (m *Filter_Worker) MarshalTo(dAtA []byte) (int, error)

func (*Filter_Worker) MarshalToSizedBuffer 

func (m *Filter_Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Filter_Worker) Size 

func (m *Filter_Worker) Size() (n int)

type Profile 

type Profile struct {
	Name                 string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Duration             *types.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Profile) Descriptor 

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

func (*Profile) GetDuration 

func (m *Profile) GetDuration() *types.Duration

func (*Profile) GetName 

func (m *Profile) GetName() string

func (*Profile) Marshal 

func (m *Profile) Marshal() (dAtA []byte, err error)

func (*Profile) MarshalLogObject 

func (x *Profile) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Profile) MarshalTo 

func (m *Profile) MarshalTo(dAtA []byte) (int, error)

func (*Profile) MarshalToSizedBuffer 

func (m *Profile) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) Reset 

func (m *Profile) Reset()

func (*Profile) Size 

func (m *Profile) Size() (n int)

func (*Profile) String 

func (m *Profile) String() string

func (*Profile) Unmarshal 

func (m *Profile) Unmarshal(dAtA []byte) error

func (*Profile) XXX_DiscardUnknown 

func (m *Profile) XXX_DiscardUnknown()

func (*Profile) XXX_Marshal 

func (m *Profile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Profile) XXX_Merge 

func (m *Profile) XXX_Merge(src proto.Message)

func (*Profile) XXX_Size 

func (m *Profile) XXX_Size() int

func (*Profile) XXX_Unmarshal 

func (m *Profile) XXX_Unmarshal(b []byte) error

type ProfileRequest 

type ProfileRequest struct {
	Profile              *Profile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	Filter               *Filter  `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProfileRequest) Descriptor 

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

func (*ProfileRequest) GetFilter 

func (m *ProfileRequest) GetFilter() *Filter

func (*ProfileRequest) GetProfile 

func (m *ProfileRequest) GetProfile() *Profile

func (*ProfileRequest) Marshal 

func (m *ProfileRequest) Marshal() (dAtA []byte, err error)

func (*ProfileRequest) MarshalLogObject 

func (x *ProfileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ProfileRequest) MarshalTo 

func (m *ProfileRequest) MarshalTo(dAtA []byte) (int, error)

func (*ProfileRequest) MarshalToSizedBuffer 

func (m *ProfileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProfileRequest) ProtoMessage 

func (*ProfileRequest) ProtoMessage()

func (*ProfileRequest) Reset 

func (m *ProfileRequest) Reset()

func (*ProfileRequest) Size 

func (m *ProfileRequest) Size() (n int)

func (*ProfileRequest) String 

func (m *ProfileRequest) String() string

func (*ProfileRequest) Unmarshal 

func (m *ProfileRequest) Unmarshal(dAtA []byte) error

func (*ProfileRequest) XXX_DiscardUnknown 

func (m *ProfileRequest) XXX_DiscardUnknown()

func (*ProfileRequest) XXX_Marshal 

func (m *ProfileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileRequest) XXX_Merge 

func (m *ProfileRequest) XXX_Merge(src proto.Message)

func (*ProfileRequest) XXX_Size 

func (m *ProfileRequest) XXX_Size() int

func (*ProfileRequest) XXX_Unmarshal 

func (m *ProfileRequest) XXX_Unmarshal(b []byte) error

type SetLogLevelRequest 

type SetLogLevelRequest struct {
	// Types that are valid to be assigned to Level:
	//	*SetLogLevelRequest_Pachyderm
	//	*SetLogLevelRequest_Grpc
	Level                isSetLogLevelRequest_Level `protobuf_oneof:"level"`
	Duration             *types.Duration            `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	Recurse              bool                       `protobuf:"varint,4,opt,name=recurse,proto3" json:"recurse,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*SetLogLevelRequest) Descriptor 

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

func (*SetLogLevelRequest) GetDuration 

func (m *SetLogLevelRequest) GetDuration() *types.Duration

func (*SetLogLevelRequest) GetGrpc 

func (m *SetLogLevelRequest) GetGrpc() SetLogLevelRequest_LogLevel

func (*SetLogLevelRequest) GetLevel 

func (m *SetLogLevelRequest) GetLevel() isSetLogLevelRequest_Level

func (*SetLogLevelRequest) GetPachyderm 

func (m *SetLogLevelRequest) GetPachyderm() SetLogLevelRequest_LogLevel

func (*SetLogLevelRequest) GetRecurse 

func (m *SetLogLevelRequest) GetRecurse() bool

func (*SetLogLevelRequest) Marshal 

func (m *SetLogLevelRequest) Marshal() (dAtA []byte, err error)

func (*SetLogLevelRequest) MarshalLogObject 

func (x *SetLogLevelRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SetLogLevelRequest) MarshalTo 

func (m *SetLogLevelRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetLogLevelRequest) MarshalToSizedBuffer 

func (m *SetLogLevelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetLogLevelRequest) ProtoMessage 

func (*SetLogLevelRequest) ProtoMessage()

func (*SetLogLevelRequest) Reset 

func (m *SetLogLevelRequest) Reset()

func (*SetLogLevelRequest) Size 

func (m *SetLogLevelRequest) Size() (n int)

func (*SetLogLevelRequest) String 

func (m *SetLogLevelRequest) String() string

func (*SetLogLevelRequest) Unmarshal 

func (m *SetLogLevelRequest) Unmarshal(dAtA []byte) error

func (*SetLogLevelRequest) XXX_DiscardUnknown 

func (m *SetLogLevelRequest) XXX_DiscardUnknown()

func (*SetLogLevelRequest) XXX_Marshal 

func (m *SetLogLevelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetLogLevelRequest) XXX_Merge 

func (m *SetLogLevelRequest) XXX_Merge(src proto.Message)

func (*SetLogLevelRequest) XXX_OneofWrappers 

func (*SetLogLevelRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SetLogLevelRequest) XXX_Size 

func (m *SetLogLevelRequest) XXX_Size() int

func (*SetLogLevelRequest) XXX_Unmarshal 

func (m *SetLogLevelRequest) XXX_Unmarshal(b []byte) error

type SetLogLevelRequest_Grpc 

type SetLogLevelRequest_Grpc struct {
	Grpc SetLogLevelRequest_LogLevel `protobuf:"varint,2,opt,name=grpc,proto3,enum=debug_v2.SetLogLevelRequest_LogLevel,oneof" json:"grpc,omitempty"`
}

func (*SetLogLevelRequest_Grpc) MarshalTo 

func (m *SetLogLevelRequest_Grpc) MarshalTo(dAtA []byte) (int, error)

func (*SetLogLevelRequest_Grpc) MarshalToSizedBuffer 

func (m *SetLogLevelRequest_Grpc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetLogLevelRequest_Grpc) Size 

func (m *SetLogLevelRequest_Grpc) Size() (n int)

type SetLogLevelRequest_LogLevel 

type SetLogLevelRequest_LogLevel int32
const (
	SetLogLevelRequest_UNKNOWN SetLogLevelRequest_LogLevel = 0
	SetLogLevelRequest_DEBUG   SetLogLevelRequest_LogLevel = 1
	SetLogLevelRequest_INFO    SetLogLevelRequest_LogLevel = 2
	SetLogLevelRequest_ERROR   SetLogLevelRequest_LogLevel = 3
	SetLogLevelRequest_OFF     SetLogLevelRequest_LogLevel = 4
)

func (SetLogLevelRequest_LogLevel) EnumDescriptor 

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

func (SetLogLevelRequest_LogLevel) String 

func (x SetLogLevelRequest_LogLevel) String() string

type SetLogLevelRequest_Pachyderm 

type SetLogLevelRequest_Pachyderm struct {
	Pachyderm SetLogLevelRequest_LogLevel `protobuf:"varint,1,opt,name=pachyderm,proto3,enum=debug_v2.SetLogLevelRequest_LogLevel,oneof" json:"pachyderm,omitempty"`
}

func (*SetLogLevelRequest_Pachyderm) MarshalTo 

func (m *SetLogLevelRequest_Pachyderm) MarshalTo(dAtA []byte) (int, error)

func (*SetLogLevelRequest_Pachyderm) MarshalToSizedBuffer 

func (m *SetLogLevelRequest_Pachyderm) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetLogLevelRequest_Pachyderm) Size 

func (m *SetLogLevelRequest_Pachyderm) Size() (n int)

type SetLogLevelResponse 

type SetLogLevelResponse struct {
	AffectedPods         []string `protobuf:"bytes,1,rep,name=affected_pods,json=affectedPods,proto3" json:"affected_pods,omitempty"`
	ErroredPods          []string `protobuf:"bytes,2,rep,name=errored_pods,json=erroredPods,proto3" json:"errored_pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetLogLevelResponse) Descriptor 

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

func (*SetLogLevelResponse) GetAffectedPods 

func (m *SetLogLevelResponse) GetAffectedPods() []string

func (*SetLogLevelResponse) GetErroredPods 

func (m *SetLogLevelResponse) GetErroredPods() []string

func (*SetLogLevelResponse) Marshal 

func (m *SetLogLevelResponse) Marshal() (dAtA []byte, err error)

func (*SetLogLevelResponse) MarshalLogObject 

func (x *SetLogLevelResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SetLogLevelResponse) MarshalTo 

func (m *SetLogLevelResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetLogLevelResponse) MarshalToSizedBuffer 

func (m *SetLogLevelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetLogLevelResponse) ProtoMessage 

func (*SetLogLevelResponse) ProtoMessage()

func (*SetLogLevelResponse) Reset 

func (m *SetLogLevelResponse) Reset()

func (*SetLogLevelResponse) Size 

func (m *SetLogLevelResponse) Size() (n int)

func (*SetLogLevelResponse) String 

func (m *SetLogLevelResponse) String() string

func (*SetLogLevelResponse) Unmarshal 

func (m *SetLogLevelResponse) Unmarshal(dAtA []byte) error

func (*SetLogLevelResponse) XXX_DiscardUnknown 

func (m *SetLogLevelResponse) XXX_DiscardUnknown()

func (*SetLogLevelResponse) XXX_Marshal 

func (m *SetLogLevelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetLogLevelResponse) XXX_Merge 

func (m *SetLogLevelResponse) XXX_Merge(src proto.Message)

func (*SetLogLevelResponse) XXX_Size 

func (m *SetLogLevelResponse) XXX_Size() int

func (*SetLogLevelResponse) XXX_Unmarshal 

func (m *SetLogLevelResponse) XXX_Unmarshal(b []byte) error

type UnimplementedDebugServer 

type UnimplementedDebugServer struct {
}

UnimplementedDebugServer can be embedded to have forward compatible implementations.

func (*UnimplementedDebugServer) Binary 

func (*UnimplementedDebugServer) Binary(req *BinaryRequest, srv Debug_BinaryServer) error

func (*UnimplementedDebugServer) Dump 

func (*UnimplementedDebugServer) Dump(req *DumpRequest, srv Debug_DumpServer) error

func (*UnimplementedDebugServer) Profile 

func (*UnimplementedDebugServer) Profile(req *ProfileRequest, srv Debug_ProfileServer) error

func (*UnimplementedDebugServer) SetLogLevel 

func (*UnimplementedDebugServer) SetLogLevel(ctx context.Context, req *SetLogLevelRequest) (*SetLogLevelResponse, error)

type Worker 

type Worker struct {
	Pod                  string   `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	Redirected           bool     `protobuf:"varint,2,opt,name=redirected,proto3" json:"redirected,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Worker) Descriptor 

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

func (*Worker) GetPod 

func (m *Worker) GetPod() string

func (*Worker) GetRedirected 

func (m *Worker) GetRedirected() bool

func (*Worker) Marshal 

func (m *Worker) Marshal() (dAtA []byte, err error)

func (*Worker) MarshalLogObject 

func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Worker) MarshalTo 

func (m *Worker) MarshalTo(dAtA []byte) (int, error)

func (*Worker) MarshalToSizedBuffer 

func (m *Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) Size 

func (m *Worker) Size() (n int)

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) Unmarshal 

func (m *Worker) Unmarshal(dAtA []byte) error

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Worker) XXX_Merge 

func (m *Worker) XXX_Merge(src proto.Message)

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

func (m *Worker) XXX_Unmarshal(b []byte) error

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.