streams

Documentation

Index

• type StreamServiceManager
  • func NewStreamServiceManager(provider common.ConfigurationProvider, credClient credhelper.CredentialClient, ...) *StreamServiceManager
  • func (c *StreamServiceManager) CreateOrUpdate(ctx context.Context, obj runtime.Object, req ctrl.Request) (servicemanager.OSOKResponse, error)
  • func (c *StreamServiceManager) CreateStream(ctx context.Context, stream ociv1beta1.Stream) (streaming.CreateStreamResponse, error)
  • func (c *StreamServiceManager) Delete(ctx context.Context, obj runtime.Object) (bool, error)
  • func (c *StreamServiceManager) DeleteStream(ctx context.Context, stream ociv1beta1.Stream) (streaming.DeleteStreamResponse, error)
  • func (c *StreamServiceManager) GetCrdStatus(obj runtime.Object) (*ociv1beta1.OSOKStatus, error)
  • func (c *StreamServiceManager) GetCreateOrUpdateStream(listStreamsResponse streaming.ListStreamsResponse, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)
  • func (c *StreamServiceManager) GetFailedOrDeleteStream(listStreamsResponse streaming.ListStreamsResponse, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)
  • func (c *StreamServiceManager) GetListOfStreams(ctx context.Context, stream ociv1beta1.Stream) (streaming.ListStreamsResponse, error)
  • func (c *StreamServiceManager) GetStream(ctx context.Context, streamId ociv1beta1.OCID, retryPolicy *common.RetryPolicy) (*streaming.Stream, error)
  • func (c *StreamServiceManager) GetStreamOCID(ctx context.Context, stream ociv1beta1.Stream, status string) (*ociv1beta1.OCID, error)
  • func (c *StreamServiceManager) GetStreamOcid(ctx context.Context, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)
  • func (c *StreamServiceManager) UpdateStream(ctx context.Context, stream *ociv1beta1.Stream) error

Types

type StreamServiceManager

type StreamServiceManager struct {
	Provider         common.ConfigurationProvider
	CredentialClient credhelper.CredentialClient
	Scheme           *runtime.Scheme
	Log              loggerutil.OSOKLogger
	Metrics          *metrics.Metrics
}

func NewStreamServiceManager

func NewStreamServiceManager(provider common.ConfigurationProvider, credClient credhelper.CredentialClient,
	scheme *runtime.Scheme, log loggerutil.OSOKLogger, metrics *metrics.Metrics) *StreamServiceManager

func (*StreamServiceManager) CreateOrUpdate

func (c *StreamServiceManager) CreateOrUpdate(ctx context.Context, obj runtime.Object, req ctrl.Request) (servicemanager.OSOKResponse, error)

func (*StreamServiceManager) CreateStream

func (c *StreamServiceManager) CreateStream(ctx context.Context, stream ociv1beta1.Stream) (streaming.CreateStreamResponse, error)

func (*StreamServiceManager) Delete

func (c *StreamServiceManager) Delete(ctx context.Context, obj runtime.Object) (bool, error)

func (*StreamServiceManager) DeleteStream

func (c *StreamServiceManager) DeleteStream(ctx context.Context, stream ociv1beta1.Stream) (streaming.DeleteStreamResponse, error)

func (*StreamServiceManager) GetCrdStatus

func (c *StreamServiceManager) GetCrdStatus(obj runtime.Object) (*ociv1beta1.OSOKStatus, error)

func (*StreamServiceManager) GetCreateOrUpdateStream

func (c *StreamServiceManager) GetCreateOrUpdateStream(listStreamsResponse streaming.ListStreamsResponse, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)

func (*StreamServiceManager) GetFailedOrDeleteStream

func (c *StreamServiceManager) GetFailedOrDeleteStream(listStreamsResponse streaming.ListStreamsResponse, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)

func (*StreamServiceManager) GetListOfStreams

func (c *StreamServiceManager) GetListOfStreams(ctx context.Context, stream ociv1beta1.Stream) (streaming.ListStreamsResponse, error)

func (*StreamServiceManager) GetStream

func (c *StreamServiceManager) GetStream(ctx context.Context, streamId ociv1beta1.OCID, retryPolicy *common.RetryPolicy) (*streaming.Stream, error)

func (*StreamServiceManager) GetStreamOCID

func (c *StreamServiceManager) GetStreamOCID(ctx context.Context, stream ociv1beta1.Stream, status string) (*ociv1beta1.OCID, error)

func (*StreamServiceManager) GetStreamOcid

func (c *StreamServiceManager) GetStreamOcid(ctx context.Context, stream ociv1beta1.Stream) (*ociv1beta1.OCID, error)

func (*StreamServiceManager) UpdateStream

func (c *StreamServiceManager) UpdateStream(ctx context.Context, stream *ociv1beta1.Stream) error