data

Documentation

Index

• Variables
• type DataService
• type Document
  • func (*Document) Descriptor() ([]byte, []int)
  • func (x *Document) FastRead(buf []byte, _type int8, number int32) (offset int, err error)
  • func (x *Document) FastWrite(buf []byte) (offset int)
  • func (x *Document) GetEventName() string
  • func (x *Document) GetTags() string
  • func (*Document) ProtoMessage()
  • func (x *Document) ProtoReflect() protoreflect.Message
  • func (x *Document) Reset()
  • func (x *Document) Size() (n int)
  • func (x *Document) String() string
• type InsertReq
  • func (*InsertReq) Descriptor() ([]byte, []int)
  • func (x *InsertReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)
  • func (x *InsertReq) FastWrite(buf []byte) (offset int)
  • func (x *InsertReq) GetDocuments() []*Document
  • func (*InsertReq) ProtoMessage()
  • func (x *InsertReq) ProtoReflect() protoreflect.Message
  • func (x *InsertReq) Reset()
  • func (x *InsertReq) Size() (n int)
  • func (x *InsertReq) String() string
• type InsertResp
  • func (*InsertResp) Descriptor() ([]byte, []int)
  • func (x *InsertResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)
  • func (x *InsertResp) FastWrite(buf []byte) (offset int)
  • func (x *InsertResp) GetDone() bool
  • func (*InsertResp) ProtoMessage()
  • func (x *InsertResp) ProtoReflect() protoreflect.Message
  • func (x *InsertResp) Reset()
  • func (x *InsertResp) Size() (n int)
  • func (x *InsertResp) String() string

Variables

var File_platform_data_data_proto protoreflect.FileDescriptor

Types

type DataService

type DataService interface {
	Insert(ctx context.Context, req *InsertReq) (res *InsertResp, err error)
}

type Document

type Document struct {
	EventName string `protobuf:"bytes,1,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"`
	Tags      string `protobuf:"bytes,2,opt,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Document) Descriptor

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

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) FastRead

func (x *Document) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*Document) FastWrite

func (x *Document) FastWrite(buf []byte) (offset int)

func (*Document) GetEventName

func (x *Document) GetEventName() string

func (*Document) GetTags

func (x *Document) GetTags() string

func (*Document) ProtoMessage

func (*Document) ProtoMessage()

func (*Document) ProtoReflect

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

func (*Document) Reset

func (x *Document) Reset()

func (*Document) Size

func (x *Document) Size() (n int)

func (*Document) String

func (x *Document) String() string

type InsertReq

type InsertReq struct {
	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertReq) Descriptor

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

Deprecated: Use InsertReq.ProtoReflect.Descriptor instead.

func (*InsertReq) FastRead

func (x *InsertReq) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*InsertReq) FastWrite

func (x *InsertReq) FastWrite(buf []byte) (offset int)

func (*InsertReq) GetDocuments

func (x *InsertReq) GetDocuments() []*Document

func (*InsertReq) ProtoMessage

func (*InsertReq) ProtoMessage()

func (*InsertReq) ProtoReflect

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

func (*InsertReq) Reset

func (x *InsertReq) Reset()

func (*InsertReq) Size

func (x *InsertReq) Size() (n int)

func (*InsertReq) String

func (x *InsertReq) String() string

type InsertResp

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

func (*InsertResp) Descriptor

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

Deprecated: Use InsertResp.ProtoReflect.Descriptor instead.

func (*InsertResp) FastRead

func (x *InsertResp) FastRead(buf []byte, _type int8, number int32) (offset int, err error)

func (*InsertResp) FastWrite

func (x *InsertResp) FastWrite(buf []byte) (offset int)

func (*InsertResp) GetDone

func (x *InsertResp) GetDone() bool

func (*InsertResp) ProtoMessage

func (*InsertResp) ProtoMessage()

func (*InsertResp) ProtoReflect

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

func (*InsertResp) Reset

func (x *InsertResp) Reset()

func (*InsertResp) Size

func (x *InsertResp) Size() (n int)

func (*InsertResp) String

func (x *InsertResp) String() string