streamdal

func (*Filter) String ¶

func (f *Filter) String() string

func (*Streamdal) Close ¶

func (s *Streamdal) Close() error

func (*Streamdal) CreateAudience ¶

func (s *Streamdal) CreateAudience(ctx context.Context, req *protos.CreateAudienceRequest) (*protos.StandardResponse, error)

func (*Streamdal) CreateNotification ¶

func (s *Streamdal) CreateNotification(ctx context.Context, req *protos.CreateNotificationRequest) (*protos.CreateNotificationResponse, error)

func (*Streamdal) CreatePipeline ¶

func (s *Streamdal) CreatePipeline(ctx context.Context, req *protos.CreatePipelineRequest) (*protos.CreatePipelineResponse, error)

func (*Streamdal) DeleteAudience ¶

func (s *Streamdal) DeleteAudience(ctx context.Context, req *protos.DeleteAudienceRequest) (*protos.StandardResponse, error)

func (*Streamdal) DeleteNotification ¶

func (s *Streamdal) DeleteNotification(ctx context.Context, req *protos.DeleteNotificationRequest) (*protos.StandardResponse, error)

func (*Streamdal) DeletePipeline ¶

func (s *Streamdal) DeletePipeline(ctx context.Context, req *protos.DeletePipelineRequest) (*protos.StandardResponse, error)

func (*Streamdal) GetAudience ¶

func (s *Streamdal) GetAudience(ctx context.Context, id string) (*protos.Audience, error)

func (*Streamdal) GetAudienceFilter ¶

func (s *Streamdal) GetAudienceFilter(filters []*Filter) (map[string]interface{}, diag.Diagnostics)

func (*Streamdal) GetNotification ¶

func (s *Streamdal) GetNotification(ctx context.Context, req *protos.GetNotificationRequest) (*protos.GetNotificationResponse, error)

func (*Streamdal) GetNotificationConfigFilter ¶

func (s *Streamdal) GetNotificationConfigFilter(filters []*Filter) (map[string]interface{}, diag.Diagnostics)

func (*Streamdal) GetPipeline ¶

func (s *Streamdal) GetPipeline(ctx context.Context, req *protos.GetPipelineRequest) (*protos.GetPipelineResponse, error)

func (*Streamdal) GetPipelineFilter ¶

func (s *Streamdal) GetPipelineFilter(filters []*Filter) (map[string]interface{}, diag.Diagnostics)

GetPipelineFilter obtains a pipeline for a data source

func (*Streamdal) GetPipelinesForAudience ¶

func (s *Streamdal) GetPipelinesForAudience(ctx context.Context, aud *protos.Audience) ([]string, error)

GetPipelinesForAudience returns a list of pipeline IDs that are associated with the given audience. Used for obtaining pipeline assignments for the audience resource

func (*Streamdal) SetPipelines ¶

func (s *Streamdal) SetPipelines(ctx context.Context, aud *protos.Audience, pipelineIDs []string) (*protos.StandardResponse, error)

func (*Streamdal) UpdateNotification ¶

func (s *Streamdal) UpdateNotification(ctx context.Context, req *protos.UpdateNotificationRequest) (*protos.StandardResponse, error)

func (*Streamdal) UpdatePipeline ¶

func (s *Streamdal) UpdatePipeline(ctx context.Context, req *protos.UpdatePipelineRequest) (*protos.StandardResponse, error)