processorv1

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2025 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_processor_v1_processor_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CommandRequest 

type CommandRequest struct {

	// Types that are assignable to Request:
	//
	//	*CommandRequest_Specify
	//	*CommandRequest_Configure
	//	*CommandRequest_Open
	//	*CommandRequest_Process
	//	*CommandRequest_Teardown
	Request isCommandRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*CommandRequest) Descriptor deprecated 

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

Deprecated: Use CommandRequest.ProtoReflect.Descriptor instead.

func (*CommandRequest) GetConfigure 

func (x *CommandRequest) GetConfigure() *Configure_Request

func (*CommandRequest) GetOpen 

func (x *CommandRequest) GetOpen() *Open_Request

func (*CommandRequest) GetProcess 

func (x *CommandRequest) GetProcess() *Process_Request

func (*CommandRequest) GetRequest 

func (m *CommandRequest) GetRequest() isCommandRequest_Request

func (*CommandRequest) GetSpecify 

func (x *CommandRequest) GetSpecify() *Specify_Request

func (*CommandRequest) GetTeardown 

func (x *CommandRequest) GetTeardown() *Teardown_Request

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) ProtoReflect 

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

func (*CommandRequest) Reset 

func (x *CommandRequest) Reset()

func (*CommandRequest) String 

func (x *CommandRequest) String() string

type CommandRequest_Configure 

type CommandRequest_Configure struct {
	Configure *Configure_Request `protobuf:"bytes,2,opt,name=configure,proto3,oneof"`
}

type CommandRequest_Open 

type CommandRequest_Open struct {
	Open *Open_Request `protobuf:"bytes,3,opt,name=open,proto3,oneof"`
}

type CommandRequest_Process 

type CommandRequest_Process struct {
	Process *Process_Request `protobuf:"bytes,4,opt,name=process,proto3,oneof"`
}

type CommandRequest_Specify 

type CommandRequest_Specify struct {
	Specify *Specify_Request `protobuf:"bytes,1,opt,name=specify,proto3,oneof"`
}

type CommandRequest_Teardown 

type CommandRequest_Teardown struct {
	Teardown *Teardown_Request `protobuf:"bytes,5,opt,name=teardown,proto3,oneof"`
}

type CommandResponse 

type CommandResponse struct {

	// Types that are assignable to Response:
	//
	//	*CommandResponse_Error
	//	*CommandResponse_Specify
	//	*CommandResponse_Configure
	//	*CommandResponse_Open
	//	*CommandResponse_Process
	//	*CommandResponse_Teardown
	Response isCommandResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*CommandResponse) Descriptor deprecated 

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

Deprecated: Use CommandResponse.ProtoReflect.Descriptor instead.

func (*CommandResponse) GetConfigure 

func (x *CommandResponse) GetConfigure() *Configure_Response

func (*CommandResponse) GetError 

func (x *CommandResponse) GetError() *Error

func (*CommandResponse) GetOpen 

func (x *CommandResponse) GetOpen() *Open_Response

func (*CommandResponse) GetProcess 

func (x *CommandResponse) GetProcess() *Process_Response

func (*CommandResponse) GetResponse 

func (m *CommandResponse) GetResponse() isCommandResponse_Response

func (*CommandResponse) GetSpecify 

func (x *CommandResponse) GetSpecify() *Specify_Response

func (*CommandResponse) GetTeardown 

func (x *CommandResponse) GetTeardown() *Teardown_Response

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) ProtoReflect 

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

func (*CommandResponse) Reset 

func (x *CommandResponse) Reset()

func (*CommandResponse) String 

func (x *CommandResponse) String() string

type CommandResponse_Configure 

type CommandResponse_Configure struct {
	Configure *Configure_Response `protobuf:"bytes,3,opt,name=configure,proto3,oneof"`
}

type CommandResponse_Error 

type CommandResponse_Error struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type CommandResponse_Open 

type CommandResponse_Open struct {
	Open *Open_Response `protobuf:"bytes,4,opt,name=open,proto3,oneof"`
}

type CommandResponse_Process 

type CommandResponse_Process struct {
	Process *Process_Response `protobuf:"bytes,5,opt,name=process,proto3,oneof"`
}

type CommandResponse_Specify 

type CommandResponse_Specify struct {
	Specify *Specify_Response `protobuf:"bytes,2,opt,name=specify,proto3,oneof"`
}

type CommandResponse_Teardown 

type CommandResponse_Teardown struct {
	Teardown *Teardown_Response `protobuf:"bytes,6,opt,name=teardown,proto3,oneof"`
}

type Configure 

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

func (*Configure) Descriptor deprecated 

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

Deprecated: Use Configure.ProtoReflect.Descriptor instead.

func (*Configure) ProtoMessage 

func (*Configure) ProtoMessage()

func (*Configure) ProtoReflect 

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

func (*Configure) Reset 

func (x *Configure) Reset()

func (*Configure) String 

func (x *Configure) String() string

type Configure_Request 

type Configure_Request struct {
	Parameters map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Configure_Request) Descriptor deprecated 

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

Deprecated: Use Configure_Request.ProtoReflect.Descriptor instead.

func (*Configure_Request) GetParameters 

func (x *Configure_Request) GetParameters() map[string]string

func (*Configure_Request) ProtoMessage 

func (*Configure_Request) ProtoMessage()

func (*Configure_Request) ProtoReflect 

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

func (*Configure_Request) Reset 

func (x *Configure_Request) Reset()

func (*Configure_Request) String 

func (x *Configure_Request) String() string

type Configure_Response 

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

func (*Configure_Response) Descriptor deprecated 

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

Deprecated: Use Configure_Response.ProtoReflect.Descriptor instead.

func (*Configure_Response) ProtoMessage 

func (*Configure_Response) ProtoMessage()

func (*Configure_Response) ProtoReflect 

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

func (*Configure_Response) Reset 

func (x *Configure_Response) Reset()

func (*Configure_Response) String 

func (x *Configure_Response) String() string

type Error 

type Error struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Open 

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

func (*Open) Descriptor deprecated 

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

Deprecated: Use Open.ProtoReflect.Descriptor instead.

func (*Open) ProtoMessage 

func (*Open) ProtoMessage()

func (*Open) ProtoReflect 

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

func (*Open) Reset 

func (x *Open) Reset()

func (*Open) String 

func (x *Open) String() string

type Open_Request 

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

func (*Open_Request) Descriptor deprecated 

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

Deprecated: Use Open_Request.ProtoReflect.Descriptor instead.

func (*Open_Request) ProtoMessage 

func (*Open_Request) ProtoMessage()

func (*Open_Request) ProtoReflect 

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

func (*Open_Request) Reset 

func (x *Open_Request) Reset()

func (*Open_Request) String 

func (x *Open_Request) String() string

type Open_Response 

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

func (*Open_Response) Descriptor deprecated 

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

Deprecated: Use Open_Response.ProtoReflect.Descriptor instead.

func (*Open_Response) ProtoMessage 

func (*Open_Response) ProtoMessage()

func (*Open_Response) ProtoReflect 

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

func (*Open_Response) Reset 

func (x *Open_Response) Reset()

func (*Open_Response) String 

func (x *Open_Response) String() string

type Process 

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

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type Process_ErrorRecord 

type Process_ErrorRecord struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Process_ErrorRecord) Descriptor deprecated 

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

Deprecated: Use Process_ErrorRecord.ProtoReflect.Descriptor instead.

func (*Process_ErrorRecord) GetError 

func (x *Process_ErrorRecord) GetError() *Error

func (*Process_ErrorRecord) ProtoMessage 

func (*Process_ErrorRecord) ProtoMessage()

func (*Process_ErrorRecord) ProtoReflect 

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

func (*Process_ErrorRecord) Reset 

func (x *Process_ErrorRecord) Reset()

func (*Process_ErrorRecord) String 

func (x *Process_ErrorRecord) String() string

type Process_FilterRecord 

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

func (*Process_FilterRecord) Descriptor deprecated 

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

Deprecated: Use Process_FilterRecord.ProtoReflect.Descriptor instead.

func (*Process_FilterRecord) ProtoMessage 

func (*Process_FilterRecord) ProtoMessage()

func (*Process_FilterRecord) ProtoReflect 

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

func (*Process_FilterRecord) Reset 

func (x *Process_FilterRecord) Reset()

func (*Process_FilterRecord) String 

func (x *Process_FilterRecord) String() string

type Process_ProcessedRecord 

type Process_ProcessedRecord struct {

	// Types that are assignable to Record:
	//
	//	*Process_ProcessedRecord_SingleRecord
	//	*Process_ProcessedRecord_FilterRecord
	//	*Process_ProcessedRecord_ErrorRecord
	Record isProcess_ProcessedRecord_Record `protobuf_oneof:"record"`
	// contains filtered or unexported fields
}

func (*Process_ProcessedRecord) Descriptor deprecated 

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

Deprecated: Use Process_ProcessedRecord.ProtoReflect.Descriptor instead.

func (*Process_ProcessedRecord) GetErrorRecord 

func (x *Process_ProcessedRecord) GetErrorRecord() *Process_ErrorRecord

func (*Process_ProcessedRecord) GetFilterRecord 

func (x *Process_ProcessedRecord) GetFilterRecord() *Process_FilterRecord

func (*Process_ProcessedRecord) GetRecord 

func (m *Process_ProcessedRecord) GetRecord() isProcess_ProcessedRecord_Record

func (*Process_ProcessedRecord) GetSingleRecord 

func (x *Process_ProcessedRecord) GetSingleRecord() *v11.Record

func (*Process_ProcessedRecord) ProtoMessage 

func (*Process_ProcessedRecord) ProtoMessage()

func (*Process_ProcessedRecord) ProtoReflect 

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

func (*Process_ProcessedRecord) Reset 

func (x *Process_ProcessedRecord) Reset()

func (*Process_ProcessedRecord) String 

func (x *Process_ProcessedRecord) String() string

type Process_ProcessedRecord_ErrorRecord 

type Process_ProcessedRecord_ErrorRecord struct {
	ErrorRecord *Process_ErrorRecord `protobuf:"bytes,3,opt,name=error_record,json=errorRecord,proto3,oneof"`
}

type Process_ProcessedRecord_FilterRecord 

type Process_ProcessedRecord_FilterRecord struct {
	FilterRecord *Process_FilterRecord `protobuf:"bytes,2,opt,name=filter_record,json=filterRecord,proto3,oneof"`
}

type Process_ProcessedRecord_SingleRecord 

type Process_ProcessedRecord_SingleRecord struct {
	SingleRecord *v11.Record `protobuf:"bytes,1,opt,name=single_record,json=singleRecord,proto3,oneof"`
}

type Process_Request 

type Process_Request struct {
	Records []*v11.Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*Process_Request) Descriptor deprecated 

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

Deprecated: Use Process_Request.ProtoReflect.Descriptor instead.

func (*Process_Request) GetRecords 

func (x *Process_Request) GetRecords() []*v11.Record

func (*Process_Request) ProtoMessage 

func (*Process_Request) ProtoMessage()

func (*Process_Request) ProtoReflect 

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

func (*Process_Request) Reset 

func (x *Process_Request) Reset()

func (*Process_Request) String 

func (x *Process_Request) String() string

type Process_Response 

type Process_Response struct {
	Records []*Process_ProcessedRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*Process_Response) Descriptor deprecated 

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

Deprecated: Use Process_Response.ProtoReflect.Descriptor instead.

func (*Process_Response) GetRecords 

func (x *Process_Response) GetRecords() []*Process_ProcessedRecord

func (*Process_Response) ProtoMessage 

func (*Process_Response) ProtoMessage()

func (*Process_Response) ProtoReflect 

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

func (*Process_Response) Reset 

func (x *Process_Response) Reset()

func (*Process_Response) String 

func (x *Process_Response) String() string

type Specify 

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

func (*Specify) Descriptor deprecated 

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

Deprecated: Use Specify.ProtoReflect.Descriptor instead.

func (*Specify) ProtoMessage 

func (*Specify) ProtoMessage()

func (*Specify) ProtoReflect 

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

func (*Specify) Reset 

func (x *Specify) Reset()

func (*Specify) String 

func (x *Specify) String() string

type Specify_Request 

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

func (*Specify_Request) Descriptor deprecated 

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

Deprecated: Use Specify_Request.ProtoReflect.Descriptor instead.

func (*Specify_Request) ProtoMessage 

func (*Specify_Request) ProtoMessage()

func (*Specify_Request) ProtoReflect 

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

func (*Specify_Request) Reset 

func (x *Specify_Request) Reset()

func (*Specify_Request) String 

func (x *Specify_Request) String() string

type Specify_Response 

type Specify_Response struct {

	// Name is the name of the plugin.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Summary is a brief description of the plugin and what it does,
	// ideally not longer than one sentence.
	Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	// Description is a longer form field, appropriate for README-like
	// text that the author can provide for documentation about the
	// usage of the plugin.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Version string. Should follow semantic versioning and use the "v"
	// prefix (e.g. v1.23.4).
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// Author declares the entity that created or maintains this plugin.
	Author string `protobuf:"bytes,5,opt,name=author,proto3" json:"author,omitempty"`
	// A map that describes parameters available for configuring the
	// processor plugin.
	Parameters map[string]*v1.Parameter `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Specify_Response) Descriptor deprecated 

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

Deprecated: Use Specify_Response.ProtoReflect.Descriptor instead.

func (*Specify_Response) GetAuthor 

func (x *Specify_Response) GetAuthor() string

func (*Specify_Response) GetDescription 

func (x *Specify_Response) GetDescription() string

func (*Specify_Response) GetName 

func (x *Specify_Response) GetName() string

func (*Specify_Response) GetParameters 

func (x *Specify_Response) GetParameters() map[string]*v1.Parameter

func (*Specify_Response) GetSummary 

func (x *Specify_Response) GetSummary() string

func (*Specify_Response) GetVersion 

func (x *Specify_Response) GetVersion() string

func (*Specify_Response) ProtoMessage 

func (*Specify_Response) ProtoMessage()

func (*Specify_Response) ProtoReflect 

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

func (*Specify_Response) Reset 

func (x *Specify_Response) Reset()

func (*Specify_Response) String 

func (x *Specify_Response) String() string

type Teardown 

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

func (*Teardown) Descriptor deprecated 

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

Deprecated: Use Teardown.ProtoReflect.Descriptor instead.

func (*Teardown) ProtoMessage 

func (*Teardown) ProtoMessage()

func (*Teardown) ProtoReflect 

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

func (*Teardown) Reset 

func (x *Teardown) Reset()

func (*Teardown) String 

func (x *Teardown) String() string

type Teardown_Request 

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

func (*Teardown_Request) Descriptor deprecated 

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

Deprecated: Use Teardown_Request.ProtoReflect.Descriptor instead.

func (*Teardown_Request) ProtoMessage 

func (*Teardown_Request) ProtoMessage()

func (*Teardown_Request) ProtoReflect 

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

func (*Teardown_Request) Reset 

func (x *Teardown_Request) Reset()

func (*Teardown_Request) String 

func (x *Teardown_Request) String() string

type Teardown_Response 

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

func (*Teardown_Response) Descriptor deprecated 

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

Deprecated: Use Teardown_Response.ProtoReflect.Descriptor instead.

func (*Teardown_Response) ProtoMessage 

func (*Teardown_Response) ProtoMessage()

func (*Teardown_Response) ProtoReflect 

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

func (*Teardown_Response) Reset 

func (x *Teardown_Response) Reset()

func (*Teardown_Response) String 

func (x *Teardown_Response) String() string

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.