logs

package
v2.12.0-alpha.1 Latest Latest
Warning

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

Go to latest
Published: Sep 4, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package logs is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	API_GetLogs_FullMethodName = "/logs.API/GetLogs"
)

Variables

View Source
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.

View Source
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)

View Source
var File_logs_logs_proto protoreflect.FileDescriptor

Functions

func RegisterAPIHandler

func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAPIHandler registers the http handlers for service API to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAPIHandlerClient

func RegisterAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client APIClient) error

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

func RegisterAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server APIServer) error

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

Cause function returns cause value.

func (AdminLogQueryValidationError) Error

Error satisfies the builtin error interface

func (AdminLogQueryValidationError) ErrorName

func (e AdminLogQueryValidationError) ErrorName() string

ErrorName returns error name.

func (AdminLogQueryValidationError) Field

Field function returns field value.

func (AdminLogQueryValidationError) Key

Key function returns key value.

func (AdminLogQueryValidationError) Reason

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

Cause function returns cause value.

func (GetLogsRequestValidationError) Error

Error satisfies the builtin error interface

func (GetLogsRequestValidationError) ErrorName

func (e GetLogsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetLogsRequestValidationError) Field

Field function returns field value.

func (GetLogsRequestValidationError) Key

Key function returns key value.

func (GetLogsRequestValidationError) Reason

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

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

Cause function returns cause value.

func (GetLogsResponseValidationError) Error

Error satisfies the builtin error interface

func (GetLogsResponseValidationError) ErrorName

func (e GetLogsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetLogsResponseValidationError) Field

Field function returns field value.

func (GetLogsResponseValidationError) Key

Key function returns key value.

func (GetLogsResponseValidationError) Reason

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

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

Cause function returns cause value.

func (JobDatumLogQueryValidationError) Error

Error satisfies the builtin error interface

func (JobDatumLogQueryValidationError) ErrorName

ErrorName returns error name.

func (JobDatumLogQueryValidationError) Field

Field function returns field value.

func (JobDatumLogQueryValidationError) Key

Key function returns key value.

func (JobDatumLogQueryValidationError) Reason

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) Descriptor() ([]byte, []int)

Deprecated: Use LogFilter.ProtoReflect.Descriptor instead.

func (*LogFilter) GetLevel

func (x *LogFilter) GetLevel() LogLevel

func (*LogFilter) GetLimit

func (x *LogFilter) GetLimit() uint64

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 (x *LogFilter) GetUserLogsOnly() bool

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) Reset

func (x *LogFilter) Reset()

func (*LogFilter) String

func (x *LogFilter) String() string

func (*LogFilter) Validate

func (m *LogFilter) Validate() error

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

func (m *LogFilter) ValidateAll() error

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

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.

const (
	// Use default log level filtering.
	LogLevel_LOG_LEVEL_UNSET LogLevel = 0
	// Include DEBUG, INFO, and ERROR logs.
	LogLevel_LOG_LEVEL_DEBUG LogLevel = 1
	// Include INFO and ERROR logs.
	LogLevel_LOG_LEVEL_INFO LogLevel = 2
	// Include only ERROR logs.
	LogLevel_LOG_LEVEL_ERROR LogLevel = 3
)

func (LogLevel) Descriptor

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated

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

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String

func (x LogLevel) String() string

func (LogLevel) Type

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

Error satisfies the builtin error interface

func (LogMessageValidationError) ErrorName

func (e LogMessageValidationError) ErrorName() string

ErrorName returns error name.

func (LogMessageValidationError) Field

Field function returns field value.

func (LogMessageValidationError) Key

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) Descriptor() ([]byte, []int)

Deprecated: Use LogQuery.ProtoReflect.Descriptor instead.

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) Reset

func (x *LogQuery) Reset()

func (*LogQuery) String

func (x *LogQuery) String() string

func (*LogQuery) Validate

func (m *LogQuery) Validate() error

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

func (m *LogQuery) ValidateAll() error

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

Error satisfies the builtin error interface

func (PagingHintValidationError) ErrorName

func (e PagingHintValidationError) ErrorName() string

ErrorName returns error name.

func (PagingHintValidationError) Field

Field function returns field value.

func (PagingHintValidationError) Key

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

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

Cause function returns cause value.

func (PipelineDatumLogQueryValidationError) Error added in v2.11.0

Error satisfies the builtin error interface

func (PipelineDatumLogQueryValidationError) ErrorName added in v2.11.0

ErrorName returns error name.

func (PipelineDatumLogQueryValidationError) Field added in v2.11.0

Field function returns field value.

func (PipelineDatumLogQueryValidationError) Key added in v2.11.0

Key function returns key value.

func (PipelineDatumLogQueryValidationError) Reason added in v2.11.0

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

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

Cause function returns cause value.

func (PipelineJobLogQueryValidationError) Error

Error satisfies the builtin error interface

func (PipelineJobLogQueryValidationError) ErrorName

ErrorName returns error name.

func (PipelineJobLogQueryValidationError) Field

Field function returns field value.

func (PipelineJobLogQueryValidationError) Key

Key function returns key value.

func (PipelineJobLogQueryValidationError) Reason

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

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

Cause function returns cause value.

func (PipelineLogQueryValidationError) Error

Error satisfies the builtin error interface

func (PipelineLogQueryValidationError) ErrorName

ErrorName returns error name.

func (PipelineLogQueryValidationError) Field

Field function returns field value.

func (PipelineLogQueryValidationError) Key

Key function returns key value.

func (PipelineLogQueryValidationError) Reason

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

Cause function returns cause value.

func (PodContainerValidationError) Error

Error satisfies the builtin error interface

func (PodContainerValidationError) ErrorName

func (e PodContainerValidationError) ErrorName() string

ErrorName returns error name.

func (PodContainerValidationError) Field

Field function returns field value.

func (PodContainerValidationError) Key

Key function returns key value.

func (PodContainerValidationError) Reason

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

Cause function returns cause value.

func (RegexLogFilterValidationError) Error

Error satisfies the builtin error interface

func (RegexLogFilterValidationError) ErrorName

func (e RegexLogFilterValidationError) ErrorName() string

ErrorName returns error name.

func (RegexLogFilterValidationError) Field

Field function returns field value.

func (RegexLogFilterValidationError) Key

Key function returns key value.

func (RegexLogFilterValidationError) Reason

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 (*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

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

Cause function returns cause value.

func (TimeRangeLogFilterValidationError) Error

Error satisfies the builtin error interface

func (TimeRangeLogFilterValidationError) ErrorName

ErrorName returns error name.

func (TimeRangeLogFilterValidationError) Field

Field function returns field value.

func (TimeRangeLogFilterValidationError) Key

Key function returns key value.

func (TimeRangeLogFilterValidationError) Reason

Reason function returns reason value.

type UnimplementedAPIServer

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) GetLogs

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

Cause function returns cause value.

func (UserLogQueryValidationError) Error

Error satisfies the builtin error interface

func (UserLogQueryValidationError) ErrorName

func (e UserLogQueryValidationError) ErrorName() string

ErrorName returns error name.

func (UserLogQueryValidationError) Field

Field function returns field value.

func (UserLogQueryValidationError) Key

Key function returns key value.

func (UserLogQueryValidationError) Reason

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

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

Cause function returns cause value.

func (VerbatimLogMessageValidationError) Error

Error satisfies the builtin error interface

func (VerbatimLogMessageValidationError) ErrorName

ErrorName returns error name.

func (VerbatimLogMessageValidationError) Field

Field function returns field value.

func (VerbatimLogMessageValidationError) Key

Key function returns key value.

func (VerbatimLogMessageValidationError) Reason

Reason function returns reason value.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL