Skip to content

PURISTA API


PURISTA API / @purista/core / SubscriptionDefinition

Type Alias: SubscriptionDefinition<S, TransformInputPayload, TransformInputParams, FunctionPayloadType, FunctionParamsType, FunctionOutputType, FinalFunctionOutputType, TransformOutputHookOutput, Resources, Invokes, StreamInvokes, EmitList, MetadataType, QueueInvokes, AgentInvokes>

SubscriptionDefinition<S, TransformInputPayload, TransformInputParams, FunctionPayloadType, FunctionParamsType, FunctionOutputType, FinalFunctionOutputType, TransformOutputHookOutput, Resources, Invokes, StreamInvokes, EmitList, MetadataType, QueueInvokes, AgentInvokes> = object

Defined in: core/types/subscription/SubscriptionDefinition.ts:24

The definition for a subscription provided by some service.

Type Parameters

S

S extends ServiceClass

TransformInputPayload

TransformInputPayload

TransformInputParams

TransformInputParams

FunctionPayloadType

FunctionPayloadType

FunctionParamsType

FunctionParamsType

FunctionOutputType

FunctionOutputType

FinalFunctionOutputType

FinalFunctionOutputType

TransformOutputHookOutput

TransformOutputHookOutput

Resources

Resources extends Record<string, unknown>

Invokes

Invokes extends InvokeList

StreamInvokes

StreamInvokes extends StreamInvokeList

EmitList

EmitList extends Record<string, Schema>

MetadataType

MetadataType extends SubscriptionDefinitionMetadataBase = SubscriptionDefinitionMetadataBase

QueueInvokes

QueueInvokes extends QueueInvokeList = QueueInvokeList

AgentInvokes

AgentInvokes extends AgentInvokeList = AgentInvokeList

Properties

agentInvokes

agentInvokes: AgentInvokes

Defined in: core/types/subscription/SubscriptionDefinition.ts:140


call

call: SubscriptionFunction<S, FunctionPayloadType, FunctionParamsType, FunctionOutputType, Resources, Invokes, StreamInvokes, EmitList, QueueInvokes, AgentInvokes>

Defined in: core/types/subscription/SubscriptionDefinition.ts:50

the subscription function


deprecated

deprecated: boolean

Defined in: core/types/subscription/SubscriptionDefinition.ts:143


emitEventName?

optional emitEventName: string

Defined in: core/types/subscription/SubscriptionDefinition.ts:81

event name to be used for custom message if the subscription functions returns value


emitList

emitList: EmitList

Defined in: core/types/subscription/SubscriptionDefinition.ts:141


eventBridgeConfig

eventBridgeConfig: DefinitionEventBridgeConfig

Defined in: core/types/subscription/SubscriptionDefinition.ts:48

config information for event bridge


eventName?

optional eventName: string

Defined in: core/types/subscription/SubscriptionDefinition.ts:79

filter forevent name


hooks

hooks: object

Defined in: core/types/subscription/SubscriptionDefinition.ts:87

hooks of subscription

afterGuard?

optional afterGuard: Record<string, SubscriptionAfterGuardHook<S, FunctionPayloadType, FunctionParamsType, FunctionOutputType, Resources, Invokes, StreamInvokes, EmitList, QueueInvokes, AgentInvokes>>

beforeGuard?

optional beforeGuard: Record<string, SubscriptionBeforeGuardHook<S, FunctionPayloadType, FunctionParamsType, Resources, Invokes, StreamInvokes, EmitList, QueueInvokes, AgentInvokes>>

transformInput?

optional transformInput: object

transformInput.transformFunction

transformFunction: SubscriptionTransformInputHook<S, TransformInputPayload, TransformInputParams, FunctionPayloadType, FunctionParamsType>

transformInput.transformInputSchema

transformInputSchema: Schema

transformInput.transformParameterSchema

transformParameterSchema: Schema

transformOutput?

optional transformOutput: object

transformOutput.transformFunction

transformFunction: SubscriptionTransformOutputHook<S, FinalFunctionOutputType, FunctionParamsType, TransformOutputHookOutput>

transformOutput.transformOutputSchema

transformOutputSchema: Schema


invokes

invokes: Invokes

Defined in: core/types/subscription/SubscriptionDefinition.ts:138


messageType?

optional messageType: EBMessageType

Defined in: core/types/subscription/SubscriptionDefinition.ts:77

filter for message type


metadata

metadata: MetadataType

Defined in: core/types/subscription/SubscriptionDefinition.ts:46

the metadata of the subscription


principalId?

optional principalId: PrincipalId

Defined in: core/types/subscription/SubscriptionDefinition.ts:83

filter for principal id


queueInvokes

queueInvokes: QueueInvokes

Defined in: core/types/subscription/SubscriptionDefinition.ts:142


receiver?

optional receiver: object

Defined in: core/types/subscription/SubscriptionDefinition.ts:70

filter for messages consumed by given receiver

instanceId?

optional instanceId: InstanceId

serviceName?

optional serviceName: string

serviceTarget?

optional serviceTarget: string

serviceVersion?

optional serviceVersion: string


sender?

optional sender: object

Defined in: core/types/subscription/SubscriptionDefinition.ts:63

filter for messages produced by given sender

instanceId?

optional instanceId: InstanceId

serviceName?

optional serviceName: string

serviceTarget?

optional serviceTarget: string

serviceVersion?

optional serviceVersion: string


streamInvokes

streamInvokes: StreamInvokes

Defined in: core/types/subscription/SubscriptionDefinition.ts:139


subscriptionDescription

subscriptionDescription: string

Defined in: core/types/subscription/SubscriptionDefinition.ts:44

the description of the subscription


subscriptionName

subscriptionName: string

Defined in: core/types/subscription/SubscriptionDefinition.ts:42

the name of the subscription


tenantId?

optional tenantId: TenantId

Defined in: core/types/subscription/SubscriptionDefinition.ts:85

filter for tenant id