Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Ctx context.Context
Dir string // temp dir for files
Logger log.Logger
State sdk.State // can be nil
RedisClient *redis.Client // can be nil
Integration *IntegrationContext
UUID string
Channel string
Secret string
GroupID string
SelfManaged bool
APIKey string
EnrollmentID string
}
Config is the configuration for the server
type DbChangeEvent ¶
type DbChangeEvent struct {
Action Action `json:"action"`
Data string `json:"data"`
Model string `json:"model"`
Object datamodel.Model `json:"-"`
}
DbChangeEvent is an event which encapsulates a db change
type IntegrationContext ¶
type IntegrationContext struct {
Integration sdk.Integration
Descriptor *sdk.Descriptor
}
IntegrationContext is the details for each integration
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server is the event loop server portion of the agent
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber is a convenience wrapper around a subscription channel
func NewDBChangeSubscriber ¶
func NewDBChangeSubscriber(config Config, location agent.ExportIntegrationLocation, refType string, callback SubscriberCallback) (*Subscriber, error)
NewDBChangeSubscriber will return a db change subscriber
func NewEventSubscriber ¶
func NewEventSubscriber(config Config, topics []string, filters *event.SubscriptionFilter, location agent.ExportIntegrationLocation, callback SubscriberCallback) (*Subscriber, error)
NewEventSubscriber will return an event subscriber
type SubscriberCallback ¶
type SubscriberCallback func(logger sdk.Logger, event event.SubscriptionEvent, refType string, location string) error
SubscriberCallback is the callback for processing events
Click to show internal directories.
Click to hide internal directories.