__

package
v0.2.28 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2022 License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_data_source_adapter_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BatchPublishReply 

type BatchPublishReply struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	SuccessCount int32  `protobuf:"varint,2,opt,name=successCount,proto3" json:"successCount,omitempty"`
	Reason       string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchPublishReply) Descriptor deprecated 

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

Deprecated: Use BatchPublishReply.ProtoReflect.Descriptor instead.

func (*BatchPublishReply) GetReason 

func (x *BatchPublishReply) GetReason() string

func (*BatchPublishReply) GetSuccess 

func (x *BatchPublishReply) GetSuccess() bool

func (*BatchPublishReply) GetSuccessCount 

func (x *BatchPublishReply) GetSuccessCount() int32

func (*BatchPublishReply) ProtoMessage 

func (*BatchPublishReply) ProtoMessage()

func (*BatchPublishReply) ProtoReflect added in v0.0.22 

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

func (*BatchPublishReply) Reset 

func (x *BatchPublishReply) Reset()

func (*BatchPublishReply) String 

func (x *BatchPublishReply) String() string

type BatchPublishRequest 

type BatchPublishRequest struct {
	Requests []*PublishRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchPublishRequest) Descriptor deprecated 

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

Deprecated: Use BatchPublishRequest.ProtoReflect.Descriptor instead.

func (*BatchPublishRequest) GetRequests 

func (x *BatchPublishRequest) GetRequests() []*PublishRequest

func (*BatchPublishRequest) ProtoMessage 

func (*BatchPublishRequest) ProtoMessage()

func (*BatchPublishRequest) ProtoReflect added in v0.0.22 

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

func (*BatchPublishRequest) Reset 

func (x *BatchPublishRequest) Reset()

func (*BatchPublishRequest) String 

func (x *BatchPublishRequest) String() string

type Event added in v0.0.22 

type Event struct {
	PrimaryKey string `protobuf:"bytes,1,opt,name=primaryKey,proto3" json:"primaryKey,omitempty"`
	EventName  string `protobuf:"bytes,2,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Payload    []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated added in v0.0.22 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEventName added in v0.0.22 

func (x *Event) GetEventName() string

func (*Event) GetPayload added in v0.0.22 

func (x *Event) GetPayload() []byte

func (*Event) GetPrimaryKey added in v0.0.22 

func (x *Event) GetPrimaryKey() string

func (*Event) ProtoMessage added in v0.0.22 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.0.22 

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

func (*Event) Reset added in v0.0.22 

func (x *Event) Reset()

func (*Event) String added in v0.0.22 

func (x *Event) String() string

type Packet added in v0.0.22 

type Packet struct {
	PipelineID int32    `protobuf:"varint,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	Events     []*Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor deprecated added in v0.0.22 

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetEvents added in v0.0.22 

func (x *Packet) GetEvents() []*Event

func (*Packet) GetPipelineID added in v0.0.22 

func (x *Packet) GetPipelineID() int32

func (*Packet) ProtoMessage added in v0.0.22 

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect added in v0.0.22 

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

func (*Packet) Reset added in v0.0.22 

func (x *Packet) Reset()

func (*Packet) String added in v0.0.22 

func (x *Packet) String() string

type PublishReply 

type PublishReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishReply) Descriptor deprecated 

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

Deprecated: Use PublishReply.ProtoReflect.Descriptor instead.

func (*PublishReply) GetReason 

func (x *PublishReply) GetReason() string

func (*PublishReply) GetSuccess 

func (x *PublishReply) GetSuccess() bool

func (*PublishReply) ProtoMessage 

func (*PublishReply) ProtoMessage()

func (*PublishReply) ProtoReflect added in v0.0.22 

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

func (*PublishReply) Reset 

func (x *PublishReply) Reset()

func (*PublishReply) String 

func (x *PublishReply) String() string

type PublishRequest 

type PublishRequest struct {
	EventName string            `protobuf:"bytes,1,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Payload   []byte            `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Meta      map[string][]byte `` /* 149-byte string literal not displayed */
	Source    string            `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Partition int32             `protobuf:"varint,5,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int32             `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetEventName 

func (x *PublishRequest) GetEventName() string

func (*PublishRequest) GetMeta 

func (x *PublishRequest) GetMeta() map[string][]byte

func (*PublishRequest) GetOffset 

func (x *PublishRequest) GetOffset() int32

func (*PublishRequest) GetPartition 

func (x *PublishRequest) GetPartition() int32

func (*PublishRequest) GetPayload 

func (x *PublishRequest) GetPayload() []byte

func (*PublishRequest) GetSource 

func (x *PublishRequest) GetSource() string

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect added in v0.0.22 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

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