pipeline

package
v0.0.0-...-61a8870 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2022 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PipelineActionPipe = "pipe"
)

Variables

View Source 
var File_grpc_protos_pipeline_pipeline_proto protoreflect.FileDescriptor
View Source 
var PipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pipeline.PipelineService",
	HandlerType: (*PipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PipelineAction",
			Handler:    _PipelineService_PipelineAction_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "grpc/protos/pipeline/pipeline.proto",
}

PipelineService_ServiceDesc is the grpc.ServiceDesc for PipelineService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPipelineServiceServer 

func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)

Types

type AggregatorConfig 

type AggregatorConfig struct {
	Uuid string                `protobuf:"bytes,1,opt,name=Uuid,json=uuid,proto3" json:"Uuid,omitempty"`
	Name string                `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"`
	Args map[string]*anypb.Any `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AggregatorConfig) Descriptor deprecated 

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

Deprecated: Use AggregatorConfig.ProtoReflect.Descriptor instead.

func (*AggregatorConfig) GetArgs 

func (x *AggregatorConfig) GetArgs() map[string]*anypb.Any

func (*AggregatorConfig) GetName 

func (x *AggregatorConfig) GetName() string

func (*AggregatorConfig) GetUuid 

func (x *AggregatorConfig) GetUuid() string

func (*AggregatorConfig) ProtoMessage 

func (*AggregatorConfig) ProtoMessage()

func (*AggregatorConfig) ProtoReflect 

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

func (*AggregatorConfig) Reset 

func (x *AggregatorConfig) Reset()

func (*AggregatorConfig) String 

func (x *AggregatorConfig) String() string

type Config 

type Config struct {
	Preference  *Preference         `protobuf:"bytes,1,opt,name=Preference,json=preference,proto3" json:"Preference,omitempty"`
	Inputs      []*InputConfig      `protobuf:"bytes,2,rep,name=Inputs,json=inputs,proto3" json:"Inputs,omitempty"`
	Processors  []*ProcessorConfig  `protobuf:"bytes,3,rep,name=Processors,json=processors,proto3" json:"Processors,omitempty"`
	Aggregators []*AggregatorConfig `protobuf:"bytes,4,rep,name=Aggregators,json=aggregators,proto3" json:"Aggregators,omitempty"`
	Outputs     []*OutputConfig     `protobuf:"bytes,5,rep,name=Outputs,json=outputs,proto3" json:"Outputs,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAggregators 

func (x *Config) GetAggregators() []*AggregatorConfig

func (*Config) GetInputs 

func (x *Config) GetInputs() []*InputConfig

func (*Config) GetOutputs 

func (x *Config) GetOutputs() []*OutputConfig

func (*Config) GetPreference 

func (x *Config) GetPreference() *Preference

func (*Config) GetProcessors 

func (x *Config) GetProcessors() []*ProcessorConfig

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type InputConfig 

type InputConfig struct {
	Uuid string                `protobuf:"bytes,1,opt,name=Uuid,json=uuid,proto3" json:"Uuid,omitempty"`
	Name string                `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"`
	Cron string                `protobuf:"bytes,3,opt,name=Cron,json=cron,proto3" json:"Cron,omitempty"`
	Args map[string]*anypb.Any `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InputConfig) Descriptor deprecated 

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

Deprecated: Use InputConfig.ProtoReflect.Descriptor instead.

func (*InputConfig) GetArgs 

func (x *InputConfig) GetArgs() map[string]*anypb.Any

func (*InputConfig) GetCron 

func (x *InputConfig) GetCron() string

func (*InputConfig) GetName 

func (x *InputConfig) GetName() string

func (*InputConfig) GetUuid 

func (x *InputConfig) GetUuid() string

func (*InputConfig) ProtoMessage 

func (*InputConfig) ProtoMessage()

func (*InputConfig) ProtoReflect 

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

func (*InputConfig) Reset 

func (x *InputConfig) Reset()

func (*InputConfig) String 

func (x *InputConfig) String() string

type OutputConfig 

type OutputConfig struct {
	Uuid        string                `protobuf:"bytes,1,opt,name=Uuid,json=uuid,proto3" json:"Uuid,omitempty"`
	Name        string                `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"`
	Interval    int32                 `protobuf:"varint,3,opt,name=Interval,json=interval,proto3" json:"Interval,omitempty"`
	BufferLimit int32                 `protobuf:"varint,4,opt,name=BufferLimit,json=buffer_limit,proto3" json:"BufferLimit,omitempty"`
	BufferBatch int32                 `protobuf:"varint,5,opt,name=BufferBatch,json=buffer_batch,proto3" json:"BufferBatch,omitempty"`
	Args        map[string]*anypb.Any `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OutputConfig) Descriptor deprecated 

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

Deprecated: Use OutputConfig.ProtoReflect.Descriptor instead.

func (*OutputConfig) GetArgs 

func (x *OutputConfig) GetArgs() map[string]*anypb.Any

func (*OutputConfig) GetBufferBatch 

func (x *OutputConfig) GetBufferBatch() int32

func (*OutputConfig) GetBufferLimit 

func (x *OutputConfig) GetBufferLimit() int32

func (*OutputConfig) GetInterval 

func (x *OutputConfig) GetInterval() int32

func (*OutputConfig) GetName 

func (x *OutputConfig) GetName() string

func (*OutputConfig) GetUuid 

func (x *OutputConfig) GetUuid() string

func (*OutputConfig) ProtoMessage 

func (*OutputConfig) ProtoMessage()

func (*OutputConfig) ProtoReflect 

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

func (*OutputConfig) Reset 

func (x *OutputConfig) Reset()

func (*OutputConfig) String 

func (x *OutputConfig) String() string

type PipelineActionModel 

type PipelineActionModel struct {
	Action string  `protobuf:"bytes,1,opt,name=Action,json=action,proto3" json:"Action,omitempty"`
	Config *Config `protobuf:"bytes,2,opt,name=Config,json=config,proto3" json:"Config,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineActionModel) Descriptor deprecated 

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

Deprecated: Use PipelineActionModel.ProtoReflect.Descriptor instead.

func (*PipelineActionModel) GetAction 

func (x *PipelineActionModel) GetAction() string

func (*PipelineActionModel) GetConfig 

func (x *PipelineActionModel) GetConfig() *Config

func (*PipelineActionModel) ProtoMessage 

func (*PipelineActionModel) ProtoMessage()

func (*PipelineActionModel) ProtoReflect 

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

func (*PipelineActionModel) Reset 

func (x *PipelineActionModel) Reset()

func (*PipelineActionModel) String 

func (x *PipelineActionModel) String() string

type PipelineHandler 

type PipelineHandler struct{}

func (*PipelineHandler) PipelineAction 

func (h *PipelineHandler) PipelineAction(ctx context.Context, in *PipelineActionModel) (*emptypb.Empty, error)

PipelineAction -

type PipelineServiceClient 

type PipelineServiceClient interface {
	PipelineAction(ctx context.Context, in *PipelineActionModel, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

PipelineServiceClient is the client API for PipelineService 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 NewPipelineServiceClient 

func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient

type PipelineServiceServer 

type PipelineServiceServer interface {
	PipelineAction(context.Context, *PipelineActionModel) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

PipelineServiceServer is the server API for PipelineService service. All implementations must embed UnimplementedPipelineServiceServer for forward compatibility

type Preference 

type Preference struct {
	Debug bool `protobuf:"varint,1,opt,name=Debug,json=debug,proto3" json:"Debug,omitempty"`
	// contains filtered or unexported fields
}

func (*Preference) Descriptor deprecated 

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

Deprecated: Use Preference.ProtoReflect.Descriptor instead.

func (*Preference) GetDebug 

func (x *Preference) GetDebug() bool

func (*Preference) ProtoMessage 

func (*Preference) ProtoMessage()

func (*Preference) ProtoReflect 

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

func (*Preference) Reset 

func (x *Preference) Reset()

func (*Preference) String 

func (x *Preference) String() string

type ProcessorConfig 

type ProcessorConfig struct {
	Uuid  string                `protobuf:"bytes,1,opt,name=Uuid,json=uuid,proto3" json:"Uuid,omitempty"`
	Name  string                `protobuf:"bytes,2,opt,name=Name,json=name,proto3" json:"Name,omitempty"`
	Order int32                 `protobuf:"varint,3,opt,name=Order,json=order,proto3" json:"Order,omitempty"`
	Args  map[string]*anypb.Any `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessorConfig) Descriptor deprecated 

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

Deprecated: Use ProcessorConfig.ProtoReflect.Descriptor instead.

func (*ProcessorConfig) GetArgs 

func (x *ProcessorConfig) GetArgs() map[string]*anypb.Any

func (*ProcessorConfig) GetName 

func (x *ProcessorConfig) GetName() string

func (*ProcessorConfig) GetOrder 

func (x *ProcessorConfig) GetOrder() int32

func (*ProcessorConfig) GetUuid 

func (x *ProcessorConfig) GetUuid() string

func (*ProcessorConfig) ProtoMessage 

func (*ProcessorConfig) ProtoMessage()

func (*ProcessorConfig) ProtoReflect 

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

func (*ProcessorConfig) Reset 

func (x *ProcessorConfig) Reset()

func (*ProcessorConfig) String 

func (x *ProcessorConfig) String() string

type UnimplementedPipelineServiceServer 

type UnimplementedPipelineServiceServer struct {
}

UnimplementedPipelineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineServiceServer) PipelineAction 

func (UnimplementedPipelineServiceServer) PipelineAction(context.Context, *PipelineActionModel) (*emptypb.Empty, error)

type UnsafePipelineServiceServer 

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

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

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.