classifier

package
v1.9.9 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClassifierFileTemplates_ParseFile_FullMethodName          = "/api.v1alpha1.classifier.ClassifierFileTemplates/ParseFile"
	ClassifierFileTemplates_ListEvents_FullMethodName         = "/api.v1alpha1.classifier.ClassifierFileTemplates/ListEvents"
	ClassifierFileTemplates_PeekList_FullMethodName           = "/api.v1alpha1.classifier.ClassifierFileTemplates/PeekList"
	ClassifierFileTemplates_UpdateFileTemplate_FullMethodName = "/api.v1alpha1.classifier.ClassifierFileTemplates/UpdateFileTemplate"
	ClassifierFileTemplates_DeleteFileTemplate_FullMethodName = "/api.v1alpha1.classifier.ClassifierFileTemplates/DeleteFileTemplate"
	ClassifierFileTemplates_ListFileTemplates_FullMethodName  = "/api.v1alpha1.classifier.ClassifierFileTemplates/ListFileTemplates"
	ClassifierFileTemplates_GetFileTemplate_FullMethodName    = "/api.v1alpha1.classifier.ClassifierFileTemplates/GetFileTemplate"
)

Variables

View Source 
var ClassifierFileTemplates_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1alpha1.classifier.ClassifierFileTemplates",
	HandlerType: (*ClassifierFileTemplatesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ParseFile",
			Handler:    _ClassifierFileTemplates_ParseFile_Handler,
		},
		{
			MethodName: "ListEvents",
			Handler:    _ClassifierFileTemplates_ListEvents_Handler,
		},
		{
			MethodName: "PeekList",
			Handler:    _ClassifierFileTemplates_PeekList_Handler,
		},
		{
			MethodName: "UpdateFileTemplate",
			Handler:    _ClassifierFileTemplates_UpdateFileTemplate_Handler,
		},
		{
			MethodName: "DeleteFileTemplate",
			Handler:    _ClassifierFileTemplates_DeleteFileTemplate_Handler,
		},
		{
			MethodName: "ListFileTemplates",
			Handler:    _ClassifierFileTemplates_ListFileTemplates_Handler,
		},
		{
			MethodName: "GetFileTemplate",
			Handler:    _ClassifierFileTemplates_GetFileTemplate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1alpha1/classifier/service.proto",
}

ClassifierFileTemplates_ServiceDesc is the grpc.ServiceDesc for ClassifierFileTemplates 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_api_v1alpha1_classifier_entities_proto protoreflect.FileDescriptor
View Source 
var File_api_v1alpha1_classifier_service_proto protoreflect.FileDescriptor

Functions

func RegisterClassifierFileTemplatesServer 

func RegisterClassifierFileTemplatesServer(s grpc.ServiceRegistrar, srv ClassifierFileTemplatesServer)

Types

type ClassifierEntityTypes 

type ClassifierEntityTypes struct {
	Types []commons.ClassifierEntityType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=api.commons.ClassifierEntityType" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*ClassifierEntityTypes) Descriptor deprecated 

func (*ClassifierEntityTypes) Descriptor() ([]byte, []int)

Deprecated: Use ClassifierEntityTypes.ProtoReflect.Descriptor instead.

func (*ClassifierEntityTypes) GetTypes 

func (x *ClassifierEntityTypes) GetTypes() []commons.ClassifierEntityType

func (*ClassifierEntityTypes) ProtoMessage 

func (*ClassifierEntityTypes) ProtoMessage()

func (*ClassifierEntityTypes) ProtoReflect 

func (x *ClassifierEntityTypes) ProtoReflect() protoreflect.Message

func (*ClassifierEntityTypes) Reset 

func (x *ClassifierEntityTypes) Reset()

func (*ClassifierEntityTypes) String 

func (x *ClassifierEntityTypes) String() string

type ClassifierFileTemplatesClient 

type ClassifierFileTemplatesClient interface {
	ParseFile(ctx context.Context, in *ParseFileRequest, opts ...grpc.CallOption) (*ParseFileResponse, error)
	ListEvents(ctx context.Context, in *ListEventsRequest, opts ...grpc.CallOption) (*ListEventsResponse, error)
	PeekList(ctx context.Context, in *PeekListRequest, opts ...grpc.CallOption) (*PeekListResponse, error)
	UpdateFileTemplate(ctx context.Context, in *UpdateFileTemplateRequest, opts ...grpc.CallOption) (*UpdateFileTemplateResponse, error)
	DeleteFileTemplate(ctx context.Context, in *DeleteFileTemplateRequest, opts ...grpc.CallOption) (*DeleteFileTemplateResponse, error)
	ListFileTemplates(ctx context.Context, in *ListFileTemplatesRequest, opts ...grpc.CallOption) (*ListFileTemplatesResponse, error)
	GetFileTemplate(ctx context.Context, in *GetFileTemplateRequest, opts ...grpc.CallOption) (*GetFileTemplateResponse, error)
}

ClassifierFileTemplatesClient is the client API for ClassifierFileTemplates 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 NewClassifierFileTemplatesClient 

func NewClassifierFileTemplatesClient(cc grpc.ClientConnInterface) ClassifierFileTemplatesClient

type ClassifierFileTemplatesServer 

type ClassifierFileTemplatesServer interface {
	ParseFile(context.Context, *ParseFileRequest) (*ParseFileResponse, error)
	ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error)
	PeekList(context.Context, *PeekListRequest) (*PeekListResponse, error)
	UpdateFileTemplate(context.Context, *UpdateFileTemplateRequest) (*UpdateFileTemplateResponse, error)
	DeleteFileTemplate(context.Context, *DeleteFileTemplateRequest) (*DeleteFileTemplateResponse, error)
	ListFileTemplates(context.Context, *ListFileTemplatesRequest) (*ListFileTemplatesResponse, error)
	GetFileTemplate(context.Context, *GetFileTemplateRequest) (*GetFileTemplateResponse, error)
	// contains filtered or unexported methods
}

ClassifierFileTemplatesServer is the server API for ClassifierFileTemplates service. All implementations must embed UnimplementedClassifierFileTemplatesServer for forward compatibility.

type Constraints 

type Constraints struct {
	Forbid map[string]*ClassifierEntityTypes `` /* 139-byte string literal not displayed */
	Allow  map[string]*ClassifierEntityTypes `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

these are options to forbid/allow certain types from being guessed by Classifier

func (*Constraints) Descriptor deprecated 

func (*Constraints) Descriptor() ([]byte, []int)

Deprecated: Use Constraints.ProtoReflect.Descriptor instead.

func (*Constraints) GetAllow 

func (x *Constraints) GetAllow() map[string]*ClassifierEntityTypes

func (*Constraints) GetForbid 

func (x *Constraints) GetForbid() map[string]*ClassifierEntityTypes

func (*Constraints) ProtoMessage 

func (*Constraints) ProtoMessage()

func (*Constraints) ProtoReflect 

func (x *Constraints) ProtoReflect() protoreflect.Message

func (*Constraints) Reset 

func (x *Constraints) Reset()

func (*Constraints) String 

func (x *Constraints) String() string

type DeleteFileTemplateRequest 

type DeleteFileTemplateRequest struct {
	FileTemplate int64 `protobuf:"varint,1,opt,name=file_template,json=fileTemplate,proto3" json:"file_template,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFileTemplateRequest) Descriptor deprecated 

func (*DeleteFileTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileTemplateRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileTemplateRequest) GetFileTemplate 

func (x *DeleteFileTemplateRequest) GetFileTemplate() int64

func (*DeleteFileTemplateRequest) ProtoMessage 

func (*DeleteFileTemplateRequest) ProtoMessage()

func (*DeleteFileTemplateRequest) ProtoReflect 

func (x *DeleteFileTemplateRequest) ProtoReflect() protoreflect.Message

func (*DeleteFileTemplateRequest) Reset 

func (x *DeleteFileTemplateRequest) Reset()

func (*DeleteFileTemplateRequest) String 

func (x *DeleteFileTemplateRequest) String() string

type DeleteFileTemplateResponse 

type DeleteFileTemplateResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteFileTemplateResponse) Descriptor deprecated 

func (*DeleteFileTemplateResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteFileTemplateResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileTemplateResponse) ProtoMessage 

func (*DeleteFileTemplateResponse) ProtoMessage()

func (*DeleteFileTemplateResponse) ProtoReflect 

func (x *DeleteFileTemplateResponse) ProtoReflect() protoreflect.Message

func (*DeleteFileTemplateResponse) Reset 

func (x *DeleteFileTemplateResponse) Reset()

func (*DeleteFileTemplateResponse) String 

func (x *DeleteFileTemplateResponse) String() string

type FileTemplate 

type FileTemplate struct {
	FileTemplateId int64                 `protobuf:"varint,1,opt,name=file_template_id,json=fileTemplateId,proto3" json:"file_template_id,omitempty"`
	Filename       string                `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Fields         []*FileTemplate_Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// Deprecated: Marked as deprecated in api/v1alpha1/classifier/entities.proto.
	ParseOpts *ParseOpts `protobuf:"bytes,4,opt,name=parse_opts,json=parseOpts,proto3" json:"parse_opts,omitempty"`
	// Deprecated: Marked as deprecated in api/v1alpha1/classifier/entities.proto.
	Constraints *Constraints `protobuf:"bytes,5,opt,name=constraints,proto3" json:"constraints,omitempty"`
	Foid        int64        `protobuf:"varint,6,opt,name=foid,proto3" json:"foid,omitempty"`
	Opts        *Opts        `protobuf:"bytes,7,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*FileTemplate) Descriptor deprecated 

func (*FileTemplate) Descriptor() ([]byte, []int)

Deprecated: Use FileTemplate.ProtoReflect.Descriptor instead.

func (*FileTemplate) GetConstraints deprecated 

func (x *FileTemplate) GetConstraints() *Constraints

Deprecated: Marked as deprecated in api/v1alpha1/classifier/entities.proto.

func (*FileTemplate) GetFields 

func (x *FileTemplate) GetFields() []*FileTemplate_Field

func (*FileTemplate) GetFileTemplateId 

func (x *FileTemplate) GetFileTemplateId() int64

func (*FileTemplate) GetFilename 

func (x *FileTemplate) GetFilename() string

func (*FileTemplate) GetFoid 

func (x *FileTemplate) GetFoid() int64

func (*FileTemplate) GetOpts added in v1.7.76 

func (x *FileTemplate) GetOpts() *Opts

func (*FileTemplate) GetParseOpts deprecated 

func (x *FileTemplate) GetParseOpts() *ParseOpts

Deprecated: Marked as deprecated in api/v1alpha1/classifier/entities.proto.

func (*FileTemplate) ProtoMessage 

func (*FileTemplate) ProtoMessage()

func (*FileTemplate) ProtoReflect 

func (x *FileTemplate) ProtoReflect() protoreflect.Message

func (*FileTemplate) Reset 

func (x *FileTemplate) Reset()

func (*FileTemplate) String 

func (x *FileTemplate) String() string

type FileTemplate_Field 

type FileTemplate_Field struct {
	SyntaxType string                       `protobuf:"bytes,1,opt,name=syntax_type,json=syntaxType,proto3" json:"syntax_type,omitempty"`
	EntityType commons.ClassifierEntityType `` /* 130-byte string literal not displayed */
	Name       string                       `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Format     string                       `protobuf:"bytes,4,opt,name=format,proto3" json:"format,omitempty"`
	// example of a value for this field
	RawValue string `protobuf:"bytes,5,opt,name=raw_value,json=rawValue,proto3" json:"raw_value,omitempty"`
	// contains filtered or unexported fields
}

func (*FileTemplate_Field) Descriptor deprecated 

func (*FileTemplate_Field) Descriptor() ([]byte, []int)

Deprecated: Use FileTemplate_Field.ProtoReflect.Descriptor instead.

func (*FileTemplate_Field) GetEntityType 

func (x *FileTemplate_Field) GetEntityType() commons.ClassifierEntityType

func (*FileTemplate_Field) GetFormat 

func (x *FileTemplate_Field) GetFormat() string

func (*FileTemplate_Field) GetName 

func (x *FileTemplate_Field) GetName() string

func (*FileTemplate_Field) GetRawValue 

func (x *FileTemplate_Field) GetRawValue() string

func (*FileTemplate_Field) GetSyntaxType 

func (x *FileTemplate_Field) GetSyntaxType() string

func (*FileTemplate_Field) ProtoMessage 

func (*FileTemplate_Field) ProtoMessage()

func (*FileTemplate_Field) ProtoReflect 

func (x *FileTemplate_Field) ProtoReflect() protoreflect.Message

func (*FileTemplate_Field) Reset 

func (x *FileTemplate_Field) Reset()

func (*FileTemplate_Field) String 

func (x *FileTemplate_Field) String() string

type GetFileTemplateRequest 

type GetFileTemplateRequest struct {
	FileTemplateId int64 `protobuf:"varint,1,opt,name=file_template_id,json=fileTemplateId,proto3" json:"file_template_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileTemplateRequest) Descriptor deprecated 

func (*GetFileTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetFileTemplateRequest.ProtoReflect.Descriptor instead.

func (*GetFileTemplateRequest) GetFileTemplateId 

func (x *GetFileTemplateRequest) GetFileTemplateId() int64

func (*GetFileTemplateRequest) ProtoMessage 

func (*GetFileTemplateRequest) ProtoMessage()

func (*GetFileTemplateRequest) ProtoReflect 

func (x *GetFileTemplateRequest) ProtoReflect() protoreflect.Message

func (*GetFileTemplateRequest) Reset 

func (x *GetFileTemplateRequest) Reset()

func (*GetFileTemplateRequest) String 

func (x *GetFileTemplateRequest) String() string

type GetFileTemplateResponse 

type GetFileTemplateResponse struct {
	FileTemplate *FileTemplate `protobuf:"bytes,1,opt,name=file_template,json=fileTemplate,proto3" json:"file_template,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileTemplateResponse) Descriptor deprecated 

func (*GetFileTemplateResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetFileTemplateResponse.ProtoReflect.Descriptor instead.

func (*GetFileTemplateResponse) GetFileTemplate 

func (x *GetFileTemplateResponse) GetFileTemplate() *FileTemplate

func (*GetFileTemplateResponse) ProtoMessage 

func (*GetFileTemplateResponse) ProtoMessage()

func (*GetFileTemplateResponse) ProtoReflect 

func (x *GetFileTemplateResponse) ProtoReflect() protoreflect.Message

func (*GetFileTemplateResponse) Reset 

func (x *GetFileTemplateResponse) Reset()

func (*GetFileTemplateResponse) String 

func (x *GetFileTemplateResponse) String() string

type ListEventsRequest added in v1.9.0 

type ListEventsRequest struct {

	// which element we are looking at events for in the dag
	ElementId string `protobuf:"bytes,1,opt,name=element_id,json=elementId,proto3" json:"element_id,omitempty"`
	// the beginning of our time range
	Begin *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=begin,proto3" json:"begin,omitempty"`
	// end of the time range
	End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// group by step size.
	// How big of a time range we group the records on.
	// examples:
	// - 1h = 1 hour increments (default)
	// - 10m = 10 minute increments
	// - 3d = 3 day increments
	TimeRange string `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// optional, if provided, we only show data that came from this entrypoint id
	EntrypointId string `protobuf:"bytes,5,opt,name=entrypoint_id,json=entrypointId,proto3" json:"entrypoint_id,omitempty"`
	// optional, if provided we only show data that fed through to this element from
	// the parent_id
	ParentId string `protobuf:"bytes,6,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventsRequest) Descriptor deprecated added in v1.9.0 

func (*ListEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListEventsRequest.ProtoReflect.Descriptor instead.

func (*ListEventsRequest) GetBegin added in v1.9.0 

func (x *ListEventsRequest) GetBegin() *timestamppb.Timestamp

func (*ListEventsRequest) GetElementId added in v1.9.0 

func (x *ListEventsRequest) GetElementId() string

func (*ListEventsRequest) GetEnd added in v1.9.0 

func (x *ListEventsRequest) GetEnd() *timestamppb.Timestamp

func (*ListEventsRequest) GetEntrypointId added in v1.9.0 

func (x *ListEventsRequest) GetEntrypointId() string

func (*ListEventsRequest) GetParentId added in v1.9.0 

func (x *ListEventsRequest) GetParentId() string

func (*ListEventsRequest) GetTimeRange added in v1.9.0 

func (x *ListEventsRequest) GetTimeRange() string

func (*ListEventsRequest) ProtoMessage added in v1.9.0 

func (*ListEventsRequest) ProtoMessage()

func (*ListEventsRequest) ProtoReflect added in v1.9.0 

func (x *ListEventsRequest) ProtoReflect() protoreflect.Message

func (*ListEventsRequest) Reset added in v1.9.0 

func (x *ListEventsRequest) Reset()

func (*ListEventsRequest) String added in v1.9.0 

func (x *ListEventsRequest) String() string

type ListEventsResponse added in v1.9.0 

type ListEventsResponse struct {
	Rows []*ListEventsResponse_Row `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventsResponse) Descriptor deprecated added in v1.9.0 

func (*ListEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListEventsResponse.ProtoReflect.Descriptor instead.

func (*ListEventsResponse) GetRows added in v1.9.0 

func (x *ListEventsResponse) GetRows() []*ListEventsResponse_Row

func (*ListEventsResponse) ProtoMessage added in v1.9.0 

func (*ListEventsResponse) ProtoMessage()

func (*ListEventsResponse) ProtoReflect added in v1.9.0 

func (x *ListEventsResponse) ProtoReflect() protoreflect.Message

func (*ListEventsResponse) Reset added in v1.9.0 

func (x *ListEventsResponse) Reset()

func (*ListEventsResponse) String added in v1.9.0 

func (x *ListEventsResponse) String() string

type ListEventsResponse_Row added in v1.9.0 

type ListEventsResponse_Row struct {
	InputRecordCount     int64 `protobuf:"varint,1,opt,name=input_record_count,json=inputRecordCount,proto3" json:"input_record_count,omitempty"`
	OutputRecordCount    int64 `protobuf:"varint,2,opt,name=output_record_count,json=outputRecordCount,proto3" json:"output_record_count,omitempty"`
	DiscardedRecordCount int64 `protobuf:"varint,3,opt,name=discarded_record_count,json=discardedRecordCount,proto3" json:"discarded_record_count,omitempty"`
	// beginning of the time frame for this specific row.
	// not the same as ListEventsRequest.begin.
	Begin *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=begin,proto3" json:"begin,omitempty"`
	// end of the time frame for this specific row.
	// not the same as ListEventsRequest.end.
	End *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end,proto3" json:"end,omitempty"`
	// the element we are peeking at.
	ElementId string `protobuf:"bytes,6,opt,name=element_id,json=elementId,proto3" json:"element_id,omitempty"`
	// the entrypoints that were triggered during this time frame
	Entrypoints []string `protobuf:"bytes,7,rep,name=entrypoints,proto3" json:"entrypoints,omitempty"`
	// the parent paths that lead into this element that were triggered
	// during this time frame.
	ParentIds []string `protobuf:"bytes,8,rep,name=parent_ids,json=parentIds,proto3" json:"parent_ids,omitempty"`
	// the columns used for these records. in this time frame
	Columns []string `protobuf:"bytes,9,rep,name=columns,proto3" json:"columns,omitempty"`
	// how long the element sat in the queue waiting to start processing, in seconds.
	// a large number here, means upstream of this element took a really long time.
	// the longer the DAG, the more time will be spent waiting to process, because
	// processing has to happen in order.
	TotalQueueWaitSeconds int64 `` /* 130-byte string literal not displayed */
	// how long the element took (in seconds) to process all the data on this hour.
	// a long time here, means the element took a long time to execute its action
	// on the input records.
	TotalProcessingSeconds int64 `` /* 131-byte string literal not displayed */
	// the latest 5 server messages that were for this element for this time range.
	Msgs []string `protobuf:"bytes,12,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventsResponse_Row) Descriptor deprecated added in v1.9.0 

func (*ListEventsResponse_Row) Descriptor() ([]byte, []int)

Deprecated: Use ListEventsResponse_Row.ProtoReflect.Descriptor instead.

func (*ListEventsResponse_Row) GetBegin added in v1.9.0 

func (x *ListEventsResponse_Row) GetBegin() *timestamppb.Timestamp

func (*ListEventsResponse_Row) GetColumns added in v1.9.0 

func (x *ListEventsResponse_Row) GetColumns() []string

func (*ListEventsResponse_Row) GetDiscardedRecordCount added in v1.9.0 

func (x *ListEventsResponse_Row) GetDiscardedRecordCount() int64

func (*ListEventsResponse_Row) GetElementId added in v1.9.0 

func (x *ListEventsResponse_Row) GetElementId() string

func (*ListEventsResponse_Row) GetEnd added in v1.9.0 

func (x *ListEventsResponse_Row) GetEnd() *timestamppb.Timestamp

func (*ListEventsResponse_Row) GetEntrypoints added in v1.9.0 

func (x *ListEventsResponse_Row) GetEntrypoints() []string

func (*ListEventsResponse_Row) GetInputRecordCount added in v1.9.0 

func (x *ListEventsResponse_Row) GetInputRecordCount() int64

func (*ListEventsResponse_Row) GetMsgs added in v1.9.0 

func (x *ListEventsResponse_Row) GetMsgs() []string

func (*ListEventsResponse_Row) GetOutputRecordCount added in v1.9.0 

func (x *ListEventsResponse_Row) GetOutputRecordCount() int64

func (*ListEventsResponse_Row) GetParentIds added in v1.9.0 

func (x *ListEventsResponse_Row) GetParentIds() []string

func (*ListEventsResponse_Row) GetTotalProcessingSeconds added in v1.9.0 

func (x *ListEventsResponse_Row) GetTotalProcessingSeconds() int64

func (*ListEventsResponse_Row) GetTotalQueueWaitSeconds added in v1.9.0 

func (x *ListEventsResponse_Row) GetTotalQueueWaitSeconds() int64

func (*ListEventsResponse_Row) ProtoMessage added in v1.9.0 

func (*ListEventsResponse_Row) ProtoMessage()

func (*ListEventsResponse_Row) ProtoReflect added in v1.9.0 

func (x *ListEventsResponse_Row) ProtoReflect() protoreflect.Message

func (*ListEventsResponse_Row) Reset added in v1.9.0 

func (x *ListEventsResponse_Row) Reset()

func (*ListEventsResponse_Row) String added in v1.9.0 

func (x *ListEventsResponse_Row) String() string

type ListFileTemplatesRequest 

type ListFileTemplatesRequest struct {

	// if empty we will start at begining/end of list
	PrevId int64 `protobuf:"varint,1,opt,name=prev_id,json=prevId,proto3" json:"prev_id,omitempty"`
	// sort ascending instead of descending
	Asc bool `protobuf:"varint,2,opt,name=asc,proto3" json:"asc,omitempty"`
	// how many records to get
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFileTemplatesRequest) Descriptor deprecated 

func (*ListFileTemplatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListFileTemplatesRequest.ProtoReflect.Descriptor instead.

func (*ListFileTemplatesRequest) GetAsc 

func (x *ListFileTemplatesRequest) GetAsc() bool

func (*ListFileTemplatesRequest) GetPageSize 

func (x *ListFileTemplatesRequest) GetPageSize() int32

func (*ListFileTemplatesRequest) GetPrevId 

func (x *ListFileTemplatesRequest) GetPrevId() int64

func (*ListFileTemplatesRequest) ProtoMessage 

func (*ListFileTemplatesRequest) ProtoMessage()

func (*ListFileTemplatesRequest) ProtoReflect 

func (x *ListFileTemplatesRequest) ProtoReflect() protoreflect.Message

func (*ListFileTemplatesRequest) Reset 

func (x *ListFileTemplatesRequest) Reset()

func (*ListFileTemplatesRequest) String 

func (x *ListFileTemplatesRequest) String() string

type ListFileTemplatesResponse 

type ListFileTemplatesResponse struct {
	FileTemplates []*FileTemplate `protobuf:"bytes,1,rep,name=file_templates,json=fileTemplates,proto3" json:"file_templates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFileTemplatesResponse) Descriptor deprecated 

func (*ListFileTemplatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListFileTemplatesResponse.ProtoReflect.Descriptor instead.

func (*ListFileTemplatesResponse) GetFileTemplates 

func (x *ListFileTemplatesResponse) GetFileTemplates() []*FileTemplate

func (*ListFileTemplatesResponse) ProtoMessage 

func (*ListFileTemplatesResponse) ProtoMessage()

func (*ListFileTemplatesResponse) ProtoReflect 

func (x *ListFileTemplatesResponse) ProtoReflect() protoreflect.Message

func (*ListFileTemplatesResponse) Reset 

func (x *ListFileTemplatesResponse) Reset()

func (*ListFileTemplatesResponse) String 

func (x *ListFileTemplatesResponse) String() string

type Opts added in v1.7.76 

type Opts struct {

	// map from field name to date format
	// e.g: "dob": yyyy/mm/dd
	DateFormats map[string]string `` /* 168-byte string literal not displayed */
	// keys are old field names, values are new field names
	RenameFields map[string]string `` /* 171-byte string literal not displayed */
	ParseOpts    *ParseOpts        `protobuf:"bytes,3,opt,name=parse_opts,json=parseOpts,proto3" json:"parse_opts,omitempty"`
	Constraints  *Constraints      `protobuf:"bytes,4,opt,name=constraints,proto3" json:"constraints,omitempty"`
	// contains filtered or unexported fields
}

func (*Opts) Descriptor deprecated added in v1.7.76 

func (*Opts) Descriptor() ([]byte, []int)

Deprecated: Use Opts.ProtoReflect.Descriptor instead.

func (*Opts) GetConstraints added in v1.7.76 

func (x *Opts) GetConstraints() *Constraints

func (*Opts) GetDateFormats added in v1.7.76 

func (x *Opts) GetDateFormats() map[string]string

func (*Opts) GetParseOpts added in v1.7.76 

func (x *Opts) GetParseOpts() *ParseOpts

func (*Opts) GetRenameFields added in v1.7.76 

func (x *Opts) GetRenameFields() map[string]string

func (*Opts) ProtoMessage added in v1.7.76 

func (*Opts) ProtoMessage()

func (*Opts) ProtoReflect added in v1.7.76 

func (x *Opts) ProtoReflect() protoreflect.Message

func (*Opts) Reset added in v1.7.76 

func (x *Opts) Reset()

func (*Opts) String added in v1.7.76 

func (x *Opts) String() string

type OptsCsv 

type OptsCsv struct {
	HasHeader bool     `protobuf:"varint,1,opt,name=has_header,json=hasHeader,proto3" json:"has_header,omitempty"`
	SkipRows  int64    `protobuf:"varint,2,opt,name=skip_rows,json=skipRows,proto3" json:"skip_rows,omitempty"`
	Header    []string `protobuf:"bytes,3,rep,name=header,proto3" json:"header,omitempty"`
	Separator string   `protobuf:"bytes,4,opt,name=separator,proto3" json:"separator,omitempty"`
	// contains filtered or unexported fields
}

func (*OptsCsv) Descriptor deprecated 

func (*OptsCsv) Descriptor() ([]byte, []int)

Deprecated: Use OptsCsv.ProtoReflect.Descriptor instead.

func (*OptsCsv) GetHasHeader 

func (x *OptsCsv) GetHasHeader() bool

func (*OptsCsv) GetHeader 

func (x *OptsCsv) GetHeader() []string

func (*OptsCsv) GetSeparator 

func (x *OptsCsv) GetSeparator() string

func (*OptsCsv) GetSkipRows 

func (x *OptsCsv) GetSkipRows() int64

func (*OptsCsv) ProtoMessage 

func (*OptsCsv) ProtoMessage()

func (*OptsCsv) ProtoReflect 

func (x *OptsCsv) ProtoReflect() protoreflect.Message

func (*OptsCsv) Reset 

func (x *OptsCsv) Reset()

func (*OptsCsv) String 

func (x *OptsCsv) String() string

type OptsFixed 

type OptsFixed struct {

	// field opts keyed by field name
	Positions map[string]*OptsFixed_FieldOpts `` /* 145-byte string literal not displayed */
	HasHeader bool                            `protobuf:"varint,2,opt,name=has_header,json=hasHeader,proto3" json:"has_header,omitempty"`
	// contains filtered or unexported fields
}

func (*OptsFixed) Descriptor deprecated 

func (*OptsFixed) Descriptor() ([]byte, []int)

Deprecated: Use OptsFixed.ProtoReflect.Descriptor instead.

func (*OptsFixed) GetHasHeader added in v1.7.76 

func (x *OptsFixed) GetHasHeader() bool

func (*OptsFixed) GetPositions 

func (x *OptsFixed) GetPositions() map[string]*OptsFixed_FieldOpts

func (*OptsFixed) ProtoMessage 

func (*OptsFixed) ProtoMessage()

func (*OptsFixed) ProtoReflect 

func (x *OptsFixed) ProtoReflect() protoreflect.Message

func (*OptsFixed) Reset 

func (x *OptsFixed) Reset()

func (*OptsFixed) String 

func (x *OptsFixed) String() string

type OptsFixed_FieldOpts 

type OptsFixed_FieldOpts struct {

	// for fixed width files indicates the starting position of the data.
	// if it is -1, starting position is one character after the previous fields
	// starting position + length. if this is the first field and it is -1,
	// starting position is 0
	StartingPosition int32 `protobuf:"varint,13,opt,name=starting_position,json=startingPosition,proto3" json:"starting_position,omitempty"`
	// for fixed width files indicates how many characters to the right of
	// starting_position we will read. this field is required to be greater than
	// 0.
	FieldLength int32 `protobuf:"varint,14,opt,name=field_length,json=fieldLength,proto3" json:"field_length,omitempty"`
	// contains filtered or unexported fields
}

func (*OptsFixed_FieldOpts) Descriptor deprecated 

func (*OptsFixed_FieldOpts) Descriptor() ([]byte, []int)

Deprecated: Use OptsFixed_FieldOpts.ProtoReflect.Descriptor instead.

func (*OptsFixed_FieldOpts) GetFieldLength 

func (x *OptsFixed_FieldOpts) GetFieldLength() int32

func (*OptsFixed_FieldOpts) GetStartingPosition 

func (x *OptsFixed_FieldOpts) GetStartingPosition() int32

func (*OptsFixed_FieldOpts) ProtoMessage 

func (*OptsFixed_FieldOpts) ProtoMessage()

func (*OptsFixed_FieldOpts) ProtoReflect 

func (x *OptsFixed_FieldOpts) ProtoReflect() protoreflect.Message

func (*OptsFixed_FieldOpts) Reset 

func (x *OptsFixed_FieldOpts) Reset()

func (*OptsFixed_FieldOpts) String 

func (x *OptsFixed_FieldOpts) String() string

type OptsJson 

type OptsJson struct {
	RecordsRoot string `protobuf:"bytes,1,opt,name=records_root,json=recordsRoot,proto3" json:"records_root,omitempty"`
	// contains filtered or unexported fields
}

func (*OptsJson) Descriptor deprecated 

func (*OptsJson) Descriptor() ([]byte, []int)

Deprecated: Use OptsJson.ProtoReflect.Descriptor instead.

func (*OptsJson) GetRecordsRoot 

func (x *OptsJson) GetRecordsRoot() string

func (*OptsJson) ProtoMessage 

func (*OptsJson) ProtoMessage()

func (*OptsJson) ProtoReflect 

func (x *OptsJson) ProtoReflect() protoreflect.Message

func (*OptsJson) Reset 

func (x *OptsJson) Reset()

func (*OptsJson) String 

func (x *OptsJson) String() string

type OptsJsonL 

type OptsJsonL struct {
	// contains filtered or unexported fields
}

func (*OptsJsonL) Descriptor deprecated 

func (*OptsJsonL) Descriptor() ([]byte, []int)

Deprecated: Use OptsJsonL.ProtoReflect.Descriptor instead.

func (*OptsJsonL) ProtoMessage 

func (*OptsJsonL) ProtoMessage()

func (*OptsJsonL) ProtoReflect 

func (x *OptsJsonL) ProtoReflect() protoreflect.Message

func (*OptsJsonL) Reset 

func (x *OptsJsonL) Reset()

func (*OptsJsonL) String 

func (x *OptsJsonL) String() string

type OptsParquet 

type OptsParquet struct {
	// contains filtered or unexported fields
}

func (*OptsParquet) Descriptor deprecated 

func (*OptsParquet) Descriptor() ([]byte, []int)

Deprecated: Use OptsParquet.ProtoReflect.Descriptor instead.

func (*OptsParquet) ProtoMessage 

func (*OptsParquet) ProtoMessage()

func (*OptsParquet) ProtoReflect 

func (x *OptsParquet) ProtoReflect() protoreflect.Message

func (*OptsParquet) Reset 

func (x *OptsParquet) Reset()

func (*OptsParquet) String 

func (x *OptsParquet) String() string

type ParseFileRequest 

type ParseFileRequest struct {

	// Types that are valid to be assigned to Opt:
	//
	//	*ParseFileRequest_RawData
	//	*ParseFileRequest_ReparseFile
	//	*ParseFileRequest_ParseWithHints_
	Opt  isParseFileRequest_Opt `protobuf_oneof:"opt"`
	Name string                 `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseFileRequest) Descriptor deprecated 

func (*ParseFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use ParseFileRequest.ProtoReflect.Descriptor instead.

func (*ParseFileRequest) GetName 

func (x *ParseFileRequest) GetName() string

func (*ParseFileRequest) GetOpt 

func (x *ParseFileRequest) GetOpt() isParseFileRequest_Opt

func (*ParseFileRequest) GetParseWithHints added in v1.7.76 

func (x *ParseFileRequest) GetParseWithHints() *ParseFileRequest_ParseWithHints

func (*ParseFileRequest) GetRawData 

func (x *ParseFileRequest) GetRawData() []byte

func (*ParseFileRequest) GetReparseFile 

func (x *ParseFileRequest) GetReparseFile() *ParseFileRequest_ReParseFile

func (*ParseFileRequest) ProtoMessage 

func (*ParseFileRequest) ProtoMessage()

func (*ParseFileRequest) ProtoReflect 

func (x *ParseFileRequest) ProtoReflect() protoreflect.Message

func (*ParseFileRequest) Reset 

func (x *ParseFileRequest) Reset()

func (*ParseFileRequest) String 

func (x *ParseFileRequest) String() string

type ParseFileRequest_ParseWithHints added in v1.7.76 

type ParseFileRequest_ParseWithHints struct {

	// the raw file, no more than 2mb
	RawData []byte `protobuf:"bytes,7,opt,name=raw_data,json=rawData,proto3" json:"raw_data,omitempty"`
	Opts    *Opts  `protobuf:"bytes,8,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseFileRequest_ParseWithHints) Descriptor deprecated added in v1.7.76 

func (*ParseFileRequest_ParseWithHints) Descriptor() ([]byte, []int)

Deprecated: Use ParseFileRequest_ParseWithHints.ProtoReflect.Descriptor instead.

func (*ParseFileRequest_ParseWithHints) GetOpts added in v1.7.76 

func (x *ParseFileRequest_ParseWithHints) GetOpts() *Opts

func (*ParseFileRequest_ParseWithHints) GetRawData added in v1.7.76 

func (x *ParseFileRequest_ParseWithHints) GetRawData() []byte

func (*ParseFileRequest_ParseWithHints) ProtoMessage added in v1.7.76 

func (*ParseFileRequest_ParseWithHints) ProtoMessage()

func (*ParseFileRequest_ParseWithHints) ProtoReflect added in v1.7.76 

func (x *ParseFileRequest_ParseWithHints) ProtoReflect() protoreflect.Message

func (*ParseFileRequest_ParseWithHints) Reset added in v1.7.76 

func (x *ParseFileRequest_ParseWithHints) Reset()

func (*ParseFileRequest_ParseWithHints) String added in v1.7.76 

func (x *ParseFileRequest_ParseWithHints) String() string

type ParseFileRequest_ParseWithHints_ added in v1.7.76 

type ParseFileRequest_ParseWithHints_ struct {
	// parse with hints if file is not
	// a header immediately followed by data
	ParseWithHints *ParseFileRequest_ParseWithHints `protobuf:"bytes,6,opt,name=parse_with_hints,json=parseWithHints,proto3,oneof"`
}

type ParseFileRequest_RawData 

type ParseFileRequest_RawData struct {
	// the raw file, no more than 2mb
	// use raw_data if file is simple.
	// a header immediately followed by data
	RawData []byte `protobuf:"bytes,3,opt,name=raw_data,json=rawData,proto3,oneof"`
}

type ParseFileRequest_ReParseFile 

type ParseFileRequest_ReParseFile struct {
	FileTemplateId int64 `protobuf:"varint,1,opt,name=file_template_id,json=fileTemplateId,proto3" json:"file_template_id,omitempty"`
	// Deprecated: Marked as deprecated in api/v1alpha1/classifier/service.proto.
	Hints *ParseHints `protobuf:"bytes,2,opt,name=hints,proto3" json:"hints,omitempty"`
	Opts  *Opts       `protobuf:"bytes,3,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseFileRequest_ReParseFile) Descriptor deprecated 

func (*ParseFileRequest_ReParseFile) Descriptor() ([]byte, []int)

Deprecated: Use ParseFileRequest_ReParseFile.ProtoReflect.Descriptor instead.

func (*ParseFileRequest_ReParseFile) GetFileTemplateId 

func (x *ParseFileRequest_ReParseFile) GetFileTemplateId() int64

func (*ParseFileRequest_ReParseFile) GetHints deprecated 

func (x *ParseFileRequest_ReParseFile) GetHints() *ParseHints

Deprecated: Marked as deprecated in api/v1alpha1/classifier/service.proto.

func (*ParseFileRequest_ReParseFile) GetOpts added in v1.7.76 

func (x *ParseFileRequest_ReParseFile) GetOpts() *Opts

func (*ParseFileRequest_ReParseFile) ProtoMessage 

func (*ParseFileRequest_ReParseFile) ProtoMessage()

func (*ParseFileRequest_ReParseFile) ProtoReflect 

func (x *ParseFileRequest_ReParseFile) ProtoReflect() protoreflect.Message

func (*ParseFileRequest_ReParseFile) Reset 

func (x *ParseFileRequest_ReParseFile) Reset()

func (*ParseFileRequest_ReParseFile) String 

func (x *ParseFileRequest_ReParseFile) String() string

type ParseFileRequest_ReparseFile 

type ParseFileRequest_ReparseFile struct {
	// reparse the file that exists for this template with new hints
	ReparseFile *ParseFileRequest_ReParseFile `protobuf:"bytes,4,opt,name=reparse_file,json=reparseFile,proto3,oneof"`
}

type ParseFileResponse 

type ParseFileResponse struct {
	FileTemplate *FileTemplate `protobuf:"bytes,1,opt,name=file_template,json=fileTemplate,proto3" json:"file_template,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseFileResponse) Descriptor deprecated 

func (*ParseFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use ParseFileResponse.ProtoReflect.Descriptor instead.

func (*ParseFileResponse) GetFileTemplate 

func (x *ParseFileResponse) GetFileTemplate() *FileTemplate

func (*ParseFileResponse) ProtoMessage 

func (*ParseFileResponse) ProtoMessage()

func (*ParseFileResponse) ProtoReflect 

func (x *ParseFileResponse) ProtoReflect() protoreflect.Message

func (*ParseFileResponse) Reset 

func (x *ParseFileResponse) Reset()

func (*ParseFileResponse) String 

func (x *ParseFileResponse) String() string

type ParseHints 

type ParseHints struct {
	ParseOpts   *ParseOpts   `protobuf:"bytes,1,opt,name=parse_opts,json=parseOpts,proto3" json:"parse_opts,omitempty"`
	Constraints *Constraints `protobuf:"bytes,2,opt,name=constraints,proto3" json:"constraints,omitempty"`
	// contains filtered or unexported fields
}

func (*ParseHints) Descriptor deprecated 

func (*ParseHints) Descriptor() ([]byte, []int)

Deprecated: Use ParseHints.ProtoReflect.Descriptor instead.

func (*ParseHints) GetConstraints 

func (x *ParseHints) GetConstraints() *Constraints

func (*ParseHints) GetParseOpts 

func (x *ParseHints) GetParseOpts() *ParseOpts

func (*ParseHints) ProtoMessage 

func (*ParseHints) ProtoMessage()

func (*ParseHints) ProtoReflect 

func (x *ParseHints) ProtoReflect() protoreflect.Message

func (*ParseHints) Reset 

func (x *ParseHints) Reset()

func (*ParseHints) String 

func (x *ParseHints) String() string

type ParseOpts 

type ParseOpts struct {

	// Types that are valid to be assigned to Ftype:
	//
	//	*ParseOpts_Csv
	//	*ParseOpts_Json
	//	*ParseOpts_Jsonl
	//	*ParseOpts_Fixed
	//	*ParseOpts_Parquet
	Ftype isParseOpts_Ftype `protobuf_oneof:"ftype"`
	// contains filtered or unexported fields
}

details on how the data should be parsed with respect to the file type

func (*ParseOpts) Descriptor deprecated 

func (*ParseOpts) Descriptor() ([]byte, []int)

Deprecated: Use ParseOpts.ProtoReflect.Descriptor instead.

func (*ParseOpts) GetCsv 

func (x *ParseOpts) GetCsv() *OptsCsv

func (*ParseOpts) GetFixed 

func (x *ParseOpts) GetFixed() *OptsFixed

func (*ParseOpts) GetFtype 

func (x *ParseOpts) GetFtype() isParseOpts_Ftype

func (*ParseOpts) GetJson 

func (x *ParseOpts) GetJson() *OptsJson

func (*ParseOpts) GetJsonl 

func (x *ParseOpts) GetJsonl() *OptsJsonL

func (*ParseOpts) GetParquet 

func (x *ParseOpts) GetParquet() *OptsParquet

func (*ParseOpts) ProtoMessage 

func (*ParseOpts) ProtoMessage()

func (*ParseOpts) ProtoReflect 

func (x *ParseOpts) ProtoReflect() protoreflect.Message

func (*ParseOpts) Reset 

func (x *ParseOpts) Reset()

func (*ParseOpts) String 

func (x *ParseOpts) String() string

type ParseOpts_Csv 

type ParseOpts_Csv struct {
	Csv *OptsCsv `protobuf:"bytes,1,opt,name=csv,proto3,oneof"`
}

type ParseOpts_Fixed 

type ParseOpts_Fixed struct {
	Fixed *OptsFixed `protobuf:"bytes,4,opt,name=fixed,proto3,oneof"`
}

type ParseOpts_Json 

type ParseOpts_Json struct {
	Json *OptsJson `protobuf:"bytes,2,opt,name=json,proto3,oneof"`
}

type ParseOpts_Jsonl 

type ParseOpts_Jsonl struct {
	Jsonl *OptsJsonL `protobuf:"bytes,3,opt,name=jsonl,proto3,oneof"`
}

type ParseOpts_Parquet 

type ParseOpts_Parquet struct {
	Parquet *OptsParquet `protobuf:"bytes,5,opt,name=parquet,proto3,oneof"`
}

type PeekListRequest added in v1.9.0 

type PeekListRequest struct {

	// our range we are looking at. Should be fetched from the ListEventsResponse.
	// not setting begin/end results in us getting the last 12 hours.
	Begin *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// tag is optionally given when queueing a file or sending data. It has significance to the client
	// only. But we store it on all results for the operation so it can be searched.
	// If provided here, we only show results with this matching tag.
	ExternalTag string `protobuf:"bytes,3,opt,name=external_tag,json=externalTag,proto3" json:"external_tag,omitempty"`
	// if empty we will start at begining/end of list
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// sort ascending instead of descending
	Asc bool `protobuf:"varint,5,opt,name=asc,proto3" json:"asc,omitempty"`
	// how many records to get
	PageSize int32 `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// which element we are looking at events for in the dag
	ElementId string `protobuf:"bytes,7,opt,name=element_id,json=elementId,proto3" json:"element_id,omitempty"`
	// the columns and ordering we want the results to be in
	Columns []string `protobuf:"bytes,8,rep,name=columns,proto3" json:"columns,omitempty"`
	// optional. If specified we will only look at results that went through
	// the named entrypoint. Otherwise, we will look at all data that went through
	// the node
	EntrypointId string `protobuf:"bytes,9,opt,name=entrypoint_id,json=entrypointId,proto3" json:"entrypoint_id,omitempty"`
	// optional. If specified we only look at results that came from this element's
	// parent path. Otherwise we look at all data that went through the node.
	ParentId string `protobuf:"bytes,10,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// if true we look at the discarded records from this node.
	// defaults to false, where we look at the kept records.
	ViewDiscards bool `protobuf:"varint,11,opt,name=view_discards,json=viewDiscards,proto3" json:"view_discards,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekListRequest) Descriptor deprecated added in v1.9.0 

func (*PeekListRequest) Descriptor() ([]byte, []int)

Deprecated: Use PeekListRequest.ProtoReflect.Descriptor instead.

func (*PeekListRequest) GetAsc added in v1.9.0 

func (x *PeekListRequest) GetAsc() bool

func (*PeekListRequest) GetBegin added in v1.9.0 

func (x *PeekListRequest) GetBegin() *timestamppb.Timestamp

func (*PeekListRequest) GetColumns added in v1.9.0 

func (x *PeekListRequest) GetColumns() []string

func (*PeekListRequest) GetElementId added in v1.9.0 

func (x *PeekListRequest) GetElementId() string

func (*PeekListRequest) GetEnd added in v1.9.0 

func (x *PeekListRequest) GetEnd() *timestamppb.Timestamp

func (*PeekListRequest) GetEntrypointId added in v1.9.0 

func (x *PeekListRequest) GetEntrypointId() string

func (*PeekListRequest) GetExternalTag added in v1.9.0 

func (x *PeekListRequest) GetExternalTag() string

func (*PeekListRequest) GetPageSize added in v1.9.0 

func (x *PeekListRequest) GetPageSize() int32

func (*PeekListRequest) GetPageToken added in v1.9.0 

func (x *PeekListRequest) GetPageToken() string

func (*PeekListRequest) GetParentId added in v1.9.0 

func (x *PeekListRequest) GetParentId() string

func (*PeekListRequest) GetViewDiscards added in v1.9.0 

func (x *PeekListRequest) GetViewDiscards() bool

func (*PeekListRequest) ProtoMessage added in v1.9.0 

func (*PeekListRequest) ProtoMessage()

func (*PeekListRequest) ProtoReflect added in v1.9.0 

func (x *PeekListRequest) ProtoReflect() protoreflect.Message

func (*PeekListRequest) Reset added in v1.9.0 

func (x *PeekListRequest) Reset()

func (*PeekListRequest) String added in v1.9.0 

func (x *PeekListRequest) String() string

type PeekListResponse added in v1.9.0 

type PeekListResponse struct {

	// each item is a json record.
	JsonRecords []string `protobuf:"bytes,1,rep,name=json_records,json=jsonRecords,proto3" json:"json_records,omitempty"`
	// the result_id.oid.record_index of where we left off, so we can paginate this call. See task notes for structure.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekListResponse) Descriptor deprecated added in v1.9.0 

func (*PeekListResponse) Descriptor() ([]byte, []int)

Deprecated: Use PeekListResponse.ProtoReflect.Descriptor instead.

func (*PeekListResponse) GetJsonRecords added in v1.9.0 

func (x *PeekListResponse) GetJsonRecords() []string

func (*PeekListResponse) GetPageToken added in v1.9.0 

func (x *PeekListResponse) GetPageToken() string

func (*PeekListResponse) ProtoMessage added in v1.9.0 

func (*PeekListResponse) ProtoMessage()

func (*PeekListResponse) ProtoReflect added in v1.9.0 

func (x *PeekListResponse) ProtoReflect() protoreflect.Message

func (*PeekListResponse) Reset added in v1.9.0 

func (x *PeekListResponse) Reset()

func (*PeekListResponse) String added in v1.9.0 

func (x *PeekListResponse) String() string

type UnimplementedClassifierFileTemplatesServer 

type UnimplementedClassifierFileTemplatesServer struct{}

UnimplementedClassifierFileTemplatesServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedClassifierFileTemplatesServer) DeleteFileTemplate 

func (UnimplementedClassifierFileTemplatesServer) DeleteFileTemplate(context.Context, *DeleteFileTemplateRequest) (*DeleteFileTemplateResponse, error)

func (UnimplementedClassifierFileTemplatesServer) GetFileTemplate 

func (UnimplementedClassifierFileTemplatesServer) GetFileTemplate(context.Context, *GetFileTemplateRequest) (*GetFileTemplateResponse, error)

func (UnimplementedClassifierFileTemplatesServer) ListEvents added in v1.9.0 

func (UnimplementedClassifierFileTemplatesServer) ListEvents(context.Context, *ListEventsRequest) (*ListEventsResponse, error)

func (UnimplementedClassifierFileTemplatesServer) ListFileTemplates 

func (UnimplementedClassifierFileTemplatesServer) ListFileTemplates(context.Context, *ListFileTemplatesRequest) (*ListFileTemplatesResponse, error)

func (UnimplementedClassifierFileTemplatesServer) ParseFile 

func (UnimplementedClassifierFileTemplatesServer) ParseFile(context.Context, *ParseFileRequest) (*ParseFileResponse, error)

func (UnimplementedClassifierFileTemplatesServer) PeekList added in v1.9.0 

func (UnimplementedClassifierFileTemplatesServer) PeekList(context.Context, *PeekListRequest) (*PeekListResponse, error)

func (UnimplementedClassifierFileTemplatesServer) UpdateFileTemplate 

func (UnimplementedClassifierFileTemplatesServer) UpdateFileTemplate(context.Context, *UpdateFileTemplateRequest) (*UpdateFileTemplateResponse, error)

type UnsafeClassifierFileTemplatesServer 

type UnsafeClassifierFileTemplatesServer interface {
	// contains filtered or unexported methods
}

UnsafeClassifierFileTemplatesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClassifierFileTemplatesServer will result in compilation errors.

type UpdateFileTemplateRequest 

type UpdateFileTemplateRequest struct {
	FileTemplate *FileTemplate `protobuf:"bytes,1,opt,name=file_template,json=fileTemplate,proto3" json:"file_template,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFileTemplateRequest) Descriptor deprecated 

func (*UpdateFileTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateFileTemplateRequest.ProtoReflect.Descriptor instead.

func (*UpdateFileTemplateRequest) GetFileTemplate 

func (x *UpdateFileTemplateRequest) GetFileTemplate() *FileTemplate

func (*UpdateFileTemplateRequest) ProtoMessage 

func (*UpdateFileTemplateRequest) ProtoMessage()

func (*UpdateFileTemplateRequest) ProtoReflect 

func (x *UpdateFileTemplateRequest) ProtoReflect() protoreflect.Message

func (*UpdateFileTemplateRequest) Reset 

func (x *UpdateFileTemplateRequest) Reset()

func (*UpdateFileTemplateRequest) String 

func (x *UpdateFileTemplateRequest) String() string

type UpdateFileTemplateResponse 

type UpdateFileTemplateResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateFileTemplateResponse) Descriptor deprecated 

func (*UpdateFileTemplateResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateFileTemplateResponse.ProtoReflect.Descriptor instead.

func (*UpdateFileTemplateResponse) ProtoMessage 

func (*UpdateFileTemplateResponse) ProtoMessage()

func (*UpdateFileTemplateResponse) ProtoReflect 

func (x *UpdateFileTemplateResponse) ProtoReflect() protoreflect.Message

func (*UpdateFileTemplateResponse) Reset 

func (x *UpdateFileTemplateResponse) Reset()

func (*UpdateFileTemplateResponse) String 

func (x *UpdateFileTemplateResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.