model

package

Go to main page

Versions in this module

v0

v0.15.3

Jan 8, 2020

Changes in this version

type DatabaseEventMessage

+ Find interface{}

type FeedData

+ Find interface{}

v0.15.2

Jan 2, 2020

v0.15.0

Dec 29, 2019

Changes in this version

type CreateFileRequest

+ Meta map[string]interface{}

+ type DeleteFileRequest struct

+ Meta map[string]interface{}

+ Path string

+ type EventingModule interface

+ CreateFileIntentHook func(ctx context.Context, req *CreateFileRequest) (*EventIntent, error)

+ DeleteFileIntentHook func(ctx context.Context, path string) (*EventIntent, error)

+ HookStage func(ctx context.Context, intent *EventIntent, err error)

+ type FilePayload struct

+ Meta map[string]interface{}

+ Path string

v0.14.0

Dec 7, 2019

v0.13.1

Nov 25, 2019

v0.13.0

Nov 4, 2019

Changes in this version

+ type CloudEventPayload struct

+ Data interface{}

+ Id string

+ Source string

+ SpecVersion string

+ Time string

+ Type string

type EventDocument

+ Remark string

+ Url string

+ type EventResponse struct

+ Error string

+ Event *QueueEventRequest

+ Events []*QueueEventRequest

+ type MetricCrudHook func(project, dbType, col string, count int64, op utils.OperationType)

v0.12.1

Oct 8, 2019

Changes in this version

type QueueEventRequest

+ Options map[string]string

v0.12.0

Sep 29, 2019

Changes in this version

+ type BatchIntentHook func(ctx context.Context, dbType string, req *BatchRequest) (*EventIntent, error)

+ type CreateIntentHook func(ctx context.Context, dbType, col string, req *CreateRequest) (*EventIntent, error)

+ type CrudHooks struct

+ Batch BatchIntentHook

+ Create CreateIntentHook

+ Delete DeleteIntentHook

+ Stage StageEventHook

+ Update UpdateIntentHook

+ type DatabaseEventMessage struct

+ Col string

+ DBType string

+ Doc interface{}

+ DocID string

+ type DeleteIntentHook func(ctx context.Context, dbType, col string, req *DeleteRequest) (*EventIntent, error)

+ type EventDocument struct

+ BatchID string

+ EventTimestamp int64

+ Function string

+ ID string

+ Payload string

+ Retries int

+ Service string

+ Status string

+ Timestamp int64

+ Token int

+ Type string

+ type EventIntent struct

+ BatchID string

+ Docs []*EventDocument

+ Invalid bool

+ Token int

+ type EventKind string

type FeedData

+ TypeName string

+ type GraphQLRequest struct

+ OperationName string

+ Query string

+ Variables map[string]interface{}

+ type PubsubCallback func(msg *PubsubMsg)

+ type PubsubMsg struct

+ Data interface{}

+ Subject string

+ type PubsubMsgResponse struct

+ Error string

+ Msg []byte

+ Status int32

+ type PubsubPublishRequest struct

+ Data interface{}

+ Subject string

+ type PubsubSubscribeRequest struct

+ Id string

+ Project string

+ Queue string

+ Subject string

+ Token string

+ Type string

+ type PubsubUnsubscribe func() error

+ type QueueEventRequest struct

+ Delay int64

+ Payload interface{}

+ Timestamp int64

+ Type string

+ type ReadRequestKey struct

+ Col string

+ DBType string

+ HasOptions bool

+ Req ReadRequest

+ func (key ReadRequestKey) Raw() interface{}

+ func (key ReadRequestKey) String() string

+ type StageEventHook func(ctx context.Context, intent *EventIntent, err error)

+ type UpdateIntentHook func(ctx context.Context, dbType, col string, req *UpdateRequest) (*EventIntent, error)

v0.11.0

Aug 3, 2019

Changes in this version

type RaftCommand

+ Deploy *config.Deploy

+ Operation *config.OperationConfig

+ Static *config.Static

v0.10.1

Jul 24, 2019

v0.10.0

Jul 21, 2019

Changes in this version

+ type LiveQueryOptions struct

+ SkipInitial bool

+ type RaftCommand struct

+ ID string

+ Kind utils.RaftCommandType

+ Project *config.Project

type RealtimeRequest

+ Options LiveQueryOptions

v0.9.0

Jun 21, 2019

Changes in this version

+ type AggregateRequest struct

+ Operation string

+ Pipeline interface{}

+ type AllRequest struct

+ Col string

+ Document interface{}

+ Find map[string]interface{}

+ Operation string

+ Type string

+ Update map[string]interface{}

+ type BatchRequest struct

+ Requests []AllRequest

+ type CreateFileRequest struct

+ MakeAll bool

+ Name string

+ Path string

+ Type string

+ type CreateRequest struct

+ Document interface{}

+ Operation string

+ type DeleteRequest struct

+ Find map[string]interface{}

+ Operation string

+ type FeedData struct

+ DBType string

+ DocID string

+ Group string

+ Payload map[string]interface{}

+ QueryID string

+ TimeStamp int64

+ Type string

+ type File struct

+ Close func() error

+ File io.Reader

+ type FileReader func(io.Reader) (int, error)

+ type FunctionsPayload struct

+ Auth map[string]interface{}

+ Error string

+ Func string

+ ID string

+ Params interface{}

+ Service string

+ type FunctionsRequest struct

+ Params interface{}

+ Timeout int

+ type ListFilesRequest struct

+ Path string

+ Type string

+ type ListFilesResponse struct

+ Name string

+ Type string

+ type Message struct

+ Data interface{}

+ ID string

+ Type string

+ type ReadOptions struct

+ Distinct *string

+ Limit *int64

+ Select map[string]int32

+ Skip *int64

+ Sort map[string]int32

+ type ReadRequest struct

+ Find map[string]interface{}

+ Operation string

+ Options *ReadOptions

+ type RealtimeRequest struct

+ DBType string

+ Group string

+ ID string

+ Project string

+ Token string

+ Type string

+ Where map[string]interface{}

+ type RealtimeResponse struct

+ Ack bool

+ Docs []*FeedData

+ Error string

+ Group string

+ ID string

+ type ServiceRegisterRequest struct

+ Project string

+ Service string

+ Token string

+ type UpdateRequest struct

+ Find map[string]interface{}

+ Operation string

+ Update map[string]interface{}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL