pubsub_datasource

type Configuration struct {
	Events []EventConfiguration `json:"events"`
}

type Connector interface {
	New(ctx context.Context) PubSub
}

type EventConfiguration struct {
	Type      EventType `json:"type"`
	TypeName  string    `json:"typeName"`
	FieldName string    `json:"fieldName"`
	Topic     string    `json:"topic"`
}

type EventType string

type Factory struct {
	Connector Connector
}

type Planner struct {
	// contains filtered or unexported fields
}

type PubSub interface {
	// ID is the unique identifier of the pubsub implementation (e.g. NATS)
	// This is used to uniquely identify a subscription
	ID() string
	// Subscribe starts listening on the given topic and sends the received messages to the given next channel
	Subscribe(ctx context.Context, topic string, updater resolve.SubscriptionUpdater) error
	// Publish sends the given data to the given topic
	Publish(ctx context.Context, topic string, data []byte) error
	// Request sends a request on the given topic and writes the response to the given writer
	Request(ctx context.Context, topic string, data []byte, w io.Writer) error
}

type PublishDataSource struct {
	// contains filtered or unexported fields
}

type RequestDataSource struct {
	// contains filtered or unexported fields
}

type SubscriptionSource struct {
	// contains filtered or unexported fields
}