kinesisvideo

type Channel struct {
	CreationTime      time.Time
	PendingUntil      time.Time
	MediaStorage      *MediaStorage
	Tags              map[string]string
	Name              string
	ARN               string
	Type              string
	Status            string
	Version           string
	MessageTTLSeconds int32
}

type ChannelEndpoint struct {
	Protocol string
	Endpoint string
}

type ChannelNameCondition struct {
	ComparisonOperator string
	ComparisonValue    string
}

type EdgeConfig struct {
	Recorder     *EdgeRecorder
	Deletion     *EdgeDeletion
	Uploader     *EdgeUploader
	HubDeviceARN string
}

type EdgeDeletion struct {
	DeleteAfterUpload    *bool
	EdgeRetentionInHours *int32
	LocalSize            *EdgeLocalSize
}

type EdgeLocalSize struct {
	StrategyOnFullSize    string
	MaxLocalMediaSizeInMB int32
}

type EdgeMediaSource struct {
	MediaURISecretARN string
	MediaURIType      string
}

type EdgeRecorder struct {
	MediaSource *EdgeMediaSource
	Schedule    *EdgeSchedule
}

type EdgeSchedule struct {
	ScheduleExpression string
	DurationInSeconds  int32
}

type EdgeState struct {
	CreationTime    time.Time
	LastUpdatedTime time.Time
	StreamARN       string
	StreamName      string
	SyncStatus      string
	Config          EdgeConfig
}

type EdgeUploader struct {
	Schedule *EdgeSchedule
}

type Handler struct {
	Backend StorageBackend

	AccountID     string
	DefaultRegion string
	// contains filtered or unexported fields
}

type ImageGenerationConfig struct {
	FormatConfig      map[string]string
	DestinationRegion string
	URI               string
	Format            string
	ImageSelectorType string
	Status            string
	SamplingInterval  int32
	HeightPixels      int32
	WidthPixels       int32
}

type InMemoryBackend struct {
	// contains filtered or unexported fields
}

type MediaStorage struct {
	Status    string
	StreamARN string
}

type NotificationConfig struct {
	DestinationURI string
	Status         string
}

type Provider struct{}

type Snapshottable interface {
	Snapshot(ctx context.Context) []byte
	Restore(context.Context, []byte) error
}

type StorageBackend interface {
	CreateStream(accountID, region, name, deviceName, mediaType, kmsKeyID, defaultStorageTier string,
		dataRetentionInHours int32, tags map[string]string) (*Stream, error)
	DescribeStream(name, streamARN string) (*Stream, error)
	ListStreams(nextToken string, maxResults int, condition *StreamNameCondition) ([]*Stream, string, error)
	UpdateStream(name, streamARN, currentVersion, deviceName, mediaType string) error
	DeleteStream(streamARN, currentVersion string) error
	UpdateDataRetention(name, streamARN, currentVersion, operation string, changeInHours int32) error

	TagStream(name, streamARN string, tags map[string]string) error
	UntagStream(name, streamARN string, tagKeys []string) error
	ListTagsForStream(name, streamARN string) (map[string]string, error)

	TagResource(resourceARN string, tags map[string]string) error
	UntagResource(resourceARN string, tagKeys []string) error
	ListTagsForResource(resourceARN string) (map[string]string, error)

	GetDataEndpoint(name, streamARN, apiName, region string) (string, error)

	DescribeImageGenerationConfiguration(name, streamARN string) (*ImageGenerationConfig, error)
	UpdateImageGenerationConfiguration(name, streamARN string, cfg *ImageGenerationConfig) error
	DescribeNotificationConfiguration(name, streamARN string) (*NotificationConfig, error)
	UpdateNotificationConfiguration(name, streamARN string, cfg *NotificationConfig) error

	CreateSignalingChannel(
		accountID, region, name, channelType string, messageTTLSeconds int32, tags map[string]string,
	) (*Channel, error)
	DescribeSignalingChannel(name, channelARN string) (*Channel, error)
	ListSignalingChannels(nextToken string, maxResults int, condition *ChannelNameCondition) ([]*Channel, string, error)
	UpdateSignalingChannel(channelARN, currentVersion string, messageTTLSeconds *int32) error
	DeleteSignalingChannel(channelARN, currentVersion string) error

	DescribeStreamStorageConfiguration(name, streamARN string) (*Stream, error)
	UpdateStreamStorageConfiguration(name, streamARN, currentVersion, defaultStorageTier string) error
	DescribeMediaStorageConfiguration(name, channelARN string) (*MediaStorage, error)
	UpdateMediaStorageConfiguration(channelARN string, cfg MediaStorage) error
	GetSignalingChannelEndpoint(channelARN, role, region string, protocols []string) ([]ChannelEndpoint, error)

	StartEdgeConfigurationUpdate(name, streamARN string, cfg EdgeConfig) (*EdgeState, error)
	DescribeEdgeConfiguration(name, streamARN string) (*EdgeState, error)
	DeleteEdgeConfiguration(name, streamARN string) error
	ListEdgeAgentConfigurations(hubDeviceARN, nextToken string, maxResults int) ([]*EdgeState, string, error)

	Reset()
}

type Stream struct {
	CreationTime         time.Time
	PendingUntil         time.Time
	ImageGeneration      *ImageGenerationConfig
	Notification         *NotificationConfig
	Edge                 *EdgeState
	Tags                 map[string]string
	Name                 string
	ARN                  string
	Status               string
	Version              string
	DeviceName           string
	KmsKeyID             string
	MediaType            string
	DefaultStorageTier   string
	DataRetentionInHours int32
}

type StreamNameCondition struct {
	ComparisonOperator string
	ComparisonValue    string
}