Documentation ¶
Index ¶
- Variables
- func RegisterDebugServer(s *grpc.Server, srv DebugServer)
- type App
- func (*App) Descriptor() ([]byte, []int)
- func (m *App) GetName() string
- func (m *App) GetPipeline() *Pipeline
- func (m *App) GetPods() []*Pod
- func (m *App) GetTimeout() int64
- func (m *App) Marshal() (dAtA []byte, err error)
- func (x *App) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *App) MarshalTo(dAtA []byte) (int, error)
- func (m *App) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*App) ProtoMessage()
- func (m *App) Reset()
- func (m *App) Size() (n int)
- func (m *App) String() string
- func (m *App) Unmarshal(dAtA []byte) error
- func (m *App) XXX_DiscardUnknown()
- func (m *App) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *App) XXX_Merge(src proto.Message)
- func (m *App) XXX_Size() int
- func (m *App) XXX_Unmarshal(b []byte) error
- type BinaryRequest
- func (*BinaryRequest) Descriptor() ([]byte, []int)
- func (m *BinaryRequest) GetFilter() *Filter
- func (m *BinaryRequest) Marshal() (dAtA []byte, err error)
- func (x *BinaryRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *BinaryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *BinaryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BinaryRequest) ProtoMessage()
- func (m *BinaryRequest) Reset()
- func (m *BinaryRequest) Size() (n int)
- func (m *BinaryRequest) String() string
- func (m *BinaryRequest) Unmarshal(dAtA []byte) error
- func (m *BinaryRequest) XXX_DiscardUnknown()
- func (m *BinaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BinaryRequest) XXX_Merge(src proto.Message)
- func (m *BinaryRequest) XXX_Size() int
- func (m *BinaryRequest) XXX_Unmarshal(b []byte) error
- 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)
- func (m *DumpChunk) GetChunk() isDumpChunk_Chunk
- func (m *DumpChunk) GetContent() *DumpContent
- func (m *DumpChunk) GetProgress() *DumpProgress
- func (m *DumpChunk) Marshal() (dAtA []byte, err error)
- func (x *DumpChunk) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *DumpChunk) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpChunk) ProtoMessage()
- func (m *DumpChunk) Reset()
- func (m *DumpChunk) Size() (n int)
- func (m *DumpChunk) String() string
- func (m *DumpChunk) Unmarshal(dAtA []byte) error
- func (m *DumpChunk) XXX_DiscardUnknown()
- func (m *DumpChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpChunk) XXX_Merge(src proto.Message)
- func (*DumpChunk) XXX_OneofWrappers() []interface{}
- func (m *DumpChunk) XXX_Size() int
- func (m *DumpChunk) XXX_Unmarshal(b []byte) error
- type DumpChunk_Content
- type DumpChunk_Progress
- type DumpContent
- func (*DumpContent) Descriptor() ([]byte, []int)
- func (m *DumpContent) GetContent() []byte
- func (m *DumpContent) Marshal() (dAtA []byte, err error)
- func (x *DumpContent) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *DumpContent) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpContent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpContent) ProtoMessage()
- func (m *DumpContent) Reset()
- func (m *DumpContent) Size() (n int)
- func (m *DumpContent) String() string
- func (m *DumpContent) Unmarshal(dAtA []byte) error
- func (m *DumpContent) XXX_DiscardUnknown()
- func (m *DumpContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpContent) XXX_Merge(src proto.Message)
- func (m *DumpContent) XXX_Size() int
- func (m *DumpContent) XXX_Unmarshal(b []byte) error
- type DumpProgress
- func (*DumpProgress) Descriptor() ([]byte, []int)
- func (m *DumpProgress) GetProgress() int64
- func (m *DumpProgress) GetTask() string
- func (m *DumpProgress) GetTotal() int64
- func (m *DumpProgress) Marshal() (dAtA []byte, err error)
- func (x *DumpProgress) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *DumpProgress) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpProgress) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpProgress) ProtoMessage()
- func (m *DumpProgress) Reset()
- func (m *DumpProgress) Size() (n int)
- func (m *DumpProgress) String() string
- func (m *DumpProgress) Unmarshal(dAtA []byte) error
- func (m *DumpProgress) XXX_DiscardUnknown()
- func (m *DumpProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpProgress) XXX_Merge(src proto.Message)
- func (m *DumpProgress) XXX_Size() int
- func (m *DumpProgress) XXX_Unmarshal(b []byte) error
- type DumpRequest
- func (*DumpRequest) Descriptor() ([]byte, []int)
- func (m *DumpRequest) GetFilter() *Filter
- func (m *DumpRequest) GetLimit() int64
- func (m *DumpRequest) Marshal() (dAtA []byte, err error)
- func (x *DumpRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *DumpRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpRequest) ProtoMessage()
- func (m *DumpRequest) Reset()
- func (m *DumpRequest) Size() (n int)
- func (m *DumpRequest) String() string
- func (m *DumpRequest) Unmarshal(dAtA []byte) error
- func (m *DumpRequest) XXX_DiscardUnknown()
- func (m *DumpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpRequest) XXX_Merge(src proto.Message)
- func (m *DumpRequest) XXX_Size() int
- func (m *DumpRequest) XXX_Unmarshal(b []byte) error
- type DumpV2Request
- func (*DumpV2Request) Descriptor() ([]byte, []int)
- func (m *DumpV2Request) GetInputRepos() bool
- func (m *DumpV2Request) GetPipelines() []*Pipeline
- func (m *DumpV2Request) GetSystem() *System
- func (m *DumpV2Request) GetTimeout() int64
- func (m *DumpV2Request) Marshal() (dAtA []byte, err error)
- func (x *DumpV2Request) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *DumpV2Request) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpV2Request) ProtoMessage()
- func (m *DumpV2Request) Reset()
- func (m *DumpV2Request) Size() (n int)
- func (m *DumpV2Request) String() string
- func (m *DumpV2Request) Unmarshal(dAtA []byte) error
- func (m *DumpV2Request) XXX_DiscardUnknown()
- func (m *DumpV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpV2Request) XXX_Merge(src proto.Message)
- func (m *DumpV2Request) XXX_Size() int
- func (m *DumpV2Request) XXX_Unmarshal(b []byte) error
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)
- func (m *Filter) GetDatabase() bool
- func (m *Filter) GetFilter() isFilter_Filter
- func (m *Filter) GetPachd() bool
- func (m *Filter) GetPipeline() *pps.Pipeline
- func (m *Filter) GetWorker() *Worker
- func (m *Filter) Marshal() (dAtA []byte, err error)
- func (x *Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *Filter) MarshalTo(dAtA []byte) (int, error)
- func (m *Filter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Filter) ProtoMessage()
- func (m *Filter) Reset()
- func (m *Filter) Size() (n int)
- func (m *Filter) String() string
- func (m *Filter) Unmarshal(dAtA []byte) error
- func (m *Filter) XXX_DiscardUnknown()
- func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Filter) XXX_Merge(src proto.Message)
- func (*Filter) XXX_OneofWrappers() []interface{}
- func (m *Filter) XXX_Size() int
- func (m *Filter) XXX_Unmarshal(b []byte) error
- type Filter_Database
- type Filter_Pachd
- type Filter_Pipeline
- type Filter_Worker
- type GetDumpV2TemplateRequest
- func (*GetDumpV2TemplateRequest) Descriptor() ([]byte, []int)
- func (m *GetDumpV2TemplateRequest) GetFilters() []string
- func (m *GetDumpV2TemplateRequest) Marshal() (dAtA []byte, err error)
- func (x *GetDumpV2TemplateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *GetDumpV2TemplateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDumpV2TemplateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDumpV2TemplateRequest) ProtoMessage()
- func (m *GetDumpV2TemplateRequest) Reset()
- func (m *GetDumpV2TemplateRequest) Size() (n int)
- func (m *GetDumpV2TemplateRequest) String() string
- func (m *GetDumpV2TemplateRequest) Unmarshal(dAtA []byte) error
- func (m *GetDumpV2TemplateRequest) XXX_DiscardUnknown()
- func (m *GetDumpV2TemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDumpV2TemplateRequest) XXX_Merge(src proto.Message)
- func (m *GetDumpV2TemplateRequest) XXX_Size() int
- func (m *GetDumpV2TemplateRequest) XXX_Unmarshal(b []byte) error
- type GetDumpV2TemplateResponse
- func (*GetDumpV2TemplateResponse) Descriptor() ([]byte, []int)
- func (m *GetDumpV2TemplateResponse) GetRequest() *DumpV2Request
- func (m *GetDumpV2TemplateResponse) Marshal() (dAtA []byte, err error)
- func (x *GetDumpV2TemplateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *GetDumpV2TemplateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDumpV2TemplateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDumpV2TemplateResponse) ProtoMessage()
- func (m *GetDumpV2TemplateResponse) Reset()
- func (m *GetDumpV2TemplateResponse) Size() (n int)
- func (m *GetDumpV2TemplateResponse) String() string
- func (m *GetDumpV2TemplateResponse) Unmarshal(dAtA []byte) error
- func (m *GetDumpV2TemplateResponse) XXX_DiscardUnknown()
- func (m *GetDumpV2TemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDumpV2TemplateResponse) XXX_Merge(src proto.Message)
- func (m *GetDumpV2TemplateResponse) XXX_Size() int
- func (m *GetDumpV2TemplateResponse) XXX_Unmarshal(b []byte) error
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)
- func (m *Pipeline) GetName() string
- func (m *Pipeline) GetProject() string
- func (m *Pipeline) Marshal() (dAtA []byte, err error)
- func (x *Pipeline) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *Pipeline) MarshalTo(dAtA []byte) (int, error)
- func (m *Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Pipeline) ProtoMessage()
- func (m *Pipeline) Reset()
- func (m *Pipeline) Size() (n int)
- func (m *Pipeline) String() string
- func (m *Pipeline) Unmarshal(dAtA []byte) error
- func (m *Pipeline) XXX_DiscardUnknown()
- func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pipeline) XXX_Merge(src proto.Message)
- func (m *Pipeline) XXX_Size() int
- func (m *Pipeline) XXX_Unmarshal(b []byte) error
- type Pod
- func (*Pod) Descriptor() ([]byte, []int)
- func (m *Pod) GetContainers() []string
- func (m *Pod) GetIp() string
- func (m *Pod) GetName() string
- func (m *Pod) Marshal() (dAtA []byte, err error)
- func (x *Pod) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *Pod) MarshalTo(dAtA []byte) (int, error)
- func (m *Pod) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Pod) ProtoMessage()
- func (m *Pod) Reset()
- func (m *Pod) Size() (n int)
- func (m *Pod) String() string
- func (m *Pod) Unmarshal(dAtA []byte) error
- func (m *Pod) XXX_DiscardUnknown()
- func (m *Pod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pod) XXX_Merge(src proto.Message)
- func (m *Pod) XXX_Size() int
- func (m *Pod) XXX_Unmarshal(b []byte) error
- type Profile
- func (*Profile) Descriptor() ([]byte, []int)
- func (m *Profile) GetDuration() *types.Duration
- func (m *Profile) GetName() string
- func (m *Profile) Marshal() (dAtA []byte, err error)
- func (x *Profile) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *Profile) MarshalTo(dAtA []byte) (int, error)
- func (m *Profile) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Profile) ProtoMessage()
- func (m *Profile) Reset()
- func (m *Profile) Size() (n int)
- func (m *Profile) String() string
- func (m *Profile) Unmarshal(dAtA []byte) error
- func (m *Profile) XXX_DiscardUnknown()
- func (m *Profile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Profile) XXX_Merge(src proto.Message)
- func (m *Profile) XXX_Size() int
- func (m *Profile) XXX_Unmarshal(b []byte) error
- type ProfileRequest
- func (*ProfileRequest) Descriptor() ([]byte, []int)
- func (m *ProfileRequest) GetFilter() *Filter
- func (m *ProfileRequest) GetProfile() *Profile
- func (m *ProfileRequest) Marshal() (dAtA []byte, err error)
- func (x *ProfileRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *ProfileRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ProfileRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProfileRequest) ProtoMessage()
- func (m *ProfileRequest) Reset()
- func (m *ProfileRequest) Size() (n int)
- func (m *ProfileRequest) String() string
- func (m *ProfileRequest) Unmarshal(dAtA []byte) error
- func (m *ProfileRequest) XXX_DiscardUnknown()
- func (m *ProfileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProfileRequest) XXX_Merge(src proto.Message)
- func (m *ProfileRequest) XXX_Size() int
- func (m *ProfileRequest) XXX_Unmarshal(b []byte) error
- type SetLogLevelRequest
- func (*SetLogLevelRequest) Descriptor() ([]byte, []int)
- func (m *SetLogLevelRequest) GetDuration() *types.Duration
- func (m *SetLogLevelRequest) GetGrpc() SetLogLevelRequest_LogLevel
- func (m *SetLogLevelRequest) GetLevel() isSetLogLevelRequest_Level
- func (m *SetLogLevelRequest) GetPachyderm() SetLogLevelRequest_LogLevel
- func (m *SetLogLevelRequest) GetRecurse() bool
- func (m *SetLogLevelRequest) Marshal() (dAtA []byte, err error)
- func (x *SetLogLevelRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *SetLogLevelRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetLogLevelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetLogLevelRequest) ProtoMessage()
- func (m *SetLogLevelRequest) Reset()
- func (m *SetLogLevelRequest) Size() (n int)
- func (m *SetLogLevelRequest) String() string
- func (m *SetLogLevelRequest) Unmarshal(dAtA []byte) error
- func (m *SetLogLevelRequest) XXX_DiscardUnknown()
- func (m *SetLogLevelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetLogLevelRequest) XXX_Merge(src proto.Message)
- func (*SetLogLevelRequest) XXX_OneofWrappers() []interface{}
- func (m *SetLogLevelRequest) XXX_Size() int
- func (m *SetLogLevelRequest) XXX_Unmarshal(b []byte) error
- type SetLogLevelRequest_Grpc
- type SetLogLevelRequest_LogLevel
- type SetLogLevelRequest_Pachyderm
- type SetLogLevelResponse
- func (*SetLogLevelResponse) Descriptor() ([]byte, []int)
- func (m *SetLogLevelResponse) GetAffectedPods() []string
- func (m *SetLogLevelResponse) GetErroredPods() []string
- func (m *SetLogLevelResponse) Marshal() (dAtA []byte, err error)
- func (x *SetLogLevelResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *SetLogLevelResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetLogLevelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetLogLevelResponse) ProtoMessage()
- func (m *SetLogLevelResponse) Reset()
- func (m *SetLogLevelResponse) Size() (n int)
- func (m *SetLogLevelResponse) String() string
- func (m *SetLogLevelResponse) Unmarshal(dAtA []byte) error
- func (m *SetLogLevelResponse) XXX_DiscardUnknown()
- func (m *SetLogLevelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetLogLevelResponse) XXX_Merge(src proto.Message)
- func (m *SetLogLevelResponse) XXX_Size() int
- func (m *SetLogLevelResponse) XXX_Unmarshal(b []byte) error
- type System
- func (*System) Descriptor() ([]byte, []int)
- func (m *System) GetBinaries() []*App
- func (m *System) GetDatabase() bool
- func (m *System) GetDescribes() []*App
- func (m *System) GetHelm() bool
- func (m *System) GetLogs() []*App
- func (m *System) GetLokiLogs() []*App
- func (m *System) GetProfiles() []*App
- func (m *System) GetVersion() bool
- func (m *System) Marshal() (dAtA []byte, err error)
- func (x *System) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *System) MarshalTo(dAtA []byte) (int, error)
- func (m *System) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*System) ProtoMessage()
- func (m *System) Reset()
- func (m *System) Size() (n int)
- func (m *System) String() string
- func (m *System) Unmarshal(dAtA []byte) error
- func (m *System) XXX_DiscardUnknown()
- func (m *System) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *System) XXX_Merge(src proto.Message)
- func (m *System) XXX_Size() int
- func (m *System) XXX_Unmarshal(b []byte) error
- type UnimplementedDebugServer
- func (*UnimplementedDebugServer) Binary(req *BinaryRequest, srv Debug_BinaryServer) error
- func (*UnimplementedDebugServer) Dump(req *DumpRequest, srv Debug_DumpServer) error
- func (*UnimplementedDebugServer) DumpV2(req *DumpV2Request, srv Debug_DumpV2Server) error
- func (*UnimplementedDebugServer) GetDumpV2Template(ctx context.Context, req *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, error)
- func (*UnimplementedDebugServer) Profile(req *ProfileRequest, srv Debug_ProfileServer) error
- func (*UnimplementedDebugServer) SetLogLevel(ctx context.Context, req *SetLogLevelRequest) (*SetLogLevelResponse, error)
- type Worker
- func (*Worker) Descriptor() ([]byte, []int)
- func (m *Worker) GetPod() string
- func (m *Worker) GetRedirected() bool
- func (m *Worker) Marshal() (dAtA []byte, err error)
- func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *Worker) MarshalTo(dAtA []byte) (int, error)
- func (m *Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Worker) ProtoMessage()
- func (m *Worker) Reset()
- func (m *Worker) Size() (n int)
- func (m *Worker) String() string
- func (m *Worker) Unmarshal(dAtA []byte) error
- func (m *Worker) XXX_DiscardUnknown()
- func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Worker) XXX_Merge(src proto.Message)
- func (m *Worker) XXX_Size() int
- func (m *Worker) XXX_Unmarshal(b []byte) error
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 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 int64 `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"` Pipeline *Pipeline `protobuf:"bytes,4,opt,name=pipeline,proto3" json:"pipeline,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*App) Descriptor ¶ added in v2.7.0
func (*App) GetPipeline ¶ added in v2.7.0
func (*App) GetTimeout ¶ added in v2.7.0
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) XXX_DiscardUnknown ¶
func (m *App) XXX_DiscardUnknown()
func (*App) XXX_Unmarshal ¶
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) 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) 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://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) GetDumpV2Template(context.Context, *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, error) DumpV2(*DumpV2Request, Debug_DumpV2Server) 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_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() (*types.BytesValue, error) grpc.ClientStream }
type Debug_ProfileServer ¶
type Debug_ProfileServer interface { Send(*types.BytesValue) error grpc.ServerStream }
type DumpChunk ¶ added in v2.7.0
type DumpChunk struct { // Types that are valid to be assigned to Chunk: // *DumpChunk_Content // *DumpChunk_Progress Chunk isDumpChunk_Chunk `protobuf_oneof:"chunk"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpChunk) Descriptor ¶ added in v2.7.0
func (*DumpChunk) GetContent ¶ added in v2.7.0
func (m *DumpChunk) GetContent() *DumpContent
func (*DumpChunk) GetProgress ¶ added in v2.7.0
func (m *DumpChunk) GetProgress() *DumpProgress
func (*DumpChunk) MarshalLogObject ¶ added in v2.7.0
func (x *DumpChunk) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpChunk) MarshalToSizedBuffer ¶
func (*DumpChunk) ProtoMessage ¶ added in v2.7.0
func (*DumpChunk) ProtoMessage()
func (*DumpChunk) XXX_DiscardUnknown ¶
func (m *DumpChunk) XXX_DiscardUnknown()
func (*DumpChunk) XXX_Marshal ¶
func (*DumpChunk) XXX_OneofWrappers ¶
func (*DumpChunk) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DumpChunk) XXX_Unmarshal ¶
type DumpChunk_Content ¶ added in v2.7.0
type DumpChunk_Content struct {
Content *DumpContent `protobuf:"bytes,1,opt,name=content,proto3,oneof" json:"content,omitempty"`
}
func (*DumpChunk_Content) MarshalTo ¶
func (m *DumpChunk_Content) MarshalTo(dAtA []byte) (int, error)
func (*DumpChunk_Content) MarshalToSizedBuffer ¶
func (m *DumpChunk_Content) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpChunk_Content) Size ¶
func (m *DumpChunk_Content) Size() (n int)
type DumpChunk_Progress ¶ added in v2.7.0
type DumpChunk_Progress struct {
Progress *DumpProgress `protobuf:"bytes,2,opt,name=progress,proto3,oneof" json:"progress,omitempty"`
}
func (*DumpChunk_Progress) MarshalTo ¶
func (m *DumpChunk_Progress) MarshalTo(dAtA []byte) (int, error)
func (*DumpChunk_Progress) MarshalToSizedBuffer ¶
func (m *DumpChunk_Progress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpChunk_Progress) Size ¶
func (m *DumpChunk_Progress) Size() (n int)
type DumpContent ¶ added in v2.7.0
type DumpContent struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpContent) Descriptor ¶ added in v2.7.0
func (*DumpContent) Descriptor() ([]byte, []int)
func (*DumpContent) GetContent ¶ added in v2.7.0
func (m *DumpContent) GetContent() []byte
func (*DumpContent) Marshal ¶
func (m *DumpContent) Marshal() (dAtA []byte, err error)
func (*DumpContent) MarshalLogObject ¶ added in v2.7.0
func (x *DumpContent) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpContent) MarshalToSizedBuffer ¶
func (m *DumpContent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpContent) ProtoMessage ¶ added in v2.7.0
func (*DumpContent) ProtoMessage()
func (*DumpContent) Reset ¶ added in v2.7.0
func (m *DumpContent) Reset()
func (*DumpContent) Size ¶
func (m *DumpContent) Size() (n int)
func (*DumpContent) String ¶ added in v2.7.0
func (m *DumpContent) String() string
func (*DumpContent) Unmarshal ¶
func (m *DumpContent) Unmarshal(dAtA []byte) error
func (*DumpContent) XXX_DiscardUnknown ¶
func (m *DumpContent) XXX_DiscardUnknown()
func (*DumpContent) XXX_Marshal ¶
func (m *DumpContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpContent) XXX_Merge ¶
func (m *DumpContent) XXX_Merge(src proto.Message)
func (*DumpContent) XXX_Size ¶
func (m *DumpContent) XXX_Size() int
func (*DumpContent) XXX_Unmarshal ¶
func (m *DumpContent) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpProgress) Descriptor ¶ added in v2.7.0
func (*DumpProgress) Descriptor() ([]byte, []int)
func (*DumpProgress) GetProgress ¶ added in v2.7.0
func (m *DumpProgress) GetProgress() int64
func (*DumpProgress) GetTask ¶ added in v2.7.0
func (m *DumpProgress) GetTask() string
func (*DumpProgress) GetTotal ¶ added in v2.7.0
func (m *DumpProgress) GetTotal() int64
func (*DumpProgress) Marshal ¶
func (m *DumpProgress) Marshal() (dAtA []byte, err error)
func (*DumpProgress) MarshalLogObject ¶ added in v2.7.0
func (x *DumpProgress) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpProgress) MarshalToSizedBuffer ¶
func (m *DumpProgress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpProgress) ProtoMessage ¶ added in v2.7.0
func (*DumpProgress) ProtoMessage()
func (*DumpProgress) Reset ¶ added in v2.7.0
func (m *DumpProgress) Reset()
func (*DumpProgress) Size ¶
func (m *DumpProgress) Size() (n int)
func (*DumpProgress) String ¶ added in v2.7.0
func (m *DumpProgress) String() string
func (*DumpProgress) Unmarshal ¶
func (m *DumpProgress) Unmarshal(dAtA []byte) error
func (*DumpProgress) XXX_DiscardUnknown ¶
func (m *DumpProgress) XXX_DiscardUnknown()
func (*DumpProgress) XXX_Marshal ¶
func (m *DumpProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpProgress) XXX_Merge ¶
func (m *DumpProgress) XXX_Merge(src proto.Message)
func (*DumpProgress) XXX_Size ¶
func (m *DumpProgress) XXX_Size() int
func (*DumpProgress) XXX_Unmarshal ¶
func (m *DumpProgress) XXX_Unmarshal(b []byte) error
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) 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 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 int64 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpV2Request) Descriptor ¶ added in v2.7.0
func (*DumpV2Request) Descriptor() ([]byte, []int)
func (*DumpV2Request) GetInputRepos ¶ added in v2.7.0
func (m *DumpV2Request) GetInputRepos() bool
func (*DumpV2Request) GetPipelines ¶ added in v2.7.0
func (m *DumpV2Request) GetPipelines() []*Pipeline
func (*DumpV2Request) GetSystem ¶ added in v2.7.0
func (m *DumpV2Request) GetSystem() *System
func (*DumpV2Request) GetTimeout ¶ added in v2.7.0
func (m *DumpV2Request) GetTimeout() int64
func (*DumpV2Request) Marshal ¶
func (m *DumpV2Request) Marshal() (dAtA []byte, err error)
func (*DumpV2Request) MarshalLogObject ¶ added in v2.7.0
func (x *DumpV2Request) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DumpV2Request) MarshalToSizedBuffer ¶
func (m *DumpV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpV2Request) ProtoMessage ¶ added in v2.7.0
func (*DumpV2Request) ProtoMessage()
func (*DumpV2Request) Reset ¶ added in v2.7.0
func (m *DumpV2Request) Reset()
func (*DumpV2Request) Size ¶
func (m *DumpV2Request) Size() (n int)
func (*DumpV2Request) String ¶ added in v2.7.0
func (m *DumpV2Request) String() string
func (*DumpV2Request) Unmarshal ¶
func (m *DumpV2Request) Unmarshal(dAtA []byte) error
func (*DumpV2Request) XXX_DiscardUnknown ¶
func (m *DumpV2Request) XXX_DiscardUnknown()
func (*DumpV2Request) XXX_Marshal ¶
func (m *DumpV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpV2Request) XXX_Merge ¶
func (m *DumpV2Request) XXX_Merge(src proto.Message)
func (*DumpV2Request) XXX_Size ¶
func (m *DumpV2Request) XXX_Size() int
func (*DumpV2Request) XXX_Unmarshal ¶
func (m *DumpV2Request) 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) GetDatabase ¶
func (*Filter) GetPipeline ¶
func (*Filter) MarshalLogObject ¶
func (x *Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Filter) MarshalToSizedBuffer ¶
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) XXX_DiscardUnknown ¶
func (m *Filter) XXX_DiscardUnknown()
func (*Filter) XXX_Marshal ¶
func (*Filter) XXX_OneofWrappers ¶
func (*Filter) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Filter) XXX_Unmarshal ¶
type Filter_Database ¶
type Filter_Database struct {
Database bool `protobuf:"varint,4,opt,name=database,proto3,oneof" json:"database,omitempty"`
}
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) 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) 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) MarshalToSizedBuffer ¶
func (m *Filter_Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Filter_Worker) Size ¶
func (m *Filter_Worker) Size() (n int)
type GetDumpV2TemplateRequest ¶ added in v2.7.0
type GetDumpV2TemplateRequest struct { Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDumpV2TemplateRequest) Descriptor ¶ added in v2.7.0
func (*GetDumpV2TemplateRequest) Descriptor() ([]byte, []int)
func (*GetDumpV2TemplateRequest) GetFilters ¶ added in v2.7.0
func (m *GetDumpV2TemplateRequest) GetFilters() []string
func (*GetDumpV2TemplateRequest) Marshal ¶
func (m *GetDumpV2TemplateRequest) Marshal() (dAtA []byte, err error)
func (*GetDumpV2TemplateRequest) MarshalLogObject ¶ added in v2.7.0
func (x *GetDumpV2TemplateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetDumpV2TemplateRequest) MarshalTo ¶
func (m *GetDumpV2TemplateRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetDumpV2TemplateRequest) MarshalToSizedBuffer ¶
func (m *GetDumpV2TemplateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDumpV2TemplateRequest) ProtoMessage ¶ added in v2.7.0
func (*GetDumpV2TemplateRequest) ProtoMessage()
func (*GetDumpV2TemplateRequest) Reset ¶ added in v2.7.0
func (m *GetDumpV2TemplateRequest) Reset()
func (*GetDumpV2TemplateRequest) Size ¶
func (m *GetDumpV2TemplateRequest) Size() (n int)
func (*GetDumpV2TemplateRequest) String ¶ added in v2.7.0
func (m *GetDumpV2TemplateRequest) String() string
func (*GetDumpV2TemplateRequest) Unmarshal ¶
func (m *GetDumpV2TemplateRequest) Unmarshal(dAtA []byte) error
func (*GetDumpV2TemplateRequest) XXX_DiscardUnknown ¶
func (m *GetDumpV2TemplateRequest) XXX_DiscardUnknown()
func (*GetDumpV2TemplateRequest) XXX_Marshal ¶
func (m *GetDumpV2TemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDumpV2TemplateRequest) XXX_Merge ¶
func (m *GetDumpV2TemplateRequest) XXX_Merge(src proto.Message)
func (*GetDumpV2TemplateRequest) XXX_Size ¶
func (m *GetDumpV2TemplateRequest) XXX_Size() int
func (*GetDumpV2TemplateRequest) XXX_Unmarshal ¶
func (m *GetDumpV2TemplateRequest) XXX_Unmarshal(b []byte) error
type GetDumpV2TemplateResponse ¶ added in v2.7.0
type GetDumpV2TemplateResponse struct { Request *DumpV2Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDumpV2TemplateResponse) Descriptor ¶ added in v2.7.0
func (*GetDumpV2TemplateResponse) Descriptor() ([]byte, []int)
func (*GetDumpV2TemplateResponse) GetRequest ¶ added in v2.7.0
func (m *GetDumpV2TemplateResponse) GetRequest() *DumpV2Request
func (*GetDumpV2TemplateResponse) Marshal ¶
func (m *GetDumpV2TemplateResponse) Marshal() (dAtA []byte, err error)
func (*GetDumpV2TemplateResponse) MarshalLogObject ¶ added in v2.7.0
func (x *GetDumpV2TemplateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetDumpV2TemplateResponse) MarshalTo ¶
func (m *GetDumpV2TemplateResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetDumpV2TemplateResponse) MarshalToSizedBuffer ¶
func (m *GetDumpV2TemplateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDumpV2TemplateResponse) ProtoMessage ¶ added in v2.7.0
func (*GetDumpV2TemplateResponse) ProtoMessage()
func (*GetDumpV2TemplateResponse) Reset ¶ added in v2.7.0
func (m *GetDumpV2TemplateResponse) Reset()
func (*GetDumpV2TemplateResponse) Size ¶
func (m *GetDumpV2TemplateResponse) Size() (n int)
func (*GetDumpV2TemplateResponse) String ¶ added in v2.7.0
func (m *GetDumpV2TemplateResponse) String() string
func (*GetDumpV2TemplateResponse) Unmarshal ¶
func (m *GetDumpV2TemplateResponse) Unmarshal(dAtA []byte) error
func (*GetDumpV2TemplateResponse) XXX_DiscardUnknown ¶
func (m *GetDumpV2TemplateResponse) XXX_DiscardUnknown()
func (*GetDumpV2TemplateResponse) XXX_Marshal ¶
func (m *GetDumpV2TemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDumpV2TemplateResponse) XXX_Merge ¶
func (m *GetDumpV2TemplateResponse) XXX_Merge(src proto.Message)
func (*GetDumpV2TemplateResponse) XXX_Size ¶
func (m *GetDumpV2TemplateResponse) XXX_Size() int
func (*GetDumpV2TemplateResponse) XXX_Unmarshal ¶
func (m *GetDumpV2TemplateResponse) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Pipeline) Descriptor ¶ 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) MarshalToSizedBuffer ¶
func (*Pipeline) ProtoMessage ¶ added in v2.7.0
func (*Pipeline) ProtoMessage()
func (*Pipeline) XXX_DiscardUnknown ¶
func (m *Pipeline) XXX_DiscardUnknown()
func (*Pipeline) XXX_Marshal ¶
func (*Pipeline) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Pod) Descriptor ¶ 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) XXX_DiscardUnknown ¶
func (m *Pod) XXX_DiscardUnknown()
func (*Pod) XXX_Unmarshal ¶
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) GetDuration ¶
func (*Profile) MarshalLogObject ¶
func (x *Profile) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Profile) MarshalToSizedBuffer ¶
func (*Profile) ProtoMessage ¶
func (*Profile) ProtoMessage()
func (*Profile) XXX_DiscardUnknown ¶
func (m *Profile) XXX_DiscardUnknown()
func (*Profile) XXX_Marshal ¶
func (*Profile) XXX_Unmarshal ¶
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) 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 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*System) Descriptor ¶ 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) MarshalToSizedBuffer ¶
func (*System) ProtoMessage ¶ added in v2.7.0
func (*System) ProtoMessage()
func (*System) XXX_DiscardUnknown ¶
func (m *System) XXX_DiscardUnknown()
func (*System) XXX_Marshal ¶
func (*System) XXX_Unmarshal ¶
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) DumpV2 ¶ added in v2.7.0
func (*UnimplementedDebugServer) DumpV2(req *DumpV2Request, srv Debug_DumpV2Server) error
func (*UnimplementedDebugServer) GetDumpV2Template ¶ added in v2.7.0
func (*UnimplementedDebugServer) GetDumpV2Template(ctx context.Context, req *GetDumpV2TemplateRequest) (*GetDumpV2TemplateResponse, 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) GetRedirected ¶
func (*Worker) MarshalLogObject ¶
func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*Worker) MarshalToSizedBuffer ¶
func (*Worker) ProtoMessage ¶
func (*Worker) ProtoMessage()
func (*Worker) XXX_DiscardUnknown ¶
func (m *Worker) XXX_DiscardUnknown()
func (*Worker) XXX_Marshal ¶
func (*Worker) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.