jetstream

Documentation

Index

• func BuildFromVertexWatermarkStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, ...) (map[string]store.WatermarkStore, error)
• func BuildPublishersFromStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, ...) map[string]publish.Publisher
• func BuildSourcePublisherStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, ...) (store.WatermarkStore, error)
• func BuildToVertexWatermarkStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, ...) (map[string]store.WatermarkStore, error)

Functions

func BuildFromVertexWatermarkStores

func BuildFromVertexWatermarkStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, client *jsclient.NATSClient) (map[string]store.WatermarkStore, error)

BuildFromVertexWatermarkStores creates a map of WatermarkStores for all the incoming edges of the given Vertex.

func BuildPublishersFromStores

func BuildPublishersFromStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, wmStores map[string]store.WatermarkStore) map[string]publish.Publisher

BuildPublishersFromStores creates a map of publishers for all the to buckets of the given vertex using the given watermark stores.

func BuildSourcePublisherStores

func BuildSourcePublisherStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, client *jsclient.NATSClient) (store.WatermarkStore, error)

BuildSourcePublisherStores builds the watermark stores for source publisher.

func BuildToVertexWatermarkStores

func BuildToVertexWatermarkStores(ctx context.Context, vertexInstance *v1alpha1.VertexInstance, client *jsclient.NATSClient) (map[string]store.WatermarkStore, error)

BuildToVertexWatermarkStores creates a map of WatermarkStore for all the to buckets of the given vertex.