Documentation ¶
Index ¶
- func PossibleValuesForAsyncOperationStatus() []string
- func PossibleValuesForStreamingEndpointResourceState() []string
- func ValidateMediaServiceID(input interface{}, key string) (warnings []string, errors []error)
- func ValidateStreamingEndpointID(input interface{}, key string) (warnings []string, errors []error)
- func ValidateStreamingEndpointOperationID(input interface{}, key string) (warnings []string, errors []error)
- type AkamaiAccessControl
- type AkamaiSignatureHeaderAuthenticationKey
- type ArmStreamingEndpointCapacity
- type ArmStreamingEndpointCurrentSku
- type ArmStreamingEndpointSku
- type ArmStreamingEndpointSkuInfo
- type AsyncOperationOperationResponse
- type AsyncOperationResult
- type AsyncOperationStatus
- type CreateOperationOptions
- type CreateOperationResponse
- type CrossSiteAccessPolicies
- type DeleteOperationResponse
- type ErrorAdditionalInfo
- type ErrorDetail
- type GetOperationResponse
- type IPAccessControl
- type IPRange
- type ListCompleteResult
- type ListOperationResponse
- type MediaServiceId
- type ScaleOperationResponse
- type SkusOperationResponse
- type StartOperationResponse
- type StopOperationResponse
- type StreamingEndpoint
- type StreamingEndpointAccessControl
- type StreamingEndpointId
- type StreamingEndpointOperationId
- func NewStreamingEndpointOperationID(subscriptionId string, resourceGroupName string, mediaServiceName string, ...) StreamingEndpointOperationId
- func ParseStreamingEndpointOperationID(input string) (*StreamingEndpointOperationId, error)
- func ParseStreamingEndpointOperationIDInsensitively(input string) (*StreamingEndpointOperationId, error)
- type StreamingEndpointOperationPredicate
- type StreamingEndpointProperties
- func (o *StreamingEndpointProperties) GetCreatedAsTime() (*time.Time, error)
- func (o *StreamingEndpointProperties) GetFreeTrialEndTimeAsTime() (*time.Time, error)
- func (o *StreamingEndpointProperties) GetLastModifiedAsTime() (*time.Time, error)
- func (o *StreamingEndpointProperties) SetCreatedAsTime(input time.Time)
- func (o *StreamingEndpointProperties) SetFreeTrialEndTimeAsTime(input time.Time)
- func (o *StreamingEndpointProperties) SetLastModifiedAsTime(input time.Time)
- type StreamingEndpointResourceState
- type StreamingEndpointSkuInfoListResult
- type StreamingEndpointsClient
- func (c StreamingEndpointsClient) AsyncOperation(ctx context.Context, id StreamingEndpointOperationId) (result AsyncOperationOperationResponse, err error)
- func (c StreamingEndpointsClient) Create(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint, ...) (result CreateOperationResponse, err error)
- func (c StreamingEndpointsClient) CreateThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint, ...) error
- func (c StreamingEndpointsClient) Delete(ctx context.Context, id StreamingEndpointId) (result DeleteOperationResponse, err error)
- func (c StreamingEndpointsClient) DeleteThenPoll(ctx context.Context, id StreamingEndpointId) error
- func (c StreamingEndpointsClient) Get(ctx context.Context, id StreamingEndpointId) (result GetOperationResponse, err error)
- func (c StreamingEndpointsClient) List(ctx context.Context, id MediaServiceId) (result ListOperationResponse, err error)
- func (c StreamingEndpointsClient) ListComplete(ctx context.Context, id MediaServiceId) (ListCompleteResult, error)
- func (c StreamingEndpointsClient) ListCompleteMatchingPredicate(ctx context.Context, id MediaServiceId, ...) (result ListCompleteResult, err error)
- func (c StreamingEndpointsClient) Scale(ctx context.Context, id StreamingEndpointId, input StreamingEntityScaleUnit) (result ScaleOperationResponse, err error)
- func (c StreamingEndpointsClient) ScaleThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEntityScaleUnit) error
- func (c StreamingEndpointsClient) Skus(ctx context.Context, id StreamingEndpointId) (result SkusOperationResponse, err error)
- func (c StreamingEndpointsClient) Start(ctx context.Context, id StreamingEndpointId) (result StartOperationResponse, err error)
- func (c StreamingEndpointsClient) StartThenPoll(ctx context.Context, id StreamingEndpointId) error
- func (c StreamingEndpointsClient) Stop(ctx context.Context, id StreamingEndpointId) (result StopOperationResponse, err error)
- func (c StreamingEndpointsClient) StopThenPoll(ctx context.Context, id StreamingEndpointId) error
- func (c StreamingEndpointsClient) Update(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint) (result UpdateOperationResponse, err error)
- func (c StreamingEndpointsClient) UpdateThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint) error
- type StreamingEntityScaleUnit
- type UpdateOperationResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PossibleValuesForAsyncOperationStatus ¶
func PossibleValuesForAsyncOperationStatus() []string
func PossibleValuesForStreamingEndpointResourceState ¶
func PossibleValuesForStreamingEndpointResourceState() []string
func ValidateMediaServiceID ¶
ValidateMediaServiceID checks that 'input' can be parsed as a Media Service ID
func ValidateStreamingEndpointID ¶
ValidateStreamingEndpointID checks that 'input' can be parsed as a Streaming Endpoint ID
func ValidateStreamingEndpointOperationID ¶
func ValidateStreamingEndpointOperationID(input interface{}, key string) (warnings []string, errors []error)
ValidateStreamingEndpointOperationID checks that 'input' can be parsed as a Streaming Endpoint Operation ID
Types ¶
type AkamaiAccessControl ¶
type AkamaiAccessControl struct {
AkamaiSignatureHeaderAuthenticationKeyList *[]AkamaiSignatureHeaderAuthenticationKey `json:"akamaiSignatureHeaderAuthenticationKeyList,omitempty"`
}
type AkamaiSignatureHeaderAuthenticationKey ¶
type AkamaiSignatureHeaderAuthenticationKey struct { Base64Key *string `json:"base64Key,omitempty"` Expiration *string `json:"expiration,omitempty"` Identifier *string `json:"identifier,omitempty"` }
func (*AkamaiSignatureHeaderAuthenticationKey) GetExpirationAsTime ¶
func (o *AkamaiSignatureHeaderAuthenticationKey) GetExpirationAsTime() (*time.Time, error)
func (*AkamaiSignatureHeaderAuthenticationKey) SetExpirationAsTime ¶
func (o *AkamaiSignatureHeaderAuthenticationKey) SetExpirationAsTime(input time.Time)
type ArmStreamingEndpointSku ¶
type ArmStreamingEndpointSku struct {
Name *string `json:"name,omitempty"`
}
type ArmStreamingEndpointSkuInfo ¶
type ArmStreamingEndpointSkuInfo struct { Capacity *ArmStreamingEndpointCapacity `json:"capacity,omitempty"` ResourceType *string `json:"resourceType,omitempty"` Sku *ArmStreamingEndpointSku `json:"sku,omitempty"` }
type AsyncOperationOperationResponse ¶
type AsyncOperationOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *AsyncOperationResult }
type AsyncOperationResult ¶
type AsyncOperationResult struct { Error *ErrorDetail `json:"error,omitempty"` Name *string `json:"name,omitempty"` Status *AsyncOperationStatus `json:"status,omitempty"` }
type AsyncOperationStatus ¶
type AsyncOperationStatus string
const ( AsyncOperationStatusFailed AsyncOperationStatus = "Failed" AsyncOperationStatusInProgress AsyncOperationStatus = "InProgress" AsyncOperationStatusSucceeded AsyncOperationStatus = "Succeeded" )
func (*AsyncOperationStatus) UnmarshalJSON ¶ added in v0.20230406.1124617
func (s *AsyncOperationStatus) UnmarshalJSON(bytes []byte) error
type CreateOperationOptions ¶
type CreateOperationOptions struct {
AutoStart *bool
}
func DefaultCreateOperationOptions ¶
func DefaultCreateOperationOptions() CreateOperationOptions
func (CreateOperationOptions) ToHeaders ¶ added in v0.20230307.1085324
func (o CreateOperationOptions) ToHeaders() *client.Headers
func (CreateOperationOptions) ToOData ¶ added in v0.20230307.1085324
func (o CreateOperationOptions) ToOData() *odata.Query
func (CreateOperationOptions) ToQuery ¶ added in v0.20230307.1085324
func (o CreateOperationOptions) ToQuery() *client.QueryParams
type CreateOperationResponse ¶
type CrossSiteAccessPolicies ¶
type DeleteOperationResponse ¶
type ErrorAdditionalInfo ¶
type ErrorAdditionalInfo struct { Info *interface{} `json:"info,omitempty"` Type *string `json:"type,omitempty"` }
type ErrorDetail ¶
type ErrorDetail struct { AdditionalInfo *[]ErrorAdditionalInfo `json:"additionalInfo,omitempty"` Code *string `json:"code,omitempty"` Details *[]ErrorDetail `json:"details,omitempty"` Message *string `json:"message,omitempty"` Target *string `json:"target,omitempty"` }
type GetOperationResponse ¶
type GetOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *StreamingEndpoint }
type IPAccessControl ¶
type IPAccessControl struct {
Allow *[]IPRange `json:"allow,omitempty"`
}
type ListCompleteResult ¶
type ListCompleteResult struct { LatestHttpResponse *http.Response Items []StreamingEndpoint }
type ListOperationResponse ¶
type ListOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *[]StreamingEndpoint }
type MediaServiceId ¶
type MediaServiceId struct { SubscriptionId string ResourceGroupName string MediaServiceName string }
MediaServiceId is a struct representing the Resource ID for a Media Service
func NewMediaServiceID ¶
func NewMediaServiceID(subscriptionId string, resourceGroupName string, mediaServiceName string) MediaServiceId
NewMediaServiceID returns a new MediaServiceId struct
func ParseMediaServiceID ¶
func ParseMediaServiceID(input string) (*MediaServiceId, error)
ParseMediaServiceID parses 'input' into a MediaServiceId
func ParseMediaServiceIDInsensitively ¶
func ParseMediaServiceIDInsensitively(input string) (*MediaServiceId, error)
ParseMediaServiceIDInsensitively parses 'input' case-insensitively into a MediaServiceId note: this method should only be used for API response data and not user input
func (*MediaServiceId) FromParseResult ¶ added in v0.20231127.1171502
func (id *MediaServiceId) FromParseResult(input resourceids.ParseResult) error
func (MediaServiceId) ID ¶
func (id MediaServiceId) ID() string
ID returns the formatted Media Service ID
func (MediaServiceId) Segments ¶
func (id MediaServiceId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Media Service ID
func (MediaServiceId) String ¶
func (id MediaServiceId) String() string
String returns a human-readable description of this Media Service ID
type ScaleOperationResponse ¶
type SkusOperationResponse ¶
type SkusOperationResponse struct { HttpResponse *http.Response OData *odata.OData Model *StreamingEndpointSkuInfoListResult }
type StartOperationResponse ¶
type StopOperationResponse ¶
type StreamingEndpoint ¶
type StreamingEndpoint struct { Id *string `json:"id,omitempty"` Location string `json:"location"` Name *string `json:"name,omitempty"` Properties *StreamingEndpointProperties `json:"properties,omitempty"` Sku *ArmStreamingEndpointCurrentSku `json:"sku,omitempty"` SystemData *systemdata.SystemData `json:"systemData,omitempty"` Tags *map[string]string `json:"tags,omitempty"` Type *string `json:"type,omitempty"` }
type StreamingEndpointAccessControl ¶
type StreamingEndpointAccessControl struct { Akamai *AkamaiAccessControl `json:"akamai,omitempty"` IP *IPAccessControl `json:"ip,omitempty"` }
type StreamingEndpointId ¶
type StreamingEndpointId struct { SubscriptionId string ResourceGroupName string MediaServiceName string StreamingEndpointName string }
StreamingEndpointId is a struct representing the Resource ID for a Streaming Endpoint
func NewStreamingEndpointID ¶
func NewStreamingEndpointID(subscriptionId string, resourceGroupName string, mediaServiceName string, streamingEndpointName string) StreamingEndpointId
NewStreamingEndpointID returns a new StreamingEndpointId struct
func ParseStreamingEndpointID ¶
func ParseStreamingEndpointID(input string) (*StreamingEndpointId, error)
ParseStreamingEndpointID parses 'input' into a StreamingEndpointId
func ParseStreamingEndpointIDInsensitively ¶
func ParseStreamingEndpointIDInsensitively(input string) (*StreamingEndpointId, error)
ParseStreamingEndpointIDInsensitively parses 'input' case-insensitively into a StreamingEndpointId note: this method should only be used for API response data and not user input
func (*StreamingEndpointId) FromParseResult ¶ added in v0.20231127.1171502
func (id *StreamingEndpointId) FromParseResult(input resourceids.ParseResult) error
func (StreamingEndpointId) ID ¶
func (id StreamingEndpointId) ID() string
ID returns the formatted Streaming Endpoint ID
func (StreamingEndpointId) Segments ¶
func (id StreamingEndpointId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Streaming Endpoint ID
func (StreamingEndpointId) String ¶
func (id StreamingEndpointId) String() string
String returns a human-readable description of this Streaming Endpoint ID
type StreamingEndpointOperationId ¶
type StreamingEndpointOperationId struct { SubscriptionId string ResourceGroupName string MediaServiceName string OperationId string }
StreamingEndpointOperationId is a struct representing the Resource ID for a Streaming Endpoint Operation
func NewStreamingEndpointOperationID ¶
func NewStreamingEndpointOperationID(subscriptionId string, resourceGroupName string, mediaServiceName string, operationId string) StreamingEndpointOperationId
NewStreamingEndpointOperationID returns a new StreamingEndpointOperationId struct
func ParseStreamingEndpointOperationID ¶
func ParseStreamingEndpointOperationID(input string) (*StreamingEndpointOperationId, error)
ParseStreamingEndpointOperationID parses 'input' into a StreamingEndpointOperationId
func ParseStreamingEndpointOperationIDInsensitively ¶
func ParseStreamingEndpointOperationIDInsensitively(input string) (*StreamingEndpointOperationId, error)
ParseStreamingEndpointOperationIDInsensitively parses 'input' case-insensitively into a StreamingEndpointOperationId note: this method should only be used for API response data and not user input
func (*StreamingEndpointOperationId) FromParseResult ¶ added in v0.20231127.1171502
func (id *StreamingEndpointOperationId) FromParseResult(input resourceids.ParseResult) error
func (StreamingEndpointOperationId) ID ¶
func (id StreamingEndpointOperationId) ID() string
ID returns the formatted Streaming Endpoint Operation ID
func (StreamingEndpointOperationId) Segments ¶
func (id StreamingEndpointOperationId) Segments() []resourceids.Segment
Segments returns a slice of Resource ID Segments which comprise this Streaming Endpoint Operation ID
func (StreamingEndpointOperationId) String ¶
func (id StreamingEndpointOperationId) String() string
String returns a human-readable description of this Streaming Endpoint Operation ID
type StreamingEndpointOperationPredicate ¶
type StreamingEndpointOperationPredicate struct { Id *string Location *string Name *string Type *string }
func (StreamingEndpointOperationPredicate) Matches ¶
func (p StreamingEndpointOperationPredicate) Matches(input StreamingEndpoint) bool
type StreamingEndpointProperties ¶
type StreamingEndpointProperties struct { AccessControl *StreamingEndpointAccessControl `json:"accessControl,omitempty"` AvailabilitySetName *string `json:"availabilitySetName,omitempty"` CdnEnabled *bool `json:"cdnEnabled,omitempty"` CdnProfile *string `json:"cdnProfile,omitempty"` CdnProvider *string `json:"cdnProvider,omitempty"` Created *string `json:"created,omitempty"` CrossSiteAccessPolicies *CrossSiteAccessPolicies `json:"crossSiteAccessPolicies,omitempty"` CustomHostNames *[]string `json:"customHostNames,omitempty"` Description *string `json:"description,omitempty"` FreeTrialEndTime *string `json:"freeTrialEndTime,omitempty"` HostName *string `json:"hostName,omitempty"` LastModified *string `json:"lastModified,omitempty"` MaxCacheAge *int64 `json:"maxCacheAge,omitempty"` ProvisioningState *string `json:"provisioningState,omitempty"` ResourceState *StreamingEndpointResourceState `json:"resourceState,omitempty"` ScaleUnits int64 `json:"scaleUnits"` }
func (*StreamingEndpointProperties) GetCreatedAsTime ¶
func (o *StreamingEndpointProperties) GetCreatedAsTime() (*time.Time, error)
func (*StreamingEndpointProperties) GetFreeTrialEndTimeAsTime ¶
func (o *StreamingEndpointProperties) GetFreeTrialEndTimeAsTime() (*time.Time, error)
func (*StreamingEndpointProperties) GetLastModifiedAsTime ¶
func (o *StreamingEndpointProperties) GetLastModifiedAsTime() (*time.Time, error)
func (*StreamingEndpointProperties) SetCreatedAsTime ¶
func (o *StreamingEndpointProperties) SetCreatedAsTime(input time.Time)
func (*StreamingEndpointProperties) SetFreeTrialEndTimeAsTime ¶
func (o *StreamingEndpointProperties) SetFreeTrialEndTimeAsTime(input time.Time)
func (*StreamingEndpointProperties) SetLastModifiedAsTime ¶
func (o *StreamingEndpointProperties) SetLastModifiedAsTime(input time.Time)
type StreamingEndpointResourceState ¶
type StreamingEndpointResourceState string
const ( StreamingEndpointResourceStateDeleting StreamingEndpointResourceState = "Deleting" StreamingEndpointResourceStateRunning StreamingEndpointResourceState = "Running" StreamingEndpointResourceStateScaling StreamingEndpointResourceState = "Scaling" StreamingEndpointResourceStateStarting StreamingEndpointResourceState = "Starting" StreamingEndpointResourceStateStopped StreamingEndpointResourceState = "Stopped" StreamingEndpointResourceStateStopping StreamingEndpointResourceState = "Stopping" )
func (*StreamingEndpointResourceState) UnmarshalJSON ¶ added in v0.20230406.1124617
func (s *StreamingEndpointResourceState) UnmarshalJSON(bytes []byte) error
type StreamingEndpointSkuInfoListResult ¶
type StreamingEndpointSkuInfoListResult struct {
Value *[]ArmStreamingEndpointSkuInfo `json:"value,omitempty"`
}
type StreamingEndpointsClient ¶
type StreamingEndpointsClient struct {
Client *resourcemanager.Client
}
func NewStreamingEndpointsClientWithBaseURI ¶
func NewStreamingEndpointsClientWithBaseURI(sdkApi sdkEnv.Api) (*StreamingEndpointsClient, error)
func (StreamingEndpointsClient) AsyncOperation ¶
func (c StreamingEndpointsClient) AsyncOperation(ctx context.Context, id StreamingEndpointOperationId) (result AsyncOperationOperationResponse, err error)
AsyncOperation ...
func (StreamingEndpointsClient) Create ¶
func (c StreamingEndpointsClient) Create(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint, options CreateOperationOptions) (result CreateOperationResponse, err error)
Create ...
func (StreamingEndpointsClient) CreateThenPoll ¶
func (c StreamingEndpointsClient) CreateThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint, options CreateOperationOptions) error
CreateThenPoll performs Create then polls until it's completed
func (StreamingEndpointsClient) Delete ¶
func (c StreamingEndpointsClient) Delete(ctx context.Context, id StreamingEndpointId) (result DeleteOperationResponse, err error)
Delete ...
func (StreamingEndpointsClient) DeleteThenPoll ¶
func (c StreamingEndpointsClient) DeleteThenPoll(ctx context.Context, id StreamingEndpointId) error
DeleteThenPoll performs Delete then polls until it's completed
func (StreamingEndpointsClient) Get ¶
func (c StreamingEndpointsClient) Get(ctx context.Context, id StreamingEndpointId) (result GetOperationResponse, err error)
Get ...
func (StreamingEndpointsClient) List ¶
func (c StreamingEndpointsClient) List(ctx context.Context, id MediaServiceId) (result ListOperationResponse, err error)
List ...
func (StreamingEndpointsClient) ListComplete ¶
func (c StreamingEndpointsClient) ListComplete(ctx context.Context, id MediaServiceId) (ListCompleteResult, error)
ListComplete retrieves all the results into a single object
func (StreamingEndpointsClient) ListCompleteMatchingPredicate ¶
func (c StreamingEndpointsClient) ListCompleteMatchingPredicate(ctx context.Context, id MediaServiceId, predicate StreamingEndpointOperationPredicate) (result ListCompleteResult, err error)
ListCompleteMatchingPredicate retrieves all the results and then applies the predicate
func (StreamingEndpointsClient) Scale ¶
func (c StreamingEndpointsClient) Scale(ctx context.Context, id StreamingEndpointId, input StreamingEntityScaleUnit) (result ScaleOperationResponse, err error)
Scale ...
func (StreamingEndpointsClient) ScaleThenPoll ¶
func (c StreamingEndpointsClient) ScaleThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEntityScaleUnit) error
ScaleThenPoll performs Scale then polls until it's completed
func (StreamingEndpointsClient) Skus ¶
func (c StreamingEndpointsClient) Skus(ctx context.Context, id StreamingEndpointId) (result SkusOperationResponse, err error)
Skus ...
func (StreamingEndpointsClient) Start ¶
func (c StreamingEndpointsClient) Start(ctx context.Context, id StreamingEndpointId) (result StartOperationResponse, err error)
Start ...
func (StreamingEndpointsClient) StartThenPoll ¶
func (c StreamingEndpointsClient) StartThenPoll(ctx context.Context, id StreamingEndpointId) error
StartThenPoll performs Start then polls until it's completed
func (StreamingEndpointsClient) Stop ¶
func (c StreamingEndpointsClient) Stop(ctx context.Context, id StreamingEndpointId) (result StopOperationResponse, err error)
Stop ...
func (StreamingEndpointsClient) StopThenPoll ¶
func (c StreamingEndpointsClient) StopThenPoll(ctx context.Context, id StreamingEndpointId) error
StopThenPoll performs Stop then polls until it's completed
func (StreamingEndpointsClient) Update ¶ added in v0.20230214.1122756
func (c StreamingEndpointsClient) Update(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint) (result UpdateOperationResponse, err error)
Update ...
func (StreamingEndpointsClient) UpdateThenPoll ¶ added in v0.20230214.1122756
func (c StreamingEndpointsClient) UpdateThenPoll(ctx context.Context, id StreamingEndpointId, input StreamingEndpoint) error
UpdateThenPoll performs Update then polls until it's completed
type StreamingEntityScaleUnit ¶
type StreamingEntityScaleUnit struct {
ScaleUnit *int64 `json:"scaleUnit,omitempty"`
}
type UpdateOperationResponse ¶ added in v0.20230214.1122756
Source Files ¶
- client.go
- constants.go
- id_mediaservice.go
- id_streamingendpoint.go
- id_streamingendpointoperation.go
- method_asyncoperation.go
- method_create.go
- method_delete.go
- method_get.go
- method_list.go
- method_scale.go
- method_skus.go
- method_start.go
- method_stop.go
- method_update.go
- model_akamaiaccesscontrol.go
- model_akamaisignatureheaderauthenticationkey.go
- model_armstreamingendpointcapacity.go
- model_armstreamingendpointcurrentsku.go
- model_armstreamingendpointsku.go
- model_armstreamingendpointskuinfo.go
- model_asyncoperationresult.go
- model_crosssiteaccesspolicies.go
- model_erroradditionalinfo.go
- model_errordetail.go
- model_ipaccesscontrol.go
- model_iprange.go
- model_streamingendpoint.go
- model_streamingendpointaccesscontrol.go
- model_streamingendpointproperties.go
- model_streamingendpointskuinfolistresult.go
- model_streamingentityscaleunit.go
- predicates.go
- version.go