stream

Documentation

Index

• func NewStreamService(configData []byte) (...)
• func TestMakeDefaultStream(name string, description string, definition string, deploy bool) *core.StreamParameters
• func TestNewStreamService(t *testing.T) ...
• type StreamCompare
• type StreamDescribeResponse
• type StreamService
  • func (s *StreamService) Create(ctx context.Context, stream *core.StreamParameters) error
  • func (s *StreamService) CreateUniqueIdentifier(spec *core.StreamParameters, status *core.StreamObservation) (*string, error)
  • func (s *StreamService) Delete(ctx context.Context, stream *core.StreamParameters) error
  • func (s *StreamService) Describe(ctx context.Context, stream *core.StreamParameters) (*core.StreamObservation, error)
  • func (s *StreamService) GetSpec(app *core.Stream) *core.StreamParameters
  • func (s *StreamService) GetStatus(app *core.Stream) *core.StreamObservation
  • func (s *StreamService) MakeCompare() *StreamCompare
  • func (s *StreamService) SetStatus(app *core.Stream, status *core.StreamObservation)
  • func (s *StreamService) Update(ctx context.Context, app *core.StreamParameters) error

Functions

func NewStreamService

func NewStreamService(configData []byte) (clients.Service[*v1alpha1.Stream, v1alpha1.StreamParameters, v1alpha1.StreamObservation, StreamCompare], error)

func TestMakeDefaultStream

func TestMakeDefaultStream(name string, description string, definition string, deploy bool) *core.StreamParameters

func TestNewStreamService

func TestNewStreamService(t *testing.T) clients.Service[*v1alpha1.Stream, v1alpha1.StreamParameters, v1alpha1.StreamObservation, StreamCompare]

Types

type StreamCompare

type StreamCompare struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Definition  string `json:"definition"`
}

type StreamDescribeResponse

type StreamDescribeResponse struct {
	Name              string `json:"name"`
	DslText           string `json:"dslText"`
	OriginalDslText   string `json:"originalDslText"`
	Status            string `json:"status"`
	Description       string `json:"description"`
	StatusDescription string `json:"statusDescription"`
}

type StreamService

type StreamService struct {
	clients.DataFlowService
}

func (*StreamService) Create

func (s *StreamService) Create(ctx context.Context, stream *core.StreamParameters) error

func (*StreamService) CreateUniqueIdentifier

func (s *StreamService) CreateUniqueIdentifier(spec *core.StreamParameters, status *core.StreamObservation) (*string, error)

func (*StreamService) Delete

func (s *StreamService) Delete(ctx context.Context, stream *core.StreamParameters) error

func (*StreamService) Describe

func (s *StreamService) Describe(ctx context.Context, stream *core.StreamParameters) (*core.StreamObservation, error)

func (*StreamService) GetSpec

func (s *StreamService) GetSpec(app *core.Stream) *core.StreamParameters

func (*StreamService) GetStatus

func (s *StreamService) GetStatus(app *core.Stream) *core.StreamObservation

func (*StreamService) MakeCompare

func (s *StreamService) MakeCompare() *StreamCompare

func (*StreamService) SetStatus

func (s *StreamService) SetStatus(app *core.Stream, status *core.StreamObservation)

func (*StreamService) Update

func (s *StreamService) Update(ctx context.Context, app *core.StreamParameters) error