Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterDebugServer(s grpc.ServiceRegistrar, srv DebugServer)
- type App
- func (*App) Descriptor() ([]byte, []int)deprecated
- func (x *App) GetName() string
- func (x *App) GetPipeline() *Pipeline
- func (x *App) GetPods() []*Pod
- func (x *App) GetTimeout() *durationpb.Duration
- func (x *App) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*App) ProtoMessage()
- func (x *App) ProtoReflect() protoreflect.Message
- func (x *App) Reset()
- func (x *App) String() string
- type BinaryRequest
- func (*BinaryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BinaryRequest) GetFilter() *Filter
- func (x *BinaryRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*BinaryRequest) ProtoMessage()
- func (x *BinaryRequest) ProtoReflect() protoreflect.Message
- func (x *BinaryRequest) Reset()
- func (x *BinaryRequest) String() string
- type DebugClient
- type DebugServer
- type Debug_BinaryClient
- type Debug_BinaryServer
- type Debug_DumpClient
- type Debug_DumpServer
- type Debug_DumpV2Client
- type Debug_DumpV2Server
- type Debug_ProfileClient
- type Debug_ProfileServer
- type DumpChunk
- func (*DumpChunk) Descriptor() ([]byte, []int)deprecated
- func (m *DumpChunk) GetChunk() isDumpChunk_Chunk
- func (x *DumpChunk) GetContent() *DumpContent
- func (x *DumpChunk) GetProgress() *DumpProgress
- func (x *DumpChunk) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DumpChunk) ProtoMessage()
- func (x *DumpChunk) ProtoReflect() protoreflect.Message
- func (x *DumpChunk) Reset()
- func (x *DumpChunk) String() string
- type DumpChunk_Content
- type DumpChunk_Progress
- type DumpContent
- func (*DumpContent) Descriptor() ([]byte, []int)deprecated
- func (x *DumpContent) GetContent() []byte
- func (x *DumpContent) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DumpContent) ProtoMessage()
- func (x *DumpContent) ProtoReflect() protoreflect.Message
- func (x *DumpContent) Reset()
- func (x *DumpContent) String() string
- type DumpProgress
- func (*DumpProgress) Descriptor() ([]byte, []int)deprecated
- func (x *DumpProgress) GetProgress() int64
- func (x *DumpProgress) GetTask() string
- func (x *DumpProgress) GetTotal() int64
- func (x *DumpProgress) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DumpProgress) ProtoMessage()
- func (x *DumpProgress) ProtoReflect() protoreflect.Message
- func (x *DumpProgress) Reset()
- func (x *DumpProgress) String() string
- type DumpRequest
- func (*DumpRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DumpRequest) GetFilter() *Filter
- func (x *DumpRequest) GetLimit() int64
- func (x *DumpRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DumpRequest) ProtoMessage()
- func (x *DumpRequest) ProtoReflect() protoreflect.Message
- func (x *DumpRequest) Reset()
- func (x *DumpRequest) String() string
- type DumpV2Request
- func (*DumpV2Request) Descriptor() ([]byte, []int)deprecated
- func (x *DumpV2Request) GetInputRepos() bool
- func (x *DumpV2Request) GetPipelines() []*Pipeline
- func (x *DumpV2Request) GetSystem() *System
- func (x *DumpV2Request) GetTimeout() *durationpb.Duration
- func (x *DumpV2Request) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DumpV2Request) ProtoMessage()
- func (x *DumpV2Request) ProtoReflect() protoreflect.Message
- func (x *DumpV2Request) Reset()
- func (x *DumpV2Request) String() string
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetDatabase() bool
- func (m *Filter) GetFilter() isFilter_Filter
- func (x *Filter) GetPachd() bool
- func (x *Filter) GetPipeline() *pps.Pipeline
- func (x *Filter) GetWorker() *Worker
- func (x *Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type Filter_Database
- type Filter_Pachd
- type Filter_Pipeline
- type Filter_Worker
- type GetDumpV2TemplateRequest
- func (*GetDumpV2TemplateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDumpV2TemplateRequest) GetFilters() []string
- func (x *GetDumpV2TemplateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetDumpV2TemplateRequest) ProtoMessage()
- func (x *GetDumpV2TemplateRequest) ProtoReflect() protoreflect.Message
- func (x *GetDumpV2TemplateRequest) Reset()
- func (x *GetDumpV2TemplateRequest) String() string
- type GetDumpV2TemplateResponse
- func (*GetDumpV2TemplateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDumpV2TemplateResponse) GetRequest() *DumpV2Request
- func (x *GetDumpV2TemplateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetDumpV2TemplateResponse) ProtoMessage()
- func (x *GetDumpV2TemplateResponse) ProtoReflect() protoreflect.Message
- func (x *GetDumpV2TemplateResponse) Reset()
- func (x *GetDumpV2TemplateResponse) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetName() string
- func (x *Pipeline) GetProject() string
- func (x *Pipeline) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type Pod
- func (*Pod) Descriptor() ([]byte, []int)deprecated
- func (x *Pod) GetContainers() []string
- func (x *Pod) GetIp() string
- func (x *Pod) GetName() string
- func (x *Pod) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Pod) ProtoMessage()
- func (x *Pod) ProtoReflect() protoreflect.Message
- func (x *Pod) Reset()
- func (x *Pod) String() string
- type Profile
- func (*Profile) Descriptor() ([]byte, []int)deprecated
- func (x *Profile) GetDuration() *durationpb.Duration
- func (x *Profile) GetName() string
- func (x *Profile) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Profile) ProtoMessage()
- func (x *Profile) ProtoReflect() protoreflect.Message
- func (x *Profile) Reset()
- func (x *Profile) String() string
- type ProfileRequest
- func (*ProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProfileRequest) GetFilter() *Filter
- func (x *ProfileRequest) GetProfile() *Profile
- func (x *ProfileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ProfileRequest) ProtoMessage()
- func (x *ProfileRequest) ProtoReflect() protoreflect.Message
- func (x *ProfileRequest) Reset()
- func (x *ProfileRequest) String() string
- type SetLogLevelRequest
- func (*SetLogLevelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetLogLevelRequest) GetDuration() *durationpb.Duration
- func (x *SetLogLevelRequest) GetGrpc() SetLogLevelRequest_LogLevel
- func (m *SetLogLevelRequest) GetLevel() isSetLogLevelRequest_Level
- func (x *SetLogLevelRequest) GetPachyderm() SetLogLevelRequest_LogLevel
- func (x *SetLogLevelRequest) GetRecurse() bool
- func (x *SetLogLevelRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*SetLogLevelRequest) ProtoMessage()
- func (x *SetLogLevelRequest) ProtoReflect() protoreflect.Message
- func (x *SetLogLevelRequest) Reset()
- func (x *SetLogLevelRequest) String() string
- type SetLogLevelRequest_Grpc
- type SetLogLevelRequest_LogLevel
- func (SetLogLevelRequest_LogLevel) Descriptor() protoreflect.EnumDescriptor
- func (x SetLogLevelRequest_LogLevel) Enum() *SetLogLevelRequest_LogLevel
- func (SetLogLevelRequest_LogLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x SetLogLevelRequest_LogLevel) Number() protoreflect.EnumNumber
- func (x SetLogLevelRequest_LogLevel) String() string
- func (SetLogLevelRequest_LogLevel) Type() protoreflect.EnumType
- type SetLogLevelRequest_Pachyderm
- type SetLogLevelResponse
- func (*SetLogLevelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetLogLevelResponse) GetAffectedPods() []string
- func (x *SetLogLevelResponse) GetErroredPods() []string
- func (x *SetLogLevelResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*SetLogLevelResponse) ProtoMessage()
- func (x *SetLogLevelResponse) ProtoReflect() protoreflect.Message
- func (x *SetLogLevelResponse) Reset()
- func (x *SetLogLevelResponse) String() string
- type System
- func (*System) Descriptor() ([]byte, []int)deprecated
- func (x *System) GetBinaries() []*App
- func (x *System) GetDatabase() bool
- func (x *System) GetDescribes() []*App
- func (x *System) GetHelm() bool
- func (x *System) GetLogs() []*App
- func (x *System) GetLokiLogs() []*App
- func (x *System) GetProfiles() []*App
- func (x *System) GetVersion() bool
- func (x *System) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*System) ProtoMessage()
- func (x *System) ProtoReflect() protoreflect.Message
- func (x *System) Reset()
- func (x *System) String() string
- type UnimplementedDebugServer
- func (UnimplementedDebugServer) Binary(*BinaryRequest, Debug_BinaryServer) error
- func (UnimplementedDebugServer) Dump(*DumpRequest, Debug_DumpServer) error
- func (UnimplementedDebugServer) DumpV2(*DumpV2Request, Debug_DumpV2Server) error
- func (UnimplementedDebugServer) GetDumpV2Template(context.Context, *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, error)
- func (UnimplementedDebugServer) Profile(*ProfileRequest, Debug_ProfileServer) error
- func (UnimplementedDebugServer) SetLogLevel(context.Context, *SetLogLevelRequest) (*SetLogLevelResponse, error)
- type UnsafeDebugServer
- type Worker
- func (*Worker) Descriptor() ([]byte, []int)deprecated
- func (x *Worker) GetPod() string
- func (x *Worker) GetRedirected() bool
- func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*Worker) ProtoMessage()
- func (x *Worker) ProtoReflect() protoreflect.Message
- func (x *Worker) Reset()
- func (x *Worker) String() string
Constants ¶
const ( Debug_Profile_FullMethodName = "/debug_v2.Debug/Profile" Debug_Binary_FullMethodName = "/debug_v2.Debug/Binary" Debug_Dump_FullMethodName = "/debug_v2.Debug/Dump" Debug_SetLogLevel_FullMethodName = "/debug_v2.Debug/SetLogLevel" Debug_GetDumpV2Template_FullMethodName = "/debug_v2.Debug/GetDumpV2Template" Debug_DumpV2_FullMethodName = "/debug_v2.Debug/DumpV2" )
Variables ¶
var ( SetLogLevelRequest_LogLevel_name = map[int32]string{ 0: "UNKNOWN", 1: "DEBUG", 2: "INFO", 3: "ERROR", 4: "OFF", } SetLogLevelRequest_LogLevel_value = map[string]int32{ "UNKNOWN": 0, "DEBUG": 1, "INFO": 2, "ERROR": 3, "OFF": 4, } )
Enum value maps for SetLogLevelRequest_LogLevel.
var Debug_ServiceDesc = grpc.ServiceDesc{ ServiceName: "debug_v2.Debug", HandlerType: (*DebugServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetLogLevel", Handler: _Debug_SetLogLevel_Handler, }, { MethodName: "GetDumpV2Template", Handler: _Debug_GetDumpV2Template_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Profile", Handler: _Debug_Profile_Handler, ServerStreams: true, }, { StreamName: "Binary", Handler: _Debug_Binary_Handler, ServerStreams: true, }, { StreamName: "Dump", Handler: _Debug_Dump_Handler, ServerStreams: true, }, { StreamName: "DumpV2", Handler: _Debug_DumpV2_Handler, ServerStreams: true, }, }, Metadata: "debug/debug.proto", }
Debug_ServiceDesc is the grpc.ServiceDesc for Debug service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_debug_debug_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDebugServer ¶
func RegisterDebugServer(s grpc.ServiceRegistrar, srv DebugServer)
Types ¶
type App ¶ added in v2.7.0
type App struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Pods []*Pod `protobuf:"bytes,2,rep,name=pods,proto3" json:"pods,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` Pipeline *Pipeline `protobuf:"bytes,4,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
func (*App) Descriptor
deprecated
added in
v2.7.0
func (*App) GetPipeline ¶ added in v2.7.0
func (*App) GetTimeout ¶ added in v2.7.0
func (x *App) GetTimeout() *durationpb.Duration
func (*App) MarshalLogObject ¶ added in v2.7.0
func (x *App) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*App) ProtoMessage ¶ added in v2.7.0
func (*App) ProtoMessage()
func (*App) ProtoReflect ¶ added in v2.7.0
func (x *App) ProtoReflect() protoreflect.Message
type BinaryRequest ¶
type BinaryRequest struct { Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*BinaryRequest) Descriptor
deprecated
func (*BinaryRequest) Descriptor() ([]byte, []int)
Deprecated: Use BinaryRequest.ProtoReflect.Descriptor instead.
func (*BinaryRequest) GetFilter ¶
func (x *BinaryRequest) GetFilter() *Filter
func (*BinaryRequest) MarshalLogObject ¶
func (x *BinaryRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*BinaryRequest) ProtoMessage ¶
func (*BinaryRequest) ProtoMessage()
func (*BinaryRequest) ProtoReflect ¶ added in v2.7.0
func (x *BinaryRequest) ProtoReflect() protoreflect.Message
func (*BinaryRequest) Reset ¶
func (x *BinaryRequest) Reset()
func (*BinaryRequest) String ¶
func (x *BinaryRequest) String() string
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) GetDumpV2Template(ctx context.Context, in *GetDumpV2TemplateRequest, opts ...grpc.CallOption) (*GetDumpV2TemplateResponse, error) DumpV2(ctx context.Context, in *DumpV2Request, opts ...grpc.CallOption) (Debug_DumpV2Client, error) }
DebugClient is the client API for Debug 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 NewDebugClient ¶
func NewDebugClient(cc grpc.ClientConnInterface) 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) GetDumpV2Template(context.Context, *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, error) DumpV2(*DumpV2Request, Debug_DumpV2Server) error // contains filtered or unexported methods }
DebugServer is the server API for Debug service. All implementations must embed UnimplementedDebugServer for forward compatibility
type Debug_BinaryClient ¶
type Debug_BinaryClient interface { Recv() (*wrapperspb.BytesValue, error) grpc.ClientStream }
type Debug_BinaryServer ¶
type Debug_BinaryServer interface { Send(*wrapperspb.BytesValue) error grpc.ServerStream }
type Debug_DumpClient ¶
type Debug_DumpClient interface { Recv() (*wrapperspb.BytesValue, error) grpc.ClientStream }
type Debug_DumpServer ¶
type Debug_DumpServer interface { Send(*wrapperspb.BytesValue) error grpc.ServerStream }
type Debug_DumpV2Client ¶ added in v2.7.0
type Debug_DumpV2Client interface { Recv() (*DumpChunk, error) grpc.ClientStream }
type Debug_DumpV2Server ¶ added in v2.7.0
type Debug_DumpV2Server interface { Send(*DumpChunk) error grpc.ServerStream }
type Debug_ProfileClient ¶
type Debug_ProfileClient interface { Recv() (*wrapperspb.BytesValue, error) grpc.ClientStream }
type Debug_ProfileServer ¶
type Debug_ProfileServer interface { Send(*wrapperspb.BytesValue) error grpc.ServerStream }
type DumpChunk ¶ added in v2.7.0
type DumpChunk struct { // Types that are assignable to Chunk: // // *DumpChunk_Content // *DumpChunk_Progress Chunk isDumpChunk_Chunk `protobuf_oneof:"chunk"` // contains filtered or unexported fields }
func (*DumpChunk) Descriptor
deprecated
added in
v2.7.0
func (*DumpChunk) GetContent ¶ added in v2.7.0
func (x *DumpChunk) GetContent() *DumpContent
func (*DumpChunk) GetProgress ¶ added in v2.7.0
func (x *DumpChunk) GetProgress() *DumpProgress
func (*DumpChunk) MarshalLogObject ¶ added in v2.7.0
func (x *DumpChunk) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpChunk) ProtoMessage ¶ added in v2.7.0
func (*DumpChunk) ProtoMessage()
func (*DumpChunk) ProtoReflect ¶ added in v2.7.0
func (x *DumpChunk) ProtoReflect() protoreflect.Message
type DumpChunk_Content ¶ added in v2.7.0
type DumpChunk_Content struct {
Content *DumpContent `protobuf:"bytes,1,opt,name=content,proto3,oneof"`
}
type DumpChunk_Progress ¶ added in v2.7.0
type DumpChunk_Progress struct {
Progress *DumpProgress `protobuf:"bytes,2,opt,name=progress,proto3,oneof"`
}
type DumpContent ¶ added in v2.7.0
type DumpContent struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*DumpContent) Descriptor
deprecated
added in
v2.7.0
func (*DumpContent) Descriptor() ([]byte, []int)
Deprecated: Use DumpContent.ProtoReflect.Descriptor instead.
func (*DumpContent) GetContent ¶ added in v2.7.0
func (x *DumpContent) GetContent() []byte
func (*DumpContent) MarshalLogObject ¶ added in v2.7.0
func (x *DumpContent) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpContent) ProtoMessage ¶ added in v2.7.0
func (*DumpContent) ProtoMessage()
func (*DumpContent) ProtoReflect ¶ added in v2.7.0
func (x *DumpContent) ProtoReflect() protoreflect.Message
func (*DumpContent) Reset ¶ added in v2.7.0
func (x *DumpContent) Reset()
func (*DumpContent) String ¶ added in v2.7.0
func (x *DumpContent) String() string
type DumpProgress ¶ added in v2.7.0
type DumpProgress struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Progress int64 `protobuf:"varint,3,opt,name=progress,proto3" json:"progress,omitempty"` // contains filtered or unexported fields }
func (*DumpProgress) Descriptor
deprecated
added in
v2.7.0
func (*DumpProgress) Descriptor() ([]byte, []int)
Deprecated: Use DumpProgress.ProtoReflect.Descriptor instead.
func (*DumpProgress) GetProgress ¶ added in v2.7.0
func (x *DumpProgress) GetProgress() int64
func (*DumpProgress) GetTask ¶ added in v2.7.0
func (x *DumpProgress) GetTask() string
func (*DumpProgress) GetTotal ¶ added in v2.7.0
func (x *DumpProgress) GetTotal() int64
func (*DumpProgress) MarshalLogObject ¶ added in v2.7.0
func (x *DumpProgress) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpProgress) ProtoMessage ¶ added in v2.7.0
func (*DumpProgress) ProtoMessage()
func (*DumpProgress) ProtoReflect ¶ added in v2.7.0
func (x *DumpProgress) ProtoReflect() protoreflect.Message
func (*DumpProgress) Reset ¶ added in v2.7.0
func (x *DumpProgress) Reset()
func (*DumpProgress) String ¶ added in v2.7.0
func (x *DumpProgress) String() string
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"` // contains filtered or unexported fields }
func (*DumpRequest) Descriptor
deprecated
func (*DumpRequest) Descriptor() ([]byte, []int)
Deprecated: Use DumpRequest.ProtoReflect.Descriptor instead.
func (*DumpRequest) GetFilter ¶
func (x *DumpRequest) GetFilter() *Filter
func (*DumpRequest) GetLimit ¶
func (x *DumpRequest) GetLimit() int64
func (*DumpRequest) MarshalLogObject ¶
func (x *DumpRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpRequest) ProtoMessage ¶
func (*DumpRequest) ProtoMessage()
func (*DumpRequest) ProtoReflect ¶ added in v2.7.0
func (x *DumpRequest) ProtoReflect() protoreflect.Message
func (*DumpRequest) Reset ¶
func (x *DumpRequest) Reset()
func (*DumpRequest) String ¶
func (x *DumpRequest) String() string
type DumpV2Request ¶ added in v2.7.0
type DumpV2Request struct { System *System `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"` Pipelines []*Pipeline `protobuf:"bytes,2,rep,name=pipelines,proto3" json:"pipelines,omitempty"` InputRepos bool `protobuf:"varint,3,opt,name=input_repos,json=inputRepos,proto3" json:"input_repos,omitempty"` Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*DumpV2Request) Descriptor
deprecated
added in
v2.7.0
func (*DumpV2Request) Descriptor() ([]byte, []int)
Deprecated: Use DumpV2Request.ProtoReflect.Descriptor instead.
func (*DumpV2Request) GetInputRepos ¶ added in v2.7.0
func (x *DumpV2Request) GetInputRepos() bool
func (*DumpV2Request) GetPipelines ¶ added in v2.7.0
func (x *DumpV2Request) GetPipelines() []*Pipeline
func (*DumpV2Request) GetSystem ¶ added in v2.7.0
func (x *DumpV2Request) GetSystem() *System
func (*DumpV2Request) GetTimeout ¶ added in v2.7.0
func (x *DumpV2Request) GetTimeout() *durationpb.Duration
func (*DumpV2Request) MarshalLogObject ¶ added in v2.7.0
func (x *DumpV2Request) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpV2Request) ProtoMessage ¶ added in v2.7.0
func (*DumpV2Request) ProtoMessage()
func (*DumpV2Request) ProtoReflect ¶ added in v2.7.0
func (x *DumpV2Request) ProtoReflect() protoreflect.Message
func (*DumpV2Request) Reset ¶ added in v2.7.0
func (x *DumpV2Request) Reset()
func (*DumpV2Request) String ¶ added in v2.7.0
func (x *DumpV2Request) String() string
type Filter ¶
type Filter struct { // Types that are assignable to Filter: // // *Filter_Pachd // *Filter_Pipeline // *Filter_Worker // *Filter_Database Filter isFilter_Filter `protobuf_oneof:"filter"` // contains filtered or unexported fields }
func (*Filter) Descriptor
deprecated
func (*Filter) GetDatabase ¶
func (*Filter) GetPipeline ¶
func (*Filter) MarshalLogObject ¶
func (x *Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶ added in v2.7.0
func (x *Filter) ProtoReflect() protoreflect.Message
type Filter_Database ¶
type Filter_Database struct {
Database bool `protobuf:"varint,4,opt,name=database,proto3,oneof"`
}
type Filter_Pachd ¶
type Filter_Pachd struct {
Pachd bool `protobuf:"varint,1,opt,name=pachd,proto3,oneof"`
}
type Filter_Pipeline ¶
type Filter_Worker ¶
type Filter_Worker struct {
Worker *Worker `protobuf:"bytes,3,opt,name=worker,proto3,oneof"`
}
type GetDumpV2TemplateRequest ¶ added in v2.7.0
type GetDumpV2TemplateRequest struct { Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` // contains filtered or unexported fields }
func (*GetDumpV2TemplateRequest) Descriptor
deprecated
added in
v2.7.0
func (*GetDumpV2TemplateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDumpV2TemplateRequest.ProtoReflect.Descriptor instead.
func (*GetDumpV2TemplateRequest) GetFilters ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) GetFilters() []string
func (*GetDumpV2TemplateRequest) MarshalLogObject ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetDumpV2TemplateRequest) ProtoMessage ¶ added in v2.7.0
func (*GetDumpV2TemplateRequest) ProtoMessage()
func (*GetDumpV2TemplateRequest) ProtoReflect ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) ProtoReflect() protoreflect.Message
func (*GetDumpV2TemplateRequest) Reset ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) Reset()
func (*GetDumpV2TemplateRequest) String ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) String() string
type GetDumpV2TemplateResponse ¶ added in v2.7.0
type GetDumpV2TemplateResponse struct { Request *DumpV2Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` // contains filtered or unexported fields }
func (*GetDumpV2TemplateResponse) Descriptor
deprecated
added in
v2.7.0
func (*GetDumpV2TemplateResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDumpV2TemplateResponse.ProtoReflect.Descriptor instead.
func (*GetDumpV2TemplateResponse) GetRequest ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) GetRequest() *DumpV2Request
func (*GetDumpV2TemplateResponse) MarshalLogObject ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetDumpV2TemplateResponse) ProtoMessage ¶ added in v2.7.0
func (*GetDumpV2TemplateResponse) ProtoMessage()
func (*GetDumpV2TemplateResponse) ProtoReflect ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) ProtoReflect() protoreflect.Message
func (*GetDumpV2TemplateResponse) Reset ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) Reset()
func (*GetDumpV2TemplateResponse) String ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) String() string
type Pipeline ¶ added in v2.7.0
type Pipeline struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Pipeline) Descriptor
deprecated
added in
v2.7.0
func (*Pipeline) GetProject ¶ added in v2.7.0
func (*Pipeline) MarshalLogObject ¶ added in v2.7.0
func (x *Pipeline) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Pipeline) ProtoMessage ¶ added in v2.7.0
func (*Pipeline) ProtoMessage()
func (*Pipeline) ProtoReflect ¶ added in v2.7.0
func (x *Pipeline) ProtoReflect() protoreflect.Message
type Pod ¶ added in v2.7.0
type Pod struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` Containers []string `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"` // contains filtered or unexported fields }
func (*Pod) Descriptor
deprecated
added in
v2.7.0
func (*Pod) GetContainers ¶ added in v2.7.0
func (*Pod) MarshalLogObject ¶ added in v2.7.0
func (x *Pod) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Pod) ProtoMessage ¶ added in v2.7.0
func (*Pod) ProtoMessage()
func (*Pod) ProtoReflect ¶ added in v2.7.0
func (x *Pod) ProtoReflect() protoreflect.Message
type Profile ¶
type Profile struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"` // only meaningful if name == "cpu" // contains filtered or unexported fields }
func (*Profile) Descriptor
deprecated
func (*Profile) GetDuration ¶
func (x *Profile) GetDuration() *durationpb.Duration
func (*Profile) MarshalLogObject ¶
func (x *Profile) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Profile) ProtoMessage ¶
func (*Profile) ProtoMessage()
func (*Profile) ProtoReflect ¶ added in v2.7.0
func (x *Profile) ProtoReflect() protoreflect.Message
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"` // contains filtered or unexported fields }
func (*ProfileRequest) Descriptor
deprecated
func (*ProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProfileRequest.ProtoReflect.Descriptor instead.
func (*ProfileRequest) GetFilter ¶
func (x *ProfileRequest) GetFilter() *Filter
func (*ProfileRequest) GetProfile ¶
func (x *ProfileRequest) GetProfile() *Profile
func (*ProfileRequest) MarshalLogObject ¶
func (x *ProfileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ProfileRequest) ProtoMessage ¶
func (*ProfileRequest) ProtoMessage()
func (*ProfileRequest) ProtoReflect ¶ added in v2.7.0
func (x *ProfileRequest) ProtoReflect() protoreflect.Message
func (*ProfileRequest) Reset ¶
func (x *ProfileRequest) Reset()
func (*ProfileRequest) String ¶
func (x *ProfileRequest) String() string
type SetLogLevelRequest ¶
type SetLogLevelRequest struct { // Types that are assignable to Level: // // *SetLogLevelRequest_Pachyderm // *SetLogLevelRequest_Grpc Level isSetLogLevelRequest_Level `protobuf_oneof:"level"` Duration *durationpb.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"` Recurse bool `protobuf:"varint,4,opt,name=recurse,proto3" json:"recurse,omitempty"` // contains filtered or unexported fields }
func (*SetLogLevelRequest) Descriptor
deprecated
func (*SetLogLevelRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetLogLevelRequest.ProtoReflect.Descriptor instead.
func (*SetLogLevelRequest) GetDuration ¶
func (x *SetLogLevelRequest) GetDuration() *durationpb.Duration
func (*SetLogLevelRequest) GetGrpc ¶
func (x *SetLogLevelRequest) GetGrpc() SetLogLevelRequest_LogLevel
func (*SetLogLevelRequest) GetLevel ¶
func (m *SetLogLevelRequest) GetLevel() isSetLogLevelRequest_Level
func (*SetLogLevelRequest) GetPachyderm ¶
func (x *SetLogLevelRequest) GetPachyderm() SetLogLevelRequest_LogLevel
func (*SetLogLevelRequest) GetRecurse ¶
func (x *SetLogLevelRequest) GetRecurse() bool
func (*SetLogLevelRequest) MarshalLogObject ¶
func (x *SetLogLevelRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*SetLogLevelRequest) ProtoMessage ¶
func (*SetLogLevelRequest) ProtoMessage()
func (*SetLogLevelRequest) ProtoReflect ¶ added in v2.7.0
func (x *SetLogLevelRequest) ProtoReflect() protoreflect.Message
func (*SetLogLevelRequest) Reset ¶
func (x *SetLogLevelRequest) Reset()
func (*SetLogLevelRequest) String ¶
func (x *SetLogLevelRequest) String() string
type SetLogLevelRequest_Grpc ¶
type SetLogLevelRequest_Grpc struct {
Grpc SetLogLevelRequest_LogLevel `protobuf:"varint,2,opt,name=grpc,proto3,enum=debug_v2.SetLogLevelRequest_LogLevel,oneof"`
}
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 // Only GRPC logs can be turned off. )
func (SetLogLevelRequest_LogLevel) Descriptor ¶ added in v2.7.0
func (SetLogLevelRequest_LogLevel) Descriptor() protoreflect.EnumDescriptor
func (SetLogLevelRequest_LogLevel) Enum ¶ added in v2.7.0
func (x SetLogLevelRequest_LogLevel) Enum() *SetLogLevelRequest_LogLevel
func (SetLogLevelRequest_LogLevel) EnumDescriptor
deprecated
func (SetLogLevelRequest_LogLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use SetLogLevelRequest_LogLevel.Descriptor instead.
func (SetLogLevelRequest_LogLevel) Number ¶ added in v2.7.0
func (x SetLogLevelRequest_LogLevel) Number() protoreflect.EnumNumber
func (SetLogLevelRequest_LogLevel) String ¶
func (x SetLogLevelRequest_LogLevel) String() string
func (SetLogLevelRequest_LogLevel) Type ¶ added in v2.7.0
func (SetLogLevelRequest_LogLevel) Type() protoreflect.EnumType
type SetLogLevelRequest_Pachyderm ¶
type SetLogLevelRequest_Pachyderm struct {
Pachyderm SetLogLevelRequest_LogLevel `protobuf:"varint,1,opt,name=pachyderm,proto3,enum=debug_v2.SetLogLevelRequest_LogLevel,oneof"`
}
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"` // contains filtered or unexported fields }
func (*SetLogLevelResponse) Descriptor
deprecated
func (*SetLogLevelResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetLogLevelResponse.ProtoReflect.Descriptor instead.
func (*SetLogLevelResponse) GetAffectedPods ¶
func (x *SetLogLevelResponse) GetAffectedPods() []string
func (*SetLogLevelResponse) GetErroredPods ¶
func (x *SetLogLevelResponse) GetErroredPods() []string
func (*SetLogLevelResponse) MarshalLogObject ¶
func (x *SetLogLevelResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*SetLogLevelResponse) ProtoMessage ¶
func (*SetLogLevelResponse) ProtoMessage()
func (*SetLogLevelResponse) ProtoReflect ¶ added in v2.7.0
func (x *SetLogLevelResponse) ProtoReflect() protoreflect.Message
func (*SetLogLevelResponse) Reset ¶
func (x *SetLogLevelResponse) Reset()
func (*SetLogLevelResponse) String ¶
func (x *SetLogLevelResponse) String() string
type System ¶ added in v2.7.0
type System struct { Helm bool `protobuf:"varint,1,opt,name=helm,proto3" json:"helm,omitempty"` Database bool `protobuf:"varint,2,opt,name=database,proto3" json:"database,omitempty"` Version bool `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` Describes []*App `protobuf:"bytes,4,rep,name=describes,proto3" json:"describes,omitempty"` Logs []*App `protobuf:"bytes,5,rep,name=logs,proto3" json:"logs,omitempty"` LokiLogs []*App `protobuf:"bytes,6,rep,name=loki_logs,json=lokiLogs,proto3" json:"loki_logs,omitempty"` Binaries []*App `protobuf:"bytes,7,rep,name=binaries,proto3" json:"binaries,omitempty"` Profiles []*App `protobuf:"bytes,8,rep,name=profiles,proto3" json:"profiles,omitempty"` // contains filtered or unexported fields }
func (*System) Descriptor
deprecated
added in
v2.7.0
func (*System) GetBinaries ¶ added in v2.7.0
func (*System) GetDatabase ¶ added in v2.7.0
func (*System) GetDescribes ¶ added in v2.7.0
func (*System) GetLokiLogs ¶ added in v2.7.0
func (*System) GetProfiles ¶ added in v2.7.0
func (*System) GetVersion ¶ added in v2.7.0
func (*System) MarshalLogObject ¶ added in v2.7.0
func (x *System) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*System) ProtoMessage ¶ added in v2.7.0
func (*System) ProtoMessage()
func (*System) ProtoReflect ¶ added in v2.7.0
func (x *System) ProtoReflect() protoreflect.Message
type UnimplementedDebugServer ¶
type UnimplementedDebugServer struct { }
UnimplementedDebugServer must be embedded to have forward compatible implementations.
func (UnimplementedDebugServer) Binary ¶
func (UnimplementedDebugServer) Binary(*BinaryRequest, Debug_BinaryServer) error
func (UnimplementedDebugServer) Dump ¶
func (UnimplementedDebugServer) Dump(*DumpRequest, Debug_DumpServer) error
func (UnimplementedDebugServer) DumpV2 ¶ added in v2.7.0
func (UnimplementedDebugServer) DumpV2(*DumpV2Request, Debug_DumpV2Server) error
func (UnimplementedDebugServer) GetDumpV2Template ¶ added in v2.7.0
func (UnimplementedDebugServer) GetDumpV2Template(context.Context, *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, error)
func (UnimplementedDebugServer) Profile ¶
func (UnimplementedDebugServer) Profile(*ProfileRequest, Debug_ProfileServer) error
func (UnimplementedDebugServer) SetLogLevel ¶
func (UnimplementedDebugServer) SetLogLevel(context.Context, *SetLogLevelRequest) (*SetLogLevelResponse, error)
type UnsafeDebugServer ¶ added in v2.7.0
type UnsafeDebugServer interface {
// contains filtered or unexported methods
}
UnsafeDebugServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DebugServer will result in compilation errors.
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"` // contains filtered or unexported fields }
func (*Worker) Descriptor
deprecated
func (*Worker) GetRedirected ¶
func (*Worker) MarshalLogObject ¶
func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Worker) ProtoMessage ¶
func (*Worker) ProtoMessage()
func (*Worker) ProtoReflect ¶ added in v2.7.0
func (x *Worker) ProtoReflect() protoreflect.Message