proto

package
v0.2.0-nightly.20220215 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Destination_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "conduit.plugins.Destination",
	HandlerType: (*DestinationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Open",
			Handler:    _Destination_Open_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _Destination_Teardown_Handler,
		},
		{
			MethodName: "Validate",
			Handler:    _Destination_Validate_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _Destination_Write_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Destination_ServiceDesc is the grpc.ServiceDesc for Destination 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_plugins_proto protoreflect.FileDescriptor
View Source 
var Source_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "conduit.plugins.Source",
	HandlerType: (*SourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Open",
			Handler:    _Source_Open_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _Source_Teardown_Handler,
		},
		{
			MethodName: "Validate",
			Handler:    _Source_Validate_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Source_Read_Handler,
		},
		{
			MethodName: "Ack",
			Handler:    _Source_Ack_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Source_ServiceDesc is the grpc.ServiceDesc for Source 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 Specifications_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "conduit.plugins.Specifications",
	HandlerType: (*SpecificationsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Specify",
			Handler:    _Specifications_Specify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

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

Functions

func RegisterDestinationServer 

func RegisterDestinationServer(s grpc.ServiceRegistrar, srv DestinationServer)

func RegisterSourceServer 

func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)

func RegisterSpecificationsServer 

func RegisterSpecificationsServer(s grpc.ServiceRegistrar, srv SpecificationsServer)

Types

type Config 

type Config struct {
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetValues 

func (x *Config) GetValues() map[string]string

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 DestinationClient 

type DestinationClient interface {
	Open(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Empty, error)
	Teardown(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Validate(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Empty, error)
	Write(ctx context.Context, in *Record, opts ...grpc.CallOption) (*Position, error)
}

DestinationClient is the client API for Destination 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 NewDestinationClient 

func NewDestinationClient(cc grpc.ClientConnInterface) DestinationClient

type DestinationServer 

type DestinationServer interface {
	Open(context.Context, *Config) (*Empty, error)
	Teardown(context.Context, *Empty) (*Empty, error)
	Validate(context.Context, *Config) (*Empty, error)
	Write(context.Context, *Record) (*Position, error)
	// contains filtered or unexported methods
}

DestinationServer is the server API for Destination service. All implementations must embed UnimplementedDestinationServer for forward compatibility

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Metadata 

type Metadata struct {
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetValues 

func (x *Metadata) GetValues() map[string]string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Parameter 

type Parameter struct {
	Default     string `protobuf:"bytes,1,opt,name=default,proto3" json:"default,omitempty"`
	Required    bool   `protobuf:"varint,2,opt,name=required,proto3" json:"required,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Parameter) Descriptor deprecated 

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

Deprecated: Use Parameter.ProtoReflect.Descriptor instead.

func (*Parameter) GetDefault 

func (x *Parameter) GetDefault() string

func (*Parameter) GetDescription 

func (x *Parameter) GetDescription() string

func (*Parameter) GetRequired 

func (x *Parameter) GetRequired() bool

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) ProtoReflect 

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

func (*Parameter) Reset 

func (x *Parameter) Reset()

func (*Parameter) String 

func (x *Parameter) String() string

type Position 

type Position struct {
	Position []byte `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*Position) Descriptor deprecated 

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

Deprecated: Use Position.ProtoReflect.Descriptor instead.

func (*Position) GetPosition 

func (x *Position) GetPosition() []byte

func (*Position) ProtoMessage 

func (*Position) ProtoMessage()

func (*Position) ProtoReflect 

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

func (*Position) Reset 

func (x *Position) Reset()

func (*Position) String 

func (x *Position) String() string

type RawData 

type RawData struct {
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// Types that are assignable to Schema:
	//	*RawData_ProtobufSchema_
	//	*RawData_AvroSchema_
	//	*RawData_JsonSchema
	Schema isRawData_Schema `protobuf_oneof:"schema"`
	// contains filtered or unexported fields
}

func (*RawData) Descriptor deprecated 

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

Deprecated: Use RawData.ProtoReflect.Descriptor instead.

func (*RawData) GetAvroSchema 

func (x *RawData) GetAvroSchema() *RawData_AvroSchema

func (*RawData) GetJsonSchema 

func (x *RawData) GetJsonSchema() *RawData_JSONSchema

func (*RawData) GetProtobufSchema 

func (x *RawData) GetProtobufSchema() *RawData_ProtobufSchema

func (*RawData) GetRaw 

func (x *RawData) GetRaw() []byte

func (*RawData) GetSchema 

func (m *RawData) GetSchema() isRawData_Schema

func (*RawData) ProtoMessage 

func (*RawData) ProtoMessage()

func (*RawData) ProtoReflect 

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

func (*RawData) Reset 

func (x *RawData) Reset()

func (*RawData) String 

func (x *RawData) String() string

type RawData_AvroSchema 

type RawData_AvroSchema struct {
	Version int32            `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Schema  *structpb.Struct `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*RawData_AvroSchema) Descriptor deprecated 

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

Deprecated: Use RawData_AvroSchema.ProtoReflect.Descriptor instead.

func (*RawData_AvroSchema) GetSchema 

func (x *RawData_AvroSchema) GetSchema() *structpb.Struct

func (*RawData_AvroSchema) GetVersion 

func (x *RawData_AvroSchema) GetVersion() int32

func (*RawData_AvroSchema) ProtoMessage 

func (*RawData_AvroSchema) ProtoMessage()

func (*RawData_AvroSchema) ProtoReflect 

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

func (*RawData_AvroSchema) Reset 

func (x *RawData_AvroSchema) Reset()

func (*RawData_AvroSchema) String 

func (x *RawData_AvroSchema) String() string

type RawData_AvroSchema_ 

type RawData_AvroSchema_ struct {
	AvroSchema *RawData_AvroSchema `protobuf:"bytes,3,opt,name=avroSchema,proto3,oneof"`
}

type RawData_JSONSchema 

type RawData_JSONSchema struct {
	Version int32            `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Schema  *structpb.Struct `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*RawData_JSONSchema) Descriptor deprecated 

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

Deprecated: Use RawData_JSONSchema.ProtoReflect.Descriptor instead.

func (*RawData_JSONSchema) GetSchema 

func (x *RawData_JSONSchema) GetSchema() *structpb.Struct

func (*RawData_JSONSchema) GetVersion 

func (x *RawData_JSONSchema) GetVersion() int32

func (*RawData_JSONSchema) ProtoMessage 

func (*RawData_JSONSchema) ProtoMessage()

func (*RawData_JSONSchema) ProtoReflect 

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

func (*RawData_JSONSchema) Reset 

func (x *RawData_JSONSchema) Reset()

func (*RawData_JSONSchema) String 

func (x *RawData_JSONSchema) String() string

type RawData_JsonSchema 

type RawData_JsonSchema struct {
	JsonSchema *RawData_JSONSchema `protobuf:"bytes,4,opt,name=jsonSchema,proto3,oneof"`
}

type RawData_ProtobufSchema 

type RawData_ProtobufSchema struct {
	Version           int32                           `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	FileDescriptorSet *descriptorpb.FileDescriptorSet `protobuf:"bytes,2,opt,name=fileDescriptorSet,proto3" json:"fileDescriptorSet,omitempty"`
	// contains filtered or unexported fields
}

func (*RawData_ProtobufSchema) Descriptor deprecated 

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

Deprecated: Use RawData_ProtobufSchema.ProtoReflect.Descriptor instead.

func (*RawData_ProtobufSchema) GetFileDescriptorSet 

func (x *RawData_ProtobufSchema) GetFileDescriptorSet() *descriptorpb.FileDescriptorSet

func (*RawData_ProtobufSchema) GetVersion 

func (x *RawData_ProtobufSchema) GetVersion() int32

func (*RawData_ProtobufSchema) ProtoMessage 

func (*RawData_ProtobufSchema) ProtoMessage()

func (*RawData_ProtobufSchema) ProtoReflect 

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

func (*RawData_ProtobufSchema) Reset 

func (x *RawData_ProtobufSchema) Reset()

func (*RawData_ProtobufSchema) String 

func (x *RawData_ProtobufSchema) String() string

type RawData_ProtobufSchema_ 

type RawData_ProtobufSchema_ struct {
	ProtobufSchema *RawData_ProtobufSchema `protobuf:"bytes,2,opt,name=protobufSchema,proto3,oneof"`
}

type Record 

type Record struct {
	Position  *Position              `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	Metadata  *Metadata              `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// Types that are assignable to Key:
	//	*Record_KeyRaw
	//	*Record_KeyStructured
	Key isRecord_Key `protobuf_oneof:"key"`
	// Types that are assignable to Payload:
	//	*Record_PayloadRaw
	//	*Record_PayloadStructured
	Payload isRecord_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCreatedAt 

func (x *Record) GetCreatedAt() *timestamppb.Timestamp

func (*Record) GetKey 

func (m *Record) GetKey() isRecord_Key

func (*Record) GetKeyRaw 

func (x *Record) GetKeyRaw() *RawData

func (*Record) GetKeyStructured 

func (x *Record) GetKeyStructured() *structpb.Struct

func (*Record) GetMetadata 

func (x *Record) GetMetadata() *Metadata

func (*Record) GetPayload 

func (m *Record) GetPayload() isRecord_Payload

func (*Record) GetPayloadRaw 

func (x *Record) GetPayloadRaw() *RawData

func (*Record) GetPayloadStructured 

func (x *Record) GetPayloadStructured() *structpb.Struct

func (*Record) GetPosition 

func (x *Record) GetPosition() *Position

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type Record_KeyRaw 

type Record_KeyRaw struct {
	KeyRaw *RawData `protobuf:"bytes,4,opt,name=keyRaw,proto3,oneof"`
}

type Record_KeyStructured 

type Record_KeyStructured struct {
	KeyStructured *structpb.Struct `protobuf:"bytes,5,opt,name=keyStructured,proto3,oneof"`
}

type Record_PayloadRaw 

type Record_PayloadRaw struct {
	PayloadRaw *RawData `protobuf:"bytes,6,opt,name=payloadRaw,proto3,oneof"`
}

type Record_PayloadStructured 

type Record_PayloadStructured struct {
	PayloadStructured *structpb.Struct `protobuf:"bytes,7,opt,name=payloadStructured,proto3,oneof"`
}

type SourceClient 

type SourceClient interface {
	Open(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Empty, error)
	Teardown(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Validate(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Empty, error)
	Read(ctx context.Context, in *Position, opts ...grpc.CallOption) (*Record, error)
	Ack(ctx context.Context, in *Position, opts ...grpc.CallOption) (*Empty, error)
}

SourceClient is the client API for Source 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 NewSourceClient 

func NewSourceClient(cc grpc.ClientConnInterface) SourceClient

type SourceServer 

type SourceServer interface {
	Open(context.Context, *Config) (*Empty, error)
	Teardown(context.Context, *Empty) (*Empty, error)
	Validate(context.Context, *Config) (*Empty, error)
	Read(context.Context, *Position) (*Record, error)
	Ack(context.Context, *Position) (*Empty, error)
	// contains filtered or unexported methods
}

SourceServer is the server API for Source service. All implementations must embed UnimplementedSourceServer for forward compatibility

type Specification 

type Specification struct {
	Summary         string                `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	Description     string                `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Version         string                `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Author          string                `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	DestinationSpec map[string]*Parameter `` /* 171-byte string literal not displayed */
	SourceSpec      map[string]*Parameter `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Specification) Descriptor deprecated 

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

Deprecated: Use Specification.ProtoReflect.Descriptor instead.

func (*Specification) GetAuthor 

func (x *Specification) GetAuthor() string

func (*Specification) GetDescription 

func (x *Specification) GetDescription() string

func (*Specification) GetDestinationSpec 

func (x *Specification) GetDestinationSpec() map[string]*Parameter

func (*Specification) GetSourceSpec 

func (x *Specification) GetSourceSpec() map[string]*Parameter

func (*Specification) GetSummary 

func (x *Specification) GetSummary() string

func (*Specification) GetVersion 

func (x *Specification) GetVersion() string

func (*Specification) ProtoMessage 

func (*Specification) ProtoMessage()

func (*Specification) ProtoReflect 

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

func (*Specification) Reset 

func (x *Specification) Reset()

func (*Specification) String 

func (x *Specification) String() string

type SpecificationsClient 

type SpecificationsClient interface {
	Specify(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Specification, error)
}

SpecificationsClient is the client API for Specifications 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 NewSpecificationsClient 

func NewSpecificationsClient(cc grpc.ClientConnInterface) SpecificationsClient

type SpecificationsServer 

type SpecificationsServer interface {
	Specify(context.Context, *Empty) (*Specification, error)
	// contains filtered or unexported methods
}

SpecificationsServer is the server API for Specifications service. All implementations must embed UnimplementedSpecificationsServer for forward compatibility

type UnimplementedDestinationServer 

type UnimplementedDestinationServer struct {
}

UnimplementedDestinationServer must be embedded to have forward compatible implementations.

func (UnimplementedDestinationServer) Open 

func (UnimplementedDestinationServer) Open(context.Context, *Config) (*Empty, error)

func (UnimplementedDestinationServer) Teardown 

func (UnimplementedDestinationServer) Teardown(context.Context, *Empty) (*Empty, error)

func (UnimplementedDestinationServer) Validate 

func (UnimplementedDestinationServer) Validate(context.Context, *Config) (*Empty, error)

func (UnimplementedDestinationServer) Write 

func (UnimplementedDestinationServer) Write(context.Context, *Record) (*Position, error)

type UnimplementedSourceServer 

type UnimplementedSourceServer struct {
}

UnimplementedSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServer) Ack 

func (UnimplementedSourceServer) Ack(context.Context, *Position) (*Empty, error)

func (UnimplementedSourceServer) Open 

func (UnimplementedSourceServer) Open(context.Context, *Config) (*Empty, error)

func (UnimplementedSourceServer) Read 

func (UnimplementedSourceServer) Read(context.Context, *Position) (*Record, error)

func (UnimplementedSourceServer) Teardown 

func (UnimplementedSourceServer) Teardown(context.Context, *Empty) (*Empty, error)

func (UnimplementedSourceServer) Validate 

func (UnimplementedSourceServer) Validate(context.Context, *Config) (*Empty, error)

type UnimplementedSpecificationsServer 

type UnimplementedSpecificationsServer struct {
}

UnimplementedSpecificationsServer must be embedded to have forward compatible implementations.

func (UnimplementedSpecificationsServer) Specify 

func (UnimplementedSpecificationsServer) Specify(context.Context, *Empty) (*Specification, error)

type UnsafeDestinationServer 

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

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

type UnsafeSourceServer 

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

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

type UnsafeSpecificationsServer 

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

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

type Validation 

type Validation struct {
	Type   string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Params []string `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Validation) Descriptor deprecated 

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

Deprecated: Use Validation.ProtoReflect.Descriptor instead.

func (*Validation) GetParams 

func (x *Validation) GetParams() []string

func (*Validation) GetType 

func (x *Validation) GetType() string

func (*Validation) ProtoMessage 

func (*Validation) ProtoMessage()

func (*Validation) ProtoReflect 

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

func (*Validation) Reset 

func (x *Validation) Reset()

func (*Validation) String 

func (x *Validation) 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.