Documentation ¶
Overview ¶
Package logs is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client APIClient) error
- func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server APIServer) error
- func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
- type APIClient
- type APIServer
- type API_GetLogsClient
- type API_GetLogsServer
- type AdminLogQuery
- func (*AdminLogQuery) Descriptor() ([]byte, []int)deprecated
- func (m *AdminLogQuery) GetAdminType() isAdminLogQuery_AdminType
- func (x *AdminLogQuery) GetApp() string
- func (x *AdminLogQuery) GetLogql() string
- func (x *AdminLogQuery) GetMaster() *PipelineLogQuery
- func (x *AdminLogQuery) GetPod() string
- func (x *AdminLogQuery) GetPodContainer() *PodContainer
- func (x *AdminLogQuery) GetStorage() *PipelineLogQuery
- func (x *AdminLogQuery) GetUser() *UserLogQuery
- func (x *AdminLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*AdminLogQuery) ProtoMessage()
- func (x *AdminLogQuery) ProtoReflect() protoreflect.Message
- func (x *AdminLogQuery) Reset()
- func (x *AdminLogQuery) String() string
- func (m *AdminLogQuery) Validate() error
- func (m *AdminLogQuery) ValidateAll() error
- type AdminLogQueryMultiError
- type AdminLogQueryValidationError
- func (e AdminLogQueryValidationError) Cause() error
- func (e AdminLogQueryValidationError) Error() string
- func (e AdminLogQueryValidationError) ErrorName() string
- func (e AdminLogQueryValidationError) Field() string
- func (e AdminLogQueryValidationError) Key() bool
- func (e AdminLogQueryValidationError) Reason() string
- type AdminLogQuery_App
- type AdminLogQuery_Logql
- type AdminLogQuery_Master
- type AdminLogQuery_Pod
- type AdminLogQuery_PodContainer
- type AdminLogQuery_Storage
- type AdminLogQuery_User
- type GetLogsRequest
- func (*GetLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetLogsRequest) GetFilter() *LogFilter
- func (x *GetLogsRequest) GetQuery() *LogQuery
- func (x *GetLogsRequest) GetTail() bool
- func (x *GetLogsRequest) GetWantPagingHint() bool
- func (x *GetLogsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetLogsRequest) ProtoMessage()
- func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
- func (x *GetLogsRequest) Reset()
- func (x *GetLogsRequest) String() string
- func (m *GetLogsRequest) Validate() error
- func (m *GetLogsRequest) ValidateAll() error
- type GetLogsRequestMultiError
- type GetLogsRequestValidationError
- func (e GetLogsRequestValidationError) Cause() error
- func (e GetLogsRequestValidationError) Error() string
- func (e GetLogsRequestValidationError) ErrorName() string
- func (e GetLogsRequestValidationError) Field() string
- func (e GetLogsRequestValidationError) Key() bool
- func (e GetLogsRequestValidationError) Reason() string
- type GetLogsResponse
- func (*GetLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLogsResponse) GetLog() *LogMessage
- func (x *GetLogsResponse) GetPagingHint() *PagingHint
- func (m *GetLogsResponse) GetResponseType() isGetLogsResponse_ResponseType
- func (x *GetLogsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetLogsResponse) ProtoMessage()
- func (x *GetLogsResponse) ProtoReflect() protoreflect.Message
- func (x *GetLogsResponse) Reset()
- func (x *GetLogsResponse) String() string
- func (m *GetLogsResponse) Validate() error
- func (m *GetLogsResponse) ValidateAll() error
- type GetLogsResponseMultiError
- type GetLogsResponseValidationError
- func (e GetLogsResponseValidationError) Cause() error
- func (e GetLogsResponseValidationError) Error() string
- func (e GetLogsResponseValidationError) ErrorName() string
- func (e GetLogsResponseValidationError) Field() string
- func (e GetLogsResponseValidationError) Key() bool
- func (e GetLogsResponseValidationError) Reason() string
- type GetLogsResponse_Log
- type GetLogsResponse_PagingHint
- type JobDatumLogQuery
- func (*JobDatumLogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *JobDatumLogQuery) GetDatum() string
- func (x *JobDatumLogQuery) GetJob() string
- func (x *JobDatumLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*JobDatumLogQuery) ProtoMessage()
- func (x *JobDatumLogQuery) ProtoReflect() protoreflect.Message
- func (x *JobDatumLogQuery) Reset()
- func (x *JobDatumLogQuery) String() string
- func (m *JobDatumLogQuery) Validate() error
- func (m *JobDatumLogQuery) ValidateAll() error
- type JobDatumLogQueryMultiError
- type JobDatumLogQueryValidationError
- func (e JobDatumLogQueryValidationError) Cause() error
- func (e JobDatumLogQueryValidationError) Error() string
- func (e JobDatumLogQueryValidationError) ErrorName() string
- func (e JobDatumLogQueryValidationError) Field() string
- func (e JobDatumLogQueryValidationError) Key() bool
- func (e JobDatumLogQueryValidationError) Reason() string
- type LogFilter
- func (*LogFilter) Descriptor() ([]byte, []int)deprecated
- func (x *LogFilter) GetLevel() LogLevel
- func (x *LogFilter) GetLimit() uint64
- func (x *LogFilter) GetRegex() *RegexLogFilter
- func (x *LogFilter) GetTimeRange() *TimeRangeLogFilter
- func (x *LogFilter) GetUserLogsOnly() bool
- func (x *LogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*LogFilter) ProtoMessage()
- func (x *LogFilter) ProtoReflect() protoreflect.Message
- func (x *LogFilter) Reset()
- func (x *LogFilter) String() string
- func (m *LogFilter) Validate() error
- func (m *LogFilter) ValidateAll() error
- type LogFilterMultiError
- type LogFilterValidationError
- type LogLevel
- type LogMessage
- func (*LogMessage) Descriptor() ([]byte, []int)deprecated
- func (x *LogMessage) GetNativeTimestamp() *timestamppb.Timestamp
- func (x *LogMessage) GetObject() *structpb.Struct
- func (x *LogMessage) GetPpsLogMessage() *pps.LogMessage
- func (x *LogMessage) GetVerbatim() *VerbatimLogMessage
- func (x *LogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*LogMessage) ProtoMessage()
- func (x *LogMessage) ProtoReflect() protoreflect.Message
- func (x *LogMessage) Reset()
- func (x *LogMessage) String() string
- func (m *LogMessage) Validate() error
- func (m *LogMessage) ValidateAll() error
- type LogMessageMultiError
- type LogMessageValidationError
- type LogQuery
- func (*LogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *LogQuery) GetAdmin() *AdminLogQuery
- func (m *LogQuery) GetQueryType() isLogQuery_QueryType
- func (x *LogQuery) GetUser() *UserLogQuery
- func (x *LogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*LogQuery) ProtoMessage()
- func (x *LogQuery) ProtoReflect() protoreflect.Message
- func (x *LogQuery) Reset()
- func (x *LogQuery) String() string
- func (m *LogQuery) Validate() error
- func (m *LogQuery) ValidateAll() error
- type LogQueryMultiError
- type LogQueryValidationError
- type LogQuery_Admin
- type LogQuery_User
- type PagingHint
- func (*PagingHint) Descriptor() ([]byte, []int)deprecated
- func (x *PagingHint) GetNewer() *GetLogsRequest
- func (x *PagingHint) GetOlder() *GetLogsRequest
- func (x *PagingHint) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PagingHint) ProtoMessage()
- func (x *PagingHint) ProtoReflect() protoreflect.Message
- func (x *PagingHint) Reset()
- func (x *PagingHint) String() string
- func (m *PagingHint) Validate() error
- func (m *PagingHint) ValidateAll() error
- type PagingHintMultiError
- type PagingHintValidationError
- type PipelineDatumLogQuery
- func (*PipelineDatumLogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineDatumLogQuery) GetDatum() string
- func (x *PipelineDatumLogQuery) GetPipeline() *PipelineLogQuery
- func (x *PipelineDatumLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PipelineDatumLogQuery) ProtoMessage()
- func (x *PipelineDatumLogQuery) ProtoReflect() protoreflect.Message
- func (x *PipelineDatumLogQuery) Reset()
- func (x *PipelineDatumLogQuery) String() string
- func (m *PipelineDatumLogQuery) Validate() error
- func (m *PipelineDatumLogQuery) ValidateAll() error
- type PipelineDatumLogQueryMultiError
- type PipelineDatumLogQueryValidationError
- func (e PipelineDatumLogQueryValidationError) Cause() error
- func (e PipelineDatumLogQueryValidationError) Error() string
- func (e PipelineDatumLogQueryValidationError) ErrorName() string
- func (e PipelineDatumLogQueryValidationError) Field() string
- func (e PipelineDatumLogQueryValidationError) Key() bool
- func (e PipelineDatumLogQueryValidationError) Reason() string
- type PipelineJobLogQuery
- func (*PipelineJobLogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineJobLogQuery) GetJob() string
- func (x *PipelineJobLogQuery) GetPipeline() *PipelineLogQuery
- func (x *PipelineJobLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PipelineJobLogQuery) ProtoMessage()
- func (x *PipelineJobLogQuery) ProtoReflect() protoreflect.Message
- func (x *PipelineJobLogQuery) Reset()
- func (x *PipelineJobLogQuery) String() string
- func (m *PipelineJobLogQuery) Validate() error
- func (m *PipelineJobLogQuery) ValidateAll() error
- type PipelineJobLogQueryMultiError
- type PipelineJobLogQueryValidationError
- func (e PipelineJobLogQueryValidationError) Cause() error
- func (e PipelineJobLogQueryValidationError) Error() string
- func (e PipelineJobLogQueryValidationError) ErrorName() string
- func (e PipelineJobLogQueryValidationError) Field() string
- func (e PipelineJobLogQueryValidationError) Key() bool
- func (e PipelineJobLogQueryValidationError) Reason() string
- type PipelineLogQuery
- func (*PipelineLogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineLogQuery) GetPipeline() string
- func (x *PipelineLogQuery) GetProject() string
- func (x *PipelineLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PipelineLogQuery) ProtoMessage()
- func (x *PipelineLogQuery) ProtoReflect() protoreflect.Message
- func (x *PipelineLogQuery) Reset()
- func (x *PipelineLogQuery) String() string
- func (m *PipelineLogQuery) Validate() error
- func (m *PipelineLogQuery) ValidateAll() error
- type PipelineLogQueryMultiError
- type PipelineLogQueryValidationError
- func (e PipelineLogQueryValidationError) Cause() error
- func (e PipelineLogQueryValidationError) Error() string
- func (e PipelineLogQueryValidationError) ErrorName() string
- func (e PipelineLogQueryValidationError) Field() string
- func (e PipelineLogQueryValidationError) Key() bool
- func (e PipelineLogQueryValidationError) Reason() string
- type PodContainer
- func (*PodContainer) Descriptor() ([]byte, []int)deprecated
- func (x *PodContainer) GetContainer() string
- func (x *PodContainer) GetPod() string
- func (x *PodContainer) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PodContainer) ProtoMessage()
- func (x *PodContainer) ProtoReflect() protoreflect.Message
- func (x *PodContainer) Reset()
- func (x *PodContainer) String() string
- func (m *PodContainer) Validate() error
- func (m *PodContainer) ValidateAll() error
- type PodContainerMultiError
- type PodContainerValidationError
- func (e PodContainerValidationError) Cause() error
- func (e PodContainerValidationError) Error() string
- func (e PodContainerValidationError) ErrorName() string
- func (e PodContainerValidationError) Field() string
- func (e PodContainerValidationError) Key() bool
- func (e PodContainerValidationError) Reason() string
- type RegexLogFilter
- func (*RegexLogFilter) Descriptor() ([]byte, []int)deprecated
- func (x *RegexLogFilter) GetNegate() bool
- func (x *RegexLogFilter) GetPattern() string
- func (x *RegexLogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*RegexLogFilter) ProtoMessage()
- func (x *RegexLogFilter) ProtoReflect() protoreflect.Message
- func (x *RegexLogFilter) Reset()
- func (x *RegexLogFilter) String() string
- func (m *RegexLogFilter) Validate() error
- func (m *RegexLogFilter) ValidateAll() error
- type RegexLogFilterMultiError
- type RegexLogFilterValidationError
- func (e RegexLogFilterValidationError) Cause() error
- func (e RegexLogFilterValidationError) Error() string
- func (e RegexLogFilterValidationError) ErrorName() string
- func (e RegexLogFilterValidationError) Field() string
- func (e RegexLogFilterValidationError) Key() bool
- func (e RegexLogFilterValidationError) Reason() string
- type TimeRangeLogFilter
- func (*TimeRangeLogFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TimeRangeLogFilter) GetFrom() *timestamppb.Timestamp
- func (x *TimeRangeLogFilter) GetOffset() uint64
- func (x *TimeRangeLogFilter) GetUntil() *timestamppb.Timestamp
- func (x *TimeRangeLogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TimeRangeLogFilter) ProtoMessage()
- func (x *TimeRangeLogFilter) ProtoReflect() protoreflect.Message
- func (x *TimeRangeLogFilter) Reset()
- func (x *TimeRangeLogFilter) String() string
- func (m *TimeRangeLogFilter) Validate() error
- func (m *TimeRangeLogFilter) ValidateAll() error
- type TimeRangeLogFilterMultiError
- type TimeRangeLogFilterValidationError
- func (e TimeRangeLogFilterValidationError) Cause() error
- func (e TimeRangeLogFilterValidationError) Error() string
- func (e TimeRangeLogFilterValidationError) ErrorName() string
- func (e TimeRangeLogFilterValidationError) Field() string
- func (e TimeRangeLogFilterValidationError) Key() bool
- func (e TimeRangeLogFilterValidationError) Reason() string
- type UnimplementedAPIServer
- type UnsafeAPIServer
- type UserLogQuery
- func (*UserLogQuery) Descriptor() ([]byte, []int)deprecated
- func (x *UserLogQuery) GetDatum() string
- func (x *UserLogQuery) GetJob() string
- func (x *UserLogQuery) GetJobDatum() *JobDatumLogQuery
- func (x *UserLogQuery) GetPipeline() *PipelineLogQuery
- func (x *UserLogQuery) GetPipelineDatum() *PipelineDatumLogQuery
- func (x *UserLogQuery) GetPipelineJob() *PipelineJobLogQuery
- func (x *UserLogQuery) GetProject() string
- func (m *UserLogQuery) GetUserType() isUserLogQuery_UserType
- func (x *UserLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*UserLogQuery) ProtoMessage()
- func (x *UserLogQuery) ProtoReflect() protoreflect.Message
- func (x *UserLogQuery) Reset()
- func (x *UserLogQuery) String() string
- func (m *UserLogQuery) Validate() error
- func (m *UserLogQuery) ValidateAll() error
- type UserLogQueryMultiError
- type UserLogQueryValidationError
- func (e UserLogQueryValidationError) Cause() error
- func (e UserLogQueryValidationError) Error() string
- func (e UserLogQueryValidationError) ErrorName() string
- func (e UserLogQueryValidationError) Field() string
- func (e UserLogQueryValidationError) Key() bool
- func (e UserLogQueryValidationError) Reason() string
- type UserLogQuery_Datum
- type UserLogQuery_Job
- type UserLogQuery_JobDatum
- type UserLogQuery_Pipeline
- type UserLogQuery_PipelineDatum
- type UserLogQuery_PipelineJob
- type UserLogQuery_Project
- type VerbatimLogMessage
- func (*VerbatimLogMessage) Descriptor() ([]byte, []int)deprecated
- func (x *VerbatimLogMessage) GetLine() []byte
- func (x *VerbatimLogMessage) GetTimestamp() *timestamppb.Timestamp
- func (x *VerbatimLogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*VerbatimLogMessage) ProtoMessage()
- func (x *VerbatimLogMessage) ProtoReflect() protoreflect.Message
- func (x *VerbatimLogMessage) Reset()
- func (x *VerbatimLogMessage) String() string
- func (m *VerbatimLogMessage) Validate() error
- func (m *VerbatimLogMessage) ValidateAll() error
- type VerbatimLogMessageMultiError
- type VerbatimLogMessageValidationError
- func (e VerbatimLogMessageValidationError) Cause() error
- func (e VerbatimLogMessageValidationError) Error() string
- func (e VerbatimLogMessageValidationError) ErrorName() string
- func (e VerbatimLogMessageValidationError) Field() string
- func (e VerbatimLogMessageValidationError) Key() bool
- func (e VerbatimLogMessageValidationError) Reason() string
Constants ¶
const (
API_GetLogs_FullMethodName = "/logs.API/GetLogs"
)
Variables ¶
var ( LogLevel_name = map[int32]string{ 0: "LOG_LEVEL_UNSET", 1: "LOG_LEVEL_DEBUG", 2: "LOG_LEVEL_INFO", 3: "LOG_LEVEL_ERROR", } LogLevel_value = map[string]int32{ "LOG_LEVEL_UNSET": 0, "LOG_LEVEL_DEBUG": 1, "LOG_LEVEL_INFO": 2, "LOG_LEVEL_ERROR": 3, } )
Enum value maps for LogLevel.
var API_ServiceDesc = grpc.ServiceDesc{ ServiceName: "logs.API", HandlerType: (*APIServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetLogs", Handler: _API_GetLogs_Handler, ServerStreams: true, }, }, Metadata: "logs/logs.proto", }
API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_logs_logs_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAPIHandler ¶
RegisterAPIHandler registers the http handlers for service API to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterAPIHandlerClient ¶
RegisterAPIHandlerClient registers the http handlers for service API to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "APIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "APIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "APIClient" to call the correct interceptors.
func RegisterAPIHandlerFromEndpoint ¶
func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterAPIHandlerFromEndpoint is same as RegisterAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAPIHandlerServer ¶
RegisterAPIHandlerServer registers the http handlers for service API to "mux". UnaryRPC :call APIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAPIHandlerFromEndpoint instead.
func RegisterAPIServer ¶
func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
Types ¶
type APIClient ¶
type APIClient interface {
GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)
}
APIClient is the client API for API 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 NewAPIClient ¶
func NewAPIClient(cc grpc.ClientConnInterface) APIClient
type APIServer ¶
type APIServer interface { GetLogs(*GetLogsRequest, API_GetLogsServer) error // contains filtered or unexported methods }
APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility
type API_GetLogsClient ¶
type API_GetLogsClient interface { Recv() (*GetLogsResponse, error) grpc.ClientStream }
type API_GetLogsServer ¶
type API_GetLogsServer interface { Send(*GetLogsResponse) error grpc.ServerStream }
type AdminLogQuery ¶
type AdminLogQuery struct { // Types that are assignable to AdminType: // // *AdminLogQuery_Logql // *AdminLogQuery_Pod // *AdminLogQuery_PodContainer // *AdminLogQuery_App // *AdminLogQuery_Master // *AdminLogQuery_Storage // *AdminLogQuery_User AdminType isAdminLogQuery_AdminType `protobuf_oneof:"admin_type"` // contains filtered or unexported fields }
func (*AdminLogQuery) Descriptor
deprecated
func (*AdminLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use AdminLogQuery.ProtoReflect.Descriptor instead.
func (*AdminLogQuery) GetAdminType ¶
func (m *AdminLogQuery) GetAdminType() isAdminLogQuery_AdminType
func (*AdminLogQuery) GetApp ¶
func (x *AdminLogQuery) GetApp() string
func (*AdminLogQuery) GetLogql ¶
func (x *AdminLogQuery) GetLogql() string
func (*AdminLogQuery) GetMaster ¶
func (x *AdminLogQuery) GetMaster() *PipelineLogQuery
func (*AdminLogQuery) GetPod ¶
func (x *AdminLogQuery) GetPod() string
func (*AdminLogQuery) GetPodContainer ¶
func (x *AdminLogQuery) GetPodContainer() *PodContainer
func (*AdminLogQuery) GetStorage ¶
func (x *AdminLogQuery) GetStorage() *PipelineLogQuery
func (*AdminLogQuery) GetUser ¶
func (x *AdminLogQuery) GetUser() *UserLogQuery
func (*AdminLogQuery) MarshalLogObject ¶
func (x *AdminLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*AdminLogQuery) ProtoMessage ¶
func (*AdminLogQuery) ProtoMessage()
func (*AdminLogQuery) ProtoReflect ¶
func (x *AdminLogQuery) ProtoReflect() protoreflect.Message
func (*AdminLogQuery) Reset ¶
func (x *AdminLogQuery) Reset()
func (*AdminLogQuery) String ¶
func (x *AdminLogQuery) String() string
func (*AdminLogQuery) Validate ¶
func (m *AdminLogQuery) Validate() error
Validate checks the field values on AdminLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*AdminLogQuery) ValidateAll ¶
func (m *AdminLogQuery) ValidateAll() error
ValidateAll checks the field values on AdminLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AdminLogQueryMultiError, or nil if none found.
type AdminLogQueryMultiError ¶
type AdminLogQueryMultiError []error
AdminLogQueryMultiError is an error wrapping multiple validation errors returned by AdminLogQuery.ValidateAll() if the designated constraints aren't met.
func (AdminLogQueryMultiError) AllErrors ¶
func (m AdminLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (AdminLogQueryMultiError) Error ¶
func (m AdminLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type AdminLogQueryValidationError ¶
type AdminLogQueryValidationError struct {
// contains filtered or unexported fields
}
AdminLogQueryValidationError is the validation error returned by AdminLogQuery.Validate if the designated constraints aren't met.
func (AdminLogQueryValidationError) Cause ¶
func (e AdminLogQueryValidationError) Cause() error
Cause function returns cause value.
func (AdminLogQueryValidationError) Error ¶
func (e AdminLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (AdminLogQueryValidationError) ErrorName ¶
func (e AdminLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (AdminLogQueryValidationError) Field ¶
func (e AdminLogQueryValidationError) Field() string
Field function returns field value.
func (AdminLogQueryValidationError) Key ¶
func (e AdminLogQueryValidationError) Key() bool
Key function returns key value.
func (AdminLogQueryValidationError) Reason ¶
func (e AdminLogQueryValidationError) Reason() string
Reason function returns reason value.
type AdminLogQuery_App ¶
type AdminLogQuery_App struct { // One "app" (logql -> {app=X}). App string `protobuf:"bytes,4,opt,name=app,proto3,oneof"` }
type AdminLogQuery_Logql ¶
type AdminLogQuery_Logql struct { // Arbitrary LogQL query. Logql string `protobuf:"bytes,1,opt,name=logql,proto3,oneof"` }
type AdminLogQuery_Master ¶
type AdminLogQuery_Master struct { // All master worker lines from a pipeline. Master *PipelineLogQuery `protobuf:"bytes,5,opt,name=master,proto3,oneof"` }
type AdminLogQuery_Pod ¶
type AdminLogQuery_Pod struct { // A pod's logs (all containers). Pod string `protobuf:"bytes,2,opt,name=pod,proto3,oneof"` }
type AdminLogQuery_PodContainer ¶
type AdminLogQuery_PodContainer struct { // One container. PodContainer *PodContainer `protobuf:"bytes,3,opt,name=pod_container,json=podContainer,proto3,oneof"` }
type AdminLogQuery_Storage ¶
type AdminLogQuery_Storage struct { // All storage container lines from a pipeline. Storage *PipelineLogQuery `protobuf:"bytes,6,opt,name=storage,proto3,oneof"` }
type AdminLogQuery_User ¶
type AdminLogQuery_User struct { // All worker lines from a pipeline/job. User *UserLogQuery `protobuf:"bytes,7,opt,name=user,proto3,oneof"` }
type GetLogsRequest ¶
type GetLogsRequest struct { Query *LogQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Filter *LogFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` Tail bool `protobuf:"varint,3,opt,name=tail,proto3" json:"tail,omitempty"` WantPagingHint bool `protobuf:"varint,4,opt,name=want_paging_hint,json=wantPagingHint,proto3" json:"want_paging_hint,omitempty"` // contains filtered or unexported fields }
func (*GetLogsRequest) Descriptor
deprecated
func (*GetLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.
func (*GetLogsRequest) GetFilter ¶
func (x *GetLogsRequest) GetFilter() *LogFilter
func (*GetLogsRequest) GetQuery ¶
func (x *GetLogsRequest) GetQuery() *LogQuery
func (*GetLogsRequest) GetTail ¶
func (x *GetLogsRequest) GetTail() bool
func (*GetLogsRequest) GetWantPagingHint ¶
func (x *GetLogsRequest) GetWantPagingHint() bool
func (*GetLogsRequest) MarshalLogObject ¶
func (x *GetLogsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetLogsRequest) ProtoMessage ¶
func (*GetLogsRequest) ProtoMessage()
func (*GetLogsRequest) ProtoReflect ¶
func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
func (*GetLogsRequest) Reset ¶
func (x *GetLogsRequest) Reset()
func (*GetLogsRequest) String ¶
func (x *GetLogsRequest) String() string
func (*GetLogsRequest) Validate ¶
func (m *GetLogsRequest) Validate() error
Validate checks the field values on GetLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*GetLogsRequest) ValidateAll ¶
func (m *GetLogsRequest) ValidateAll() error
ValidateAll checks the field values on GetLogsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetLogsRequestMultiError, or nil if none found.
type GetLogsRequestMultiError ¶
type GetLogsRequestMultiError []error
GetLogsRequestMultiError is an error wrapping multiple validation errors returned by GetLogsRequest.ValidateAll() if the designated constraints aren't met.
func (GetLogsRequestMultiError) AllErrors ¶
func (m GetLogsRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (GetLogsRequestMultiError) Error ¶
func (m GetLogsRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type GetLogsRequestValidationError ¶
type GetLogsRequestValidationError struct {
// contains filtered or unexported fields
}
GetLogsRequestValidationError is the validation error returned by GetLogsRequest.Validate if the designated constraints aren't met.
func (GetLogsRequestValidationError) Cause ¶
func (e GetLogsRequestValidationError) Cause() error
Cause function returns cause value.
func (GetLogsRequestValidationError) Error ¶
func (e GetLogsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (GetLogsRequestValidationError) ErrorName ¶
func (e GetLogsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (GetLogsRequestValidationError) Field ¶
func (e GetLogsRequestValidationError) Field() string
Field function returns field value.
func (GetLogsRequestValidationError) Key ¶
func (e GetLogsRequestValidationError) Key() bool
Key function returns key value.
func (GetLogsRequestValidationError) Reason ¶
func (e GetLogsRequestValidationError) Reason() string
Reason function returns reason value.
type GetLogsResponse ¶
type GetLogsResponse struct { // Types that are assignable to ResponseType: // // *GetLogsResponse_PagingHint // *GetLogsResponse_Log ResponseType isGetLogsResponse_ResponseType `protobuf_oneof:"response_type"` // contains filtered or unexported fields }
func (*GetLogsResponse) Descriptor
deprecated
func (*GetLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsResponse.ProtoReflect.Descriptor instead.
func (*GetLogsResponse) GetLog ¶
func (x *GetLogsResponse) GetLog() *LogMessage
func (*GetLogsResponse) GetPagingHint ¶
func (x *GetLogsResponse) GetPagingHint() *PagingHint
func (*GetLogsResponse) GetResponseType ¶
func (m *GetLogsResponse) GetResponseType() isGetLogsResponse_ResponseType
func (*GetLogsResponse) MarshalLogObject ¶
func (x *GetLogsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetLogsResponse) ProtoMessage ¶
func (*GetLogsResponse) ProtoMessage()
func (*GetLogsResponse) ProtoReflect ¶
func (x *GetLogsResponse) ProtoReflect() protoreflect.Message
func (*GetLogsResponse) Reset ¶
func (x *GetLogsResponse) Reset()
func (*GetLogsResponse) String ¶
func (x *GetLogsResponse) String() string
func (*GetLogsResponse) Validate ¶
func (m *GetLogsResponse) Validate() error
Validate checks the field values on GetLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*GetLogsResponse) ValidateAll ¶
func (m *GetLogsResponse) ValidateAll() error
ValidateAll checks the field values on GetLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetLogsResponseMultiError, or nil if none found.
type GetLogsResponseMultiError ¶
type GetLogsResponseMultiError []error
GetLogsResponseMultiError is an error wrapping multiple validation errors returned by GetLogsResponse.ValidateAll() if the designated constraints aren't met.
func (GetLogsResponseMultiError) AllErrors ¶
func (m GetLogsResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (GetLogsResponseMultiError) Error ¶
func (m GetLogsResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type GetLogsResponseValidationError ¶
type GetLogsResponseValidationError struct {
// contains filtered or unexported fields
}
GetLogsResponseValidationError is the validation error returned by GetLogsResponse.Validate if the designated constraints aren't met.
func (GetLogsResponseValidationError) Cause ¶
func (e GetLogsResponseValidationError) Cause() error
Cause function returns cause value.
func (GetLogsResponseValidationError) Error ¶
func (e GetLogsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (GetLogsResponseValidationError) ErrorName ¶
func (e GetLogsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (GetLogsResponseValidationError) Field ¶
func (e GetLogsResponseValidationError) Field() string
Field function returns field value.
func (GetLogsResponseValidationError) Key ¶
func (e GetLogsResponseValidationError) Key() bool
Key function returns key value.
func (GetLogsResponseValidationError) Reason ¶
func (e GetLogsResponseValidationError) Reason() string
Reason function returns reason value.
type GetLogsResponse_Log ¶
type GetLogsResponse_Log struct {
Log *LogMessage `protobuf:"bytes,2,opt,name=log,proto3,oneof"`
}
type GetLogsResponse_PagingHint ¶
type GetLogsResponse_PagingHint struct {
PagingHint *PagingHint `protobuf:"bytes,1,opt,name=paging_hint,json=pagingHint,proto3,oneof"`
}
type JobDatumLogQuery ¶
type JobDatumLogQuery struct { // The hex-encoded ID of the job. Job string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // The hex-encoded ID of the datum. Datum string `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"` // contains filtered or unexported fields }
JobDatumLogQuery returns logs from the processing of one datum that was part of the job.
func (*JobDatumLogQuery) Descriptor
deprecated
func (*JobDatumLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use JobDatumLogQuery.ProtoReflect.Descriptor instead.
func (*JobDatumLogQuery) GetDatum ¶
func (x *JobDatumLogQuery) GetDatum() string
func (*JobDatumLogQuery) GetJob ¶
func (x *JobDatumLogQuery) GetJob() string
func (*JobDatumLogQuery) MarshalLogObject ¶
func (x *JobDatumLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*JobDatumLogQuery) ProtoMessage ¶
func (*JobDatumLogQuery) ProtoMessage()
func (*JobDatumLogQuery) ProtoReflect ¶
func (x *JobDatumLogQuery) ProtoReflect() protoreflect.Message
func (*JobDatumLogQuery) Reset ¶
func (x *JobDatumLogQuery) Reset()
func (*JobDatumLogQuery) String ¶
func (x *JobDatumLogQuery) String() string
func (*JobDatumLogQuery) Validate ¶
func (m *JobDatumLogQuery) Validate() error
Validate checks the field values on JobDatumLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*JobDatumLogQuery) ValidateAll ¶
func (m *JobDatumLogQuery) ValidateAll() error
ValidateAll checks the field values on JobDatumLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in JobDatumLogQueryMultiError, or nil if none found.
type JobDatumLogQueryMultiError ¶
type JobDatumLogQueryMultiError []error
JobDatumLogQueryMultiError is an error wrapping multiple validation errors returned by JobDatumLogQuery.ValidateAll() if the designated constraints aren't met.
func (JobDatumLogQueryMultiError) AllErrors ¶
func (m JobDatumLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (JobDatumLogQueryMultiError) Error ¶
func (m JobDatumLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type JobDatumLogQueryValidationError ¶
type JobDatumLogQueryValidationError struct {
// contains filtered or unexported fields
}
JobDatumLogQueryValidationError is the validation error returned by JobDatumLogQuery.Validate if the designated constraints aren't met.
func (JobDatumLogQueryValidationError) Cause ¶
func (e JobDatumLogQueryValidationError) Cause() error
Cause function returns cause value.
func (JobDatumLogQueryValidationError) Error ¶
func (e JobDatumLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (JobDatumLogQueryValidationError) ErrorName ¶
func (e JobDatumLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (JobDatumLogQueryValidationError) Field ¶
func (e JobDatumLogQueryValidationError) Field() string
Field function returns field value.
func (JobDatumLogQueryValidationError) Key ¶
func (e JobDatumLogQueryValidationError) Key() bool
Key function returns key value.
func (JobDatumLogQueryValidationError) Reason ¶
func (e JobDatumLogQueryValidationError) Reason() string
Reason function returns reason value.
type LogFilter ¶
type LogFilter struct { // If set, only return logs in the provided time range. TimeRange *TimeRangeLogFilter `protobuf:"bytes,1,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // If set, return at maximum this number of logs. Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // If set, only return logs that match this regular expression. Regex *RegexLogFilter `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"` // If set, only return logs that are greater than or equal to this log level. (DEBUG returns // DEBUG, INFO, ERROR, INFO returns INFO and ERROR, etc.). Level LogLevel `protobuf:"varint,4,opt,name=level,proto3,enum=logs.LogLevel" json:"level,omitempty"` // If true, only return logs from user code, excluding matched log messages only related to // internal Pachyderm operations. UserLogsOnly bool `protobuf:"varint,5,opt,name=user_logs_only,json=userLogsOnly,proto3" json:"user_logs_only,omitempty"` // contains filtered or unexported fields }
A LogFilter selects which log lines are returned.
func (*LogFilter) Descriptor
deprecated
func (*LogFilter) GetRegex ¶
func (x *LogFilter) GetRegex() *RegexLogFilter
func (*LogFilter) GetTimeRange ¶
func (x *LogFilter) GetTimeRange() *TimeRangeLogFilter
func (*LogFilter) GetUserLogsOnly ¶ added in v2.11.0
func (*LogFilter) MarshalLogObject ¶
func (x *LogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*LogFilter) ProtoMessage ¶
func (*LogFilter) ProtoMessage()
func (*LogFilter) ProtoReflect ¶
func (x *LogFilter) ProtoReflect() protoreflect.Message
func (*LogFilter) Validate ¶
Validate checks the field values on LogFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LogFilter) ValidateAll ¶
ValidateAll checks the field values on LogFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogFilterMultiError, or nil if none found.
type LogFilterMultiError ¶
type LogFilterMultiError []error
LogFilterMultiError is an error wrapping multiple validation errors returned by LogFilter.ValidateAll() if the designated constraints aren't met.
func (LogFilterMultiError) AllErrors ¶
func (m LogFilterMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LogFilterMultiError) Error ¶
func (m LogFilterMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LogFilterValidationError ¶
type LogFilterValidationError struct {
// contains filtered or unexported fields
}
LogFilterValidationError is the validation error returned by LogFilter.Validate if the designated constraints aren't met.
func (LogFilterValidationError) Cause ¶
func (e LogFilterValidationError) Cause() error
Cause function returns cause value.
func (LogFilterValidationError) Error ¶
func (e LogFilterValidationError) Error() string
Error satisfies the builtin error interface
func (LogFilterValidationError) ErrorName ¶
func (e LogFilterValidationError) ErrorName() string
ErrorName returns error name.
func (LogFilterValidationError) Field ¶
func (e LogFilterValidationError) Field() string
Field function returns field value.
func (LogFilterValidationError) Key ¶
func (e LogFilterValidationError) Key() bool
Key function returns key value.
func (LogFilterValidationError) Reason ¶
func (e LogFilterValidationError) Reason() string
Reason function returns reason value.
type LogLevel ¶
type LogLevel int32
LogLevel selects a log level. Pachyderm services only have DEBUG, INFO, and ERROR.
func (LogLevel) Descriptor ¶
func (LogLevel) Descriptor() protoreflect.EnumDescriptor
func (LogLevel) EnumDescriptor
deprecated
func (LogLevel) Number ¶
func (x LogLevel) Number() protoreflect.EnumNumber
func (LogLevel) Type ¶
func (LogLevel) Type() protoreflect.EnumType
type LogMessage ¶
type LogMessage struct { // The verbatim line from Loki Verbatim *VerbatimLogMessage `protobuf:"bytes,1,opt,name=verbatim,proto3" json:"verbatim,omitempty"` // A raw JSON parse of the entire line Object *structpb.Struct `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"` // If a parseable timestamp was found in `fields` NativeTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=native_timestamp,json=nativeTimestamp,proto3" json:"native_timestamp,omitempty"` // For code that wants to filter on pipeline/job/etc PpsLogMessage *pps.LogMessage `protobuf:"bytes,4,opt,name=pps_log_message,json=ppsLogMessage,proto3" json:"pps_log_message,omitempty"` // contains filtered or unexported fields }
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetNativeTimestamp ¶
func (x *LogMessage) GetNativeTimestamp() *timestamppb.Timestamp
func (*LogMessage) GetObject ¶
func (x *LogMessage) GetObject() *structpb.Struct
func (*LogMessage) GetPpsLogMessage ¶
func (x *LogMessage) GetPpsLogMessage() *pps.LogMessage
func (*LogMessage) GetVerbatim ¶
func (x *LogMessage) GetVerbatim() *VerbatimLogMessage
func (*LogMessage) MarshalLogObject ¶
func (x *LogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
func (*LogMessage) Validate ¶
func (m *LogMessage) Validate() error
Validate checks the field values on LogMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LogMessage) ValidateAll ¶
func (m *LogMessage) ValidateAll() error
ValidateAll checks the field values on LogMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogMessageMultiError, or nil if none found.
type LogMessageMultiError ¶
type LogMessageMultiError []error
LogMessageMultiError is an error wrapping multiple validation errors returned by LogMessage.ValidateAll() if the designated constraints aren't met.
func (LogMessageMultiError) AllErrors ¶
func (m LogMessageMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LogMessageMultiError) Error ¶
func (m LogMessageMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LogMessageValidationError ¶
type LogMessageValidationError struct {
// contains filtered or unexported fields
}
LogMessageValidationError is the validation error returned by LogMessage.Validate if the designated constraints aren't met.
func (LogMessageValidationError) Cause ¶
func (e LogMessageValidationError) Cause() error
Cause function returns cause value.
func (LogMessageValidationError) Error ¶
func (e LogMessageValidationError) Error() string
Error satisfies the builtin error interface
func (LogMessageValidationError) ErrorName ¶
func (e LogMessageValidationError) ErrorName() string
ErrorName returns error name.
func (LogMessageValidationError) Field ¶
func (e LogMessageValidationError) Field() string
Field function returns field value.
func (LogMessageValidationError) Key ¶
func (e LogMessageValidationError) Key() bool
Key function returns key value.
func (LogMessageValidationError) Reason ¶
func (e LogMessageValidationError) Reason() string
Reason function returns reason value.
type LogQuery ¶
type LogQuery struct { // Types that are assignable to QueryType: // // *LogQuery_User // *LogQuery_Admin QueryType isLogQuery_QueryType `protobuf_oneof:"query_type"` // contains filtered or unexported fields }
LogQuery names a source of logs.
func (*LogQuery) Descriptor
deprecated
func (*LogQuery) GetAdmin ¶
func (x *LogQuery) GetAdmin() *AdminLogQuery
func (*LogQuery) GetQueryType ¶
func (m *LogQuery) GetQueryType() isLogQuery_QueryType
func (*LogQuery) GetUser ¶
func (x *LogQuery) GetUser() *UserLogQuery
func (*LogQuery) MarshalLogObject ¶
func (x *LogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*LogQuery) ProtoMessage ¶
func (*LogQuery) ProtoMessage()
func (*LogQuery) ProtoReflect ¶
func (x *LogQuery) ProtoReflect() protoreflect.Message
func (*LogQuery) Validate ¶
Validate checks the field values on LogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*LogQuery) ValidateAll ¶
ValidateAll checks the field values on LogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogQueryMultiError, or nil if none found.
type LogQueryMultiError ¶
type LogQueryMultiError []error
LogQueryMultiError is an error wrapping multiple validation errors returned by LogQuery.ValidateAll() if the designated constraints aren't met.
func (LogQueryMultiError) AllErrors ¶
func (m LogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (LogQueryMultiError) Error ¶
func (m LogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type LogQueryValidationError ¶
type LogQueryValidationError struct {
// contains filtered or unexported fields
}
LogQueryValidationError is the validation error returned by LogQuery.Validate if the designated constraints aren't met.
func (LogQueryValidationError) Cause ¶
func (e LogQueryValidationError) Cause() error
Cause function returns cause value.
func (LogQueryValidationError) Error ¶
func (e LogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (LogQueryValidationError) ErrorName ¶
func (e LogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (LogQueryValidationError) Field ¶
func (e LogQueryValidationError) Field() string
Field function returns field value.
func (LogQueryValidationError) Key ¶
func (e LogQueryValidationError) Key() bool
Key function returns key value.
func (LogQueryValidationError) Reason ¶
func (e LogQueryValidationError) Reason() string
Reason function returns reason value.
type LogQuery_Admin ¶
type LogQuery_Admin struct { // A more broad log query that requires special permissions; useful for debugging Pachyderm // itself. Admin *AdminLogQuery `protobuf:"bytes,2,opt,name=admin,proto3,oneof"` }
type LogQuery_User ¶
type LogQuery_User struct { // A user query; covering day-to-day Pachyderm use cases. User *UserLogQuery `protobuf:"bytes,1,opt,name=user,proto3,oneof"` }
type PagingHint ¶
type PagingHint struct { Older *GetLogsRequest `protobuf:"bytes,1,opt,name=older,proto3" json:"older,omitempty"` Newer *GetLogsRequest `protobuf:"bytes,2,opt,name=newer,proto3" json:"newer,omitempty"` // contains filtered or unexported fields }
func (*PagingHint) Descriptor
deprecated
func (*PagingHint) Descriptor() ([]byte, []int)
Deprecated: Use PagingHint.ProtoReflect.Descriptor instead.
func (*PagingHint) GetNewer ¶
func (x *PagingHint) GetNewer() *GetLogsRequest
func (*PagingHint) GetOlder ¶
func (x *PagingHint) GetOlder() *GetLogsRequest
func (*PagingHint) MarshalLogObject ¶
func (x *PagingHint) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PagingHint) ProtoMessage ¶
func (*PagingHint) ProtoMessage()
func (*PagingHint) ProtoReflect ¶
func (x *PagingHint) ProtoReflect() protoreflect.Message
func (*PagingHint) Reset ¶
func (x *PagingHint) Reset()
func (*PagingHint) String ¶
func (x *PagingHint) String() string
func (*PagingHint) Validate ¶
func (m *PagingHint) Validate() error
Validate checks the field values on PagingHint with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PagingHint) ValidateAll ¶
func (m *PagingHint) ValidateAll() error
ValidateAll checks the field values on PagingHint with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PagingHintMultiError, or nil if none found.
type PagingHintMultiError ¶
type PagingHintMultiError []error
PagingHintMultiError is an error wrapping multiple validation errors returned by PagingHint.ValidateAll() if the designated constraints aren't met.
func (PagingHintMultiError) AllErrors ¶
func (m PagingHintMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PagingHintMultiError) Error ¶
func (m PagingHintMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PagingHintValidationError ¶
type PagingHintValidationError struct {
// contains filtered or unexported fields
}
PagingHintValidationError is the validation error returned by PagingHint.Validate if the designated constraints aren't met.
func (PagingHintValidationError) Cause ¶
func (e PagingHintValidationError) Cause() error
Cause function returns cause value.
func (PagingHintValidationError) Error ¶
func (e PagingHintValidationError) Error() string
Error satisfies the builtin error interface
func (PagingHintValidationError) ErrorName ¶
func (e PagingHintValidationError) ErrorName() string
ErrorName returns error name.
func (PagingHintValidationError) Field ¶
func (e PagingHintValidationError) Field() string
Field function returns field value.
func (PagingHintValidationError) Key ¶
func (e PagingHintValidationError) Key() bool
Key function returns key value.
func (PagingHintValidationError) Reason ¶
func (e PagingHintValidationError) Reason() string
Reason function returns reason value.
type PipelineDatumLogQuery ¶ added in v2.11.0
type PipelineDatumLogQuery struct { // The pipeline. Pipeline *PipelineLogQuery `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // The hex-encoded ID of the datum. Datum string `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"` // contains filtered or unexported fields }
PipelineDatumLogQuery returns logs from one datum in one pipeline.
func (*PipelineDatumLogQuery) Descriptor
deprecated
added in
v2.11.0
func (*PipelineDatumLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipelineDatumLogQuery.ProtoReflect.Descriptor instead.
func (*PipelineDatumLogQuery) GetDatum ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) GetDatum() string
func (*PipelineDatumLogQuery) GetPipeline ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) GetPipeline() *PipelineLogQuery
func (*PipelineDatumLogQuery) MarshalLogObject ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PipelineDatumLogQuery) ProtoMessage ¶ added in v2.11.0
func (*PipelineDatumLogQuery) ProtoMessage()
func (*PipelineDatumLogQuery) ProtoReflect ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) ProtoReflect() protoreflect.Message
func (*PipelineDatumLogQuery) Reset ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) Reset()
func (*PipelineDatumLogQuery) String ¶ added in v2.11.0
func (x *PipelineDatumLogQuery) String() string
func (*PipelineDatumLogQuery) Validate ¶ added in v2.11.0
func (m *PipelineDatumLogQuery) Validate() error
Validate checks the field values on PipelineDatumLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PipelineDatumLogQuery) ValidateAll ¶ added in v2.11.0
func (m *PipelineDatumLogQuery) ValidateAll() error
ValidateAll checks the field values on PipelineDatumLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineDatumLogQueryMultiError, or nil if none found.
type PipelineDatumLogQueryMultiError ¶ added in v2.11.0
type PipelineDatumLogQueryMultiError []error
PipelineDatumLogQueryMultiError is an error wrapping multiple validation errors returned by PipelineDatumLogQuery.ValidateAll() if the designated constraints aren't met.
func (PipelineDatumLogQueryMultiError) AllErrors ¶ added in v2.11.0
func (m PipelineDatumLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PipelineDatumLogQueryMultiError) Error ¶ added in v2.11.0
func (m PipelineDatumLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PipelineDatumLogQueryValidationError ¶ added in v2.11.0
type PipelineDatumLogQueryValidationError struct {
// contains filtered or unexported fields
}
PipelineDatumLogQueryValidationError is the validation error returned by PipelineDatumLogQuery.Validate if the designated constraints aren't met.
func (PipelineDatumLogQueryValidationError) Cause ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) Cause() error
Cause function returns cause value.
func (PipelineDatumLogQueryValidationError) Error ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (PipelineDatumLogQueryValidationError) ErrorName ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (PipelineDatumLogQueryValidationError) Field ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) Field() string
Field function returns field value.
func (PipelineDatumLogQueryValidationError) Key ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) Key() bool
Key function returns key value.
func (PipelineDatumLogQueryValidationError) Reason ¶ added in v2.11.0
func (e PipelineDatumLogQueryValidationError) Reason() string
Reason function returns reason value.
type PipelineJobLogQuery ¶
type PipelineJobLogQuery struct { // The pipeline. Pipeline *PipelineLogQuery `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // The hex-encoded ID of the job. Job string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
PipelineJobLogQuery selects all logs from a job that a named pipeline performed.
func (*PipelineJobLogQuery) Descriptor
deprecated
func (*PipelineJobLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipelineJobLogQuery.ProtoReflect.Descriptor instead.
func (*PipelineJobLogQuery) GetJob ¶
func (x *PipelineJobLogQuery) GetJob() string
func (*PipelineJobLogQuery) GetPipeline ¶
func (x *PipelineJobLogQuery) GetPipeline() *PipelineLogQuery
func (*PipelineJobLogQuery) MarshalLogObject ¶
func (x *PipelineJobLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PipelineJobLogQuery) ProtoMessage ¶
func (*PipelineJobLogQuery) ProtoMessage()
func (*PipelineJobLogQuery) ProtoReflect ¶
func (x *PipelineJobLogQuery) ProtoReflect() protoreflect.Message
func (*PipelineJobLogQuery) Reset ¶
func (x *PipelineJobLogQuery) Reset()
func (*PipelineJobLogQuery) String ¶
func (x *PipelineJobLogQuery) String() string
func (*PipelineJobLogQuery) Validate ¶
func (m *PipelineJobLogQuery) Validate() error
Validate checks the field values on PipelineJobLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PipelineJobLogQuery) ValidateAll ¶
func (m *PipelineJobLogQuery) ValidateAll() error
ValidateAll checks the field values on PipelineJobLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineJobLogQueryMultiError, or nil if none found.
type PipelineJobLogQueryMultiError ¶
type PipelineJobLogQueryMultiError []error
PipelineJobLogQueryMultiError is an error wrapping multiple validation errors returned by PipelineJobLogQuery.ValidateAll() if the designated constraints aren't met.
func (PipelineJobLogQueryMultiError) AllErrors ¶
func (m PipelineJobLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PipelineJobLogQueryMultiError) Error ¶
func (m PipelineJobLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PipelineJobLogQueryValidationError ¶
type PipelineJobLogQueryValidationError struct {
// contains filtered or unexported fields
}
PipelineJobLogQueryValidationError is the validation error returned by PipelineJobLogQuery.Validate if the designated constraints aren't met.
func (PipelineJobLogQueryValidationError) Cause ¶
func (e PipelineJobLogQueryValidationError) Cause() error
Cause function returns cause value.
func (PipelineJobLogQueryValidationError) Error ¶
func (e PipelineJobLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (PipelineJobLogQueryValidationError) ErrorName ¶
func (e PipelineJobLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (PipelineJobLogQueryValidationError) Field ¶
func (e PipelineJobLogQueryValidationError) Field() string
Field function returns field value.
func (PipelineJobLogQueryValidationError) Key ¶
func (e PipelineJobLogQueryValidationError) Key() bool
Key function returns key value.
func (PipelineJobLogQueryValidationError) Reason ¶
func (e PipelineJobLogQueryValidationError) Reason() string
Reason function returns reason value.
type PipelineLogQuery ¶
type PipelineLogQuery struct { // The project the pipeline is in. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // The name of the pipeline. Pipeline string `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"` // contains filtered or unexported fields }
PipelineLogQuery selects all logs from all runs of a named pipeline.
func (*PipelineLogQuery) Descriptor
deprecated
func (*PipelineLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use PipelineLogQuery.ProtoReflect.Descriptor instead.
func (*PipelineLogQuery) GetPipeline ¶
func (x *PipelineLogQuery) GetPipeline() string
func (*PipelineLogQuery) GetProject ¶
func (x *PipelineLogQuery) GetProject() string
func (*PipelineLogQuery) MarshalLogObject ¶
func (x *PipelineLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PipelineLogQuery) ProtoMessage ¶
func (*PipelineLogQuery) ProtoMessage()
func (*PipelineLogQuery) ProtoReflect ¶
func (x *PipelineLogQuery) ProtoReflect() protoreflect.Message
func (*PipelineLogQuery) Reset ¶
func (x *PipelineLogQuery) Reset()
func (*PipelineLogQuery) String ¶
func (x *PipelineLogQuery) String() string
func (*PipelineLogQuery) Validate ¶
func (m *PipelineLogQuery) Validate() error
Validate checks the field values on PipelineLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PipelineLogQuery) ValidateAll ¶
func (m *PipelineLogQuery) ValidateAll() error
ValidateAll checks the field values on PipelineLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineLogQueryMultiError, or nil if none found.
type PipelineLogQueryMultiError ¶
type PipelineLogQueryMultiError []error
PipelineLogQueryMultiError is an error wrapping multiple validation errors returned by PipelineLogQuery.ValidateAll() if the designated constraints aren't met.
func (PipelineLogQueryMultiError) AllErrors ¶
func (m PipelineLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PipelineLogQueryMultiError) Error ¶
func (m PipelineLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PipelineLogQueryValidationError ¶
type PipelineLogQueryValidationError struct {
// contains filtered or unexported fields
}
PipelineLogQueryValidationError is the validation error returned by PipelineLogQuery.Validate if the designated constraints aren't met.
func (PipelineLogQueryValidationError) Cause ¶
func (e PipelineLogQueryValidationError) Cause() error
Cause function returns cause value.
func (PipelineLogQueryValidationError) Error ¶
func (e PipelineLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (PipelineLogQueryValidationError) ErrorName ¶
func (e PipelineLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (PipelineLogQueryValidationError) Field ¶
func (e PipelineLogQueryValidationError) Field() string
Field function returns field value.
func (PipelineLogQueryValidationError) Key ¶
func (e PipelineLogQueryValidationError) Key() bool
Key function returns key value.
func (PipelineLogQueryValidationError) Reason ¶
func (e PipelineLogQueryValidationError) Reason() string
Reason function returns reason value.
type PodContainer ¶
type PodContainer struct { // The full name of the pod. Pod string `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` // The name of the container. Container string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"` // contains filtered or unexported fields }
PodContainer identifies a container running in a Pod.
func (*PodContainer) Descriptor
deprecated
func (*PodContainer) Descriptor() ([]byte, []int)
Deprecated: Use PodContainer.ProtoReflect.Descriptor instead.
func (*PodContainer) GetContainer ¶
func (x *PodContainer) GetContainer() string
func (*PodContainer) GetPod ¶
func (x *PodContainer) GetPod() string
func (*PodContainer) MarshalLogObject ¶
func (x *PodContainer) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PodContainer) ProtoMessage ¶
func (*PodContainer) ProtoMessage()
func (*PodContainer) ProtoReflect ¶
func (x *PodContainer) ProtoReflect() protoreflect.Message
func (*PodContainer) Reset ¶
func (x *PodContainer) Reset()
func (*PodContainer) String ¶
func (x *PodContainer) String() string
func (*PodContainer) Validate ¶
func (m *PodContainer) Validate() error
Validate checks the field values on PodContainer with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PodContainer) ValidateAll ¶
func (m *PodContainer) ValidateAll() error
ValidateAll checks the field values on PodContainer with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PodContainerMultiError, or nil if none found.
type PodContainerMultiError ¶
type PodContainerMultiError []error
PodContainerMultiError is an error wrapping multiple validation errors returned by PodContainer.ValidateAll() if the designated constraints aren't met.
func (PodContainerMultiError) AllErrors ¶
func (m PodContainerMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PodContainerMultiError) Error ¶
func (m PodContainerMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PodContainerValidationError ¶
type PodContainerValidationError struct {
// contains filtered or unexported fields
}
PodContainerValidationError is the validation error returned by PodContainer.Validate if the designated constraints aren't met.
func (PodContainerValidationError) Cause ¶
func (e PodContainerValidationError) Cause() error
Cause function returns cause value.
func (PodContainerValidationError) Error ¶
func (e PodContainerValidationError) Error() string
Error satisfies the builtin error interface
func (PodContainerValidationError) ErrorName ¶
func (e PodContainerValidationError) ErrorName() string
ErrorName returns error name.
func (PodContainerValidationError) Field ¶
func (e PodContainerValidationError) Field() string
Field function returns field value.
func (PodContainerValidationError) Key ¶
func (e PodContainerValidationError) Key() bool
Key function returns key value.
func (PodContainerValidationError) Reason ¶
func (e PodContainerValidationError) Reason() string
Reason function returns reason value.
type RegexLogFilter ¶
type RegexLogFilter struct { Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"` Negate bool `protobuf:"varint,2,opt,name=negate,proto3" json:"negate,omitempty"` // contains filtered or unexported fields }
func (*RegexLogFilter) Descriptor
deprecated
func (*RegexLogFilter) Descriptor() ([]byte, []int)
Deprecated: Use RegexLogFilter.ProtoReflect.Descriptor instead.
func (*RegexLogFilter) GetNegate ¶
func (x *RegexLogFilter) GetNegate() bool
func (*RegexLogFilter) GetPattern ¶
func (x *RegexLogFilter) GetPattern() string
func (*RegexLogFilter) MarshalLogObject ¶
func (x *RegexLogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*RegexLogFilter) ProtoMessage ¶
func (*RegexLogFilter) ProtoMessage()
func (*RegexLogFilter) ProtoReflect ¶
func (x *RegexLogFilter) ProtoReflect() protoreflect.Message
func (*RegexLogFilter) Reset ¶
func (x *RegexLogFilter) Reset()
func (*RegexLogFilter) String ¶
func (x *RegexLogFilter) String() string
func (*RegexLogFilter) Validate ¶
func (m *RegexLogFilter) Validate() error
Validate checks the field values on RegexLogFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RegexLogFilter) ValidateAll ¶
func (m *RegexLogFilter) ValidateAll() error
ValidateAll checks the field values on RegexLogFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RegexLogFilterMultiError, or nil if none found.
type RegexLogFilterMultiError ¶
type RegexLogFilterMultiError []error
RegexLogFilterMultiError is an error wrapping multiple validation errors returned by RegexLogFilter.ValidateAll() if the designated constraints aren't met.
func (RegexLogFilterMultiError) AllErrors ¶
func (m RegexLogFilterMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RegexLogFilterMultiError) Error ¶
func (m RegexLogFilterMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RegexLogFilterValidationError ¶
type RegexLogFilterValidationError struct {
// contains filtered or unexported fields
}
RegexLogFilterValidationError is the validation error returned by RegexLogFilter.Validate if the designated constraints aren't met.
func (RegexLogFilterValidationError) Cause ¶
func (e RegexLogFilterValidationError) Cause() error
Cause function returns cause value.
func (RegexLogFilterValidationError) Error ¶
func (e RegexLogFilterValidationError) Error() string
Error satisfies the builtin error interface
func (RegexLogFilterValidationError) ErrorName ¶
func (e RegexLogFilterValidationError) ErrorName() string
ErrorName returns error name.
func (RegexLogFilterValidationError) Field ¶
func (e RegexLogFilterValidationError) Field() string
Field function returns field value.
func (RegexLogFilterValidationError) Key ¶
func (e RegexLogFilterValidationError) Key() bool
Key function returns key value.
func (RegexLogFilterValidationError) Reason ¶
func (e RegexLogFilterValidationError) Reason() string
Reason function returns reason value.
type TimeRangeLogFilter ¶
type TimeRangeLogFilter struct { // Where in time to start returning logs from; includes logs with this exact timestamp. If null, // starts at the beginning of time. From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // Where in time to stop returning logs from; includes logs with this exact timestamp. If null, // ends at the end of time. Until *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=until,proto3" json:"until,omitempty"` // Offset from which to return results, in the case of multiple entries from the same nanosecond. Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
A TimeRangeLogFilter selects logs within a time range. Either or both timestamps can be null. If from is after until, logs will be returns in reverse order. (The first log you see will always be from the "from" time.)
func (*TimeRangeLogFilter) Descriptor
deprecated
func (*TimeRangeLogFilter) Descriptor() ([]byte, []int)
Deprecated: Use TimeRangeLogFilter.ProtoReflect.Descriptor instead.
func (*TimeRangeLogFilter) GetFrom ¶
func (x *TimeRangeLogFilter) GetFrom() *timestamppb.Timestamp
func (*TimeRangeLogFilter) GetOffset ¶
func (x *TimeRangeLogFilter) GetOffset() uint64
func (*TimeRangeLogFilter) GetUntil ¶
func (x *TimeRangeLogFilter) GetUntil() *timestamppb.Timestamp
func (*TimeRangeLogFilter) MarshalLogObject ¶
func (x *TimeRangeLogFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TimeRangeLogFilter) ProtoMessage ¶
func (*TimeRangeLogFilter) ProtoMessage()
func (*TimeRangeLogFilter) ProtoReflect ¶
func (x *TimeRangeLogFilter) ProtoReflect() protoreflect.Message
func (*TimeRangeLogFilter) Reset ¶
func (x *TimeRangeLogFilter) Reset()
func (*TimeRangeLogFilter) String ¶
func (x *TimeRangeLogFilter) String() string
func (*TimeRangeLogFilter) Validate ¶
func (m *TimeRangeLogFilter) Validate() error
Validate checks the field values on TimeRangeLogFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*TimeRangeLogFilter) ValidateAll ¶
func (m *TimeRangeLogFilter) ValidateAll() error
ValidateAll checks the field values on TimeRangeLogFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TimeRangeLogFilterMultiError, or nil if none found.
type TimeRangeLogFilterMultiError ¶
type TimeRangeLogFilterMultiError []error
TimeRangeLogFilterMultiError is an error wrapping multiple validation errors returned by TimeRangeLogFilter.ValidateAll() if the designated constraints aren't met.
func (TimeRangeLogFilterMultiError) AllErrors ¶
func (m TimeRangeLogFilterMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (TimeRangeLogFilterMultiError) Error ¶
func (m TimeRangeLogFilterMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type TimeRangeLogFilterValidationError ¶
type TimeRangeLogFilterValidationError struct {
// contains filtered or unexported fields
}
TimeRangeLogFilterValidationError is the validation error returned by TimeRangeLogFilter.Validate if the designated constraints aren't met.
func (TimeRangeLogFilterValidationError) Cause ¶
func (e TimeRangeLogFilterValidationError) Cause() error
Cause function returns cause value.
func (TimeRangeLogFilterValidationError) Error ¶
func (e TimeRangeLogFilterValidationError) Error() string
Error satisfies the builtin error interface
func (TimeRangeLogFilterValidationError) ErrorName ¶
func (e TimeRangeLogFilterValidationError) ErrorName() string
ErrorName returns error name.
func (TimeRangeLogFilterValidationError) Field ¶
func (e TimeRangeLogFilterValidationError) Field() string
Field function returns field value.
func (TimeRangeLogFilterValidationError) Key ¶
func (e TimeRangeLogFilterValidationError) Key() bool
Key function returns key value.
func (TimeRangeLogFilterValidationError) Reason ¶
func (e TimeRangeLogFilterValidationError) Reason() string
Reason function returns reason value.
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer must be embedded to have forward compatible implementations.
func (UnimplementedAPIServer) GetLogs ¶
func (UnimplementedAPIServer) GetLogs(*GetLogsRequest, API_GetLogsServer) error
type UnsafeAPIServer ¶
type UnsafeAPIServer interface {
// contains filtered or unexported methods
}
UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.
type UserLogQuery ¶
type UserLogQuery struct { // Types that are assignable to UserType: // // *UserLogQuery_Project // *UserLogQuery_Pipeline // *UserLogQuery_Datum // *UserLogQuery_Job // *UserLogQuery_PipelineJob // *UserLogQuery_JobDatum // *UserLogQuery_PipelineDatum UserType isUserLogQuery_UserType `protobuf_oneof:"user_type"` // contains filtered or unexported fields }
A UserLogQuery selects logs that Pachyderm users need to see during normal Pachyderm operations.
func (*UserLogQuery) Descriptor
deprecated
func (*UserLogQuery) Descriptor() ([]byte, []int)
Deprecated: Use UserLogQuery.ProtoReflect.Descriptor instead.
func (*UserLogQuery) GetDatum ¶
func (x *UserLogQuery) GetDatum() string
func (*UserLogQuery) GetJob ¶
func (x *UserLogQuery) GetJob() string
func (*UserLogQuery) GetJobDatum ¶
func (x *UserLogQuery) GetJobDatum() *JobDatumLogQuery
func (*UserLogQuery) GetPipeline ¶
func (x *UserLogQuery) GetPipeline() *PipelineLogQuery
func (*UserLogQuery) GetPipelineDatum ¶ added in v2.11.0
func (x *UserLogQuery) GetPipelineDatum() *PipelineDatumLogQuery
func (*UserLogQuery) GetPipelineJob ¶
func (x *UserLogQuery) GetPipelineJob() *PipelineJobLogQuery
func (*UserLogQuery) GetProject ¶
func (x *UserLogQuery) GetProject() string
func (*UserLogQuery) GetUserType ¶
func (m *UserLogQuery) GetUserType() isUserLogQuery_UserType
func (*UserLogQuery) MarshalLogObject ¶
func (x *UserLogQuery) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*UserLogQuery) ProtoMessage ¶
func (*UserLogQuery) ProtoMessage()
func (*UserLogQuery) ProtoReflect ¶
func (x *UserLogQuery) ProtoReflect() protoreflect.Message
func (*UserLogQuery) Reset ¶
func (x *UserLogQuery) Reset()
func (*UserLogQuery) String ¶
func (x *UserLogQuery) String() string
func (*UserLogQuery) Validate ¶
func (m *UserLogQuery) Validate() error
Validate checks the field values on UserLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*UserLogQuery) ValidateAll ¶
func (m *UserLogQuery) ValidateAll() error
ValidateAll checks the field values on UserLogQuery with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UserLogQueryMultiError, or nil if none found.
type UserLogQueryMultiError ¶
type UserLogQueryMultiError []error
UserLogQueryMultiError is an error wrapping multiple validation errors returned by UserLogQuery.ValidateAll() if the designated constraints aren't met.
func (UserLogQueryMultiError) AllErrors ¶
func (m UserLogQueryMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UserLogQueryMultiError) Error ¶
func (m UserLogQueryMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UserLogQueryValidationError ¶
type UserLogQueryValidationError struct {
// contains filtered or unexported fields
}
UserLogQueryValidationError is the validation error returned by UserLogQuery.Validate if the designated constraints aren't met.
func (UserLogQueryValidationError) Cause ¶
func (e UserLogQueryValidationError) Cause() error
Cause function returns cause value.
func (UserLogQueryValidationError) Error ¶
func (e UserLogQueryValidationError) Error() string
Error satisfies the builtin error interface
func (UserLogQueryValidationError) ErrorName ¶
func (e UserLogQueryValidationError) ErrorName() string
ErrorName returns error name.
func (UserLogQueryValidationError) Field ¶
func (e UserLogQueryValidationError) Field() string
Field function returns field value.
func (UserLogQueryValidationError) Key ¶
func (e UserLogQueryValidationError) Key() bool
Key function returns key value.
func (UserLogQueryValidationError) Reason ¶
func (e UserLogQueryValidationError) Reason() string
Reason function returns reason value.
type UserLogQuery_Datum ¶
type UserLogQuery_Datum struct { // One datum, by hex-encoded ID. Datum string `protobuf:"bytes,3,opt,name=datum,proto3,oneof"` }
type UserLogQuery_Job ¶
type UserLogQuery_Job struct { // One job by hex-encoded ID, across pipelines and projects. Job string `protobuf:"bytes,4,opt,name=job,proto3,oneof"` }
type UserLogQuery_JobDatum ¶
type UserLogQuery_JobDatum struct { // One datum in one job. JobDatum *JobDatumLogQuery `protobuf:"bytes,6,opt,name=job_datum,json=jobDatum,proto3,oneof"` }
type UserLogQuery_Pipeline ¶
type UserLogQuery_Pipeline struct { // One pipeline in a project. Pipeline *PipelineLogQuery `protobuf:"bytes,2,opt,name=pipeline,proto3,oneof"` }
type UserLogQuery_PipelineDatum ¶ added in v2.11.0
type UserLogQuery_PipelineDatum struct { // One datum in one pipeline. PipelineDatum *PipelineDatumLogQuery `protobuf:"bytes,7,opt,name=pipeline_datum,json=pipelineDatum,proto3,oneof"` }
type UserLogQuery_PipelineJob ¶
type UserLogQuery_PipelineJob struct { // One job in one pipeline. PipelineJob *PipelineJobLogQuery `protobuf:"bytes,5,opt,name=pipeline_job,json=pipelineJob,proto3,oneof"` }
type UserLogQuery_Project ¶
type UserLogQuery_Project struct { // All pipelines in the project. Project string `protobuf:"bytes,1,opt,name=project,proto3,oneof"` }
type VerbatimLogMessage ¶
type VerbatimLogMessage struct { Line []byte `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*VerbatimLogMessage) Descriptor
deprecated
func (*VerbatimLogMessage) Descriptor() ([]byte, []int)
Deprecated: Use VerbatimLogMessage.ProtoReflect.Descriptor instead.
func (*VerbatimLogMessage) GetLine ¶
func (x *VerbatimLogMessage) GetLine() []byte
func (*VerbatimLogMessage) GetTimestamp ¶
func (x *VerbatimLogMessage) GetTimestamp() *timestamppb.Timestamp
func (*VerbatimLogMessage) MarshalLogObject ¶
func (x *VerbatimLogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*VerbatimLogMessage) ProtoMessage ¶
func (*VerbatimLogMessage) ProtoMessage()
func (*VerbatimLogMessage) ProtoReflect ¶
func (x *VerbatimLogMessage) ProtoReflect() protoreflect.Message
func (*VerbatimLogMessage) Reset ¶
func (x *VerbatimLogMessage) Reset()
func (*VerbatimLogMessage) String ¶
func (x *VerbatimLogMessage) String() string
func (*VerbatimLogMessage) Validate ¶
func (m *VerbatimLogMessage) Validate() error
Validate checks the field values on VerbatimLogMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*VerbatimLogMessage) ValidateAll ¶
func (m *VerbatimLogMessage) ValidateAll() error
ValidateAll checks the field values on VerbatimLogMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in VerbatimLogMessageMultiError, or nil if none found.
type VerbatimLogMessageMultiError ¶
type VerbatimLogMessageMultiError []error
VerbatimLogMessageMultiError is an error wrapping multiple validation errors returned by VerbatimLogMessage.ValidateAll() if the designated constraints aren't met.
func (VerbatimLogMessageMultiError) AllErrors ¶
func (m VerbatimLogMessageMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (VerbatimLogMessageMultiError) Error ¶
func (m VerbatimLogMessageMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type VerbatimLogMessageValidationError ¶
type VerbatimLogMessageValidationError struct {
// contains filtered or unexported fields
}
VerbatimLogMessageValidationError is the validation error returned by VerbatimLogMessage.Validate if the designated constraints aren't met.
func (VerbatimLogMessageValidationError) Cause ¶
func (e VerbatimLogMessageValidationError) Cause() error
Cause function returns cause value.
func (VerbatimLogMessageValidationError) Error ¶
func (e VerbatimLogMessageValidationError) Error() string
Error satisfies the builtin error interface
func (VerbatimLogMessageValidationError) ErrorName ¶
func (e VerbatimLogMessageValidationError) ErrorName() string
ErrorName returns error name.
func (VerbatimLogMessageValidationError) Field ¶
func (e VerbatimLogMessageValidationError) Field() string
Field function returns field value.
func (VerbatimLogMessageValidationError) Key ¶
func (e VerbatimLogMessageValidationError) Key() bool
Key function returns key value.
func (VerbatimLogMessageValidationError) Reason ¶
func (e VerbatimLogMessageValidationError) Reason() string
Reason function returns reason value.