logs

package
v2.10.1 Latest Latest
Warning

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

 Go to latest Published: May 22, 2024 License: Apache-2.0 Imports: 33 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_DEBUG",
		1: "LOG_LEVEL_INFO",
		2: "LOG_LEVEL_ERROR",
	}
	LogLevel_value = map[string]int32{
		"LOG_LEVEL_DEBUG": 0,
		"LOG_LEVEL_INFO":  1,
		"LOG_LEVEL_ERROR": 2,
	}
)

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 

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 {
	Job   string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Datum string `protobuf:"bytes,2,opt,name=datum,proto3" json:"datum,omitempty"`
	// contains filtered or unexported fields
}

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 {
	TimeRange *TimeRangeLogFilter `protobuf:"bytes,1,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	Limit     uint64              `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Regex     *RegexLogFilter     `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	// Minimum log level to return; worker will always run at level debug, but setting INFO here restores original behavior
	Level LogLevel `protobuf:"varint,4,opt,name=level,proto3,enum=logs.LogLevel" json:"level,omitempty"`
	// contains filtered or unexported fields
}

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

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
const (
	LogLevel_LOG_LEVEL_DEBUG LogLevel = 0
	LogLevel_LOG_LEVEL_INFO  LogLevel = 1
	LogLevel_LOG_LEVEL_ERROR LogLevel = 2
)

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 

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
}

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 {
	Admin *AdminLogQuery `protobuf:"bytes,2,opt,name=admin,proto3,oneof"`
}

type LogQuery_User 

type LogQuery_User struct {
	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 PipelineJobLogQuery 

type PipelineJobLogQuery struct {
	Pipeline *PipelineLogQuery `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Job      string            `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

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 {
	Project  string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Pipeline string `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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 {
	Pod       string `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	Container string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

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 {

	// Can be null
	From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Can be null
	Until *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=until,proto3" json:"until,omitempty"`
	// Offset from which to return results
	Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

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
	UserType isUserLogQuery_UserType `protobuf_oneof:"user_type"`
	// contains filtered or unexported fields
}

Only returns "user" logs

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) 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.
	Datum string `protobuf:"bytes,3,opt,name=datum,proto3,oneof"`
}

type UserLogQuery_Job 

type UserLogQuery_Job struct {
	// One job, 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_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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.