Documentation ¶
Index ¶
- Variables
- type Event
- type Field
- type Handler
- func (handler *Handler) EventReceiver()
- func (handler *Handler) LoadRuleFile(filename string) error
- func (handler *Handler) PreparePipelineData(workerID int32, event *Event) (interface{}, error)
- func (handler *Handler) ProcessEvent(eventName string, data []byte, meta map[string][]byte) error
- func (handler *Handler) ProcessPipelineData(workerID int32, request *Request) error
- type MappingConfig
- type Payload
- type Projection
- type RawData
- type Request
- type Rule
- type RuleConfig
- type Service
Constants ¶
This section is empty.
Variables ¶
View Source
var PushSuccess = pb.PushReply{ Success: true, }
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func CreateHandler ¶
func (*Handler) EventReceiver ¶
func (handler *Handler) EventReceiver()
func (*Handler) LoadRuleFile ¶
func (*Handler) PreparePipelineData ¶
func (*Handler) ProcessEvent ¶
type MappingConfig ¶
type Projection ¶
type Rule ¶
type Rule struct { Event string `json:"event"` Collection string `json:"collection"` Method string `json:"method"` PrimaryKey string `json:"primaryKey"` Mapping []MappingConfig `json:"mapping"` }
type RuleConfig ¶
type RuleConfig struct {
Rules []*Rule `json:"rules"`
}
func LoadRuleFile ¶
func LoadRuleFile(filename string) (*RuleConfig, error)
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) PushStream ¶
func (service *Service) PushStream(stream pb.DataHandler_PushStreamServer) error
Click to show internal directories.
Click to hide internal directories.