Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 api.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package mediastoredata import ( "fmt" "io" "time" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/aws/signer/v4" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/restjson" ) const opDeleteObject = "DeleteObject" // DeleteObjectRequest generates a "aws/request.Request" representing the // client's request for the DeleteObject operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DeleteObject for more information on using the DeleteObject // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DeleteObjectRequest method. // req, resp := client.DeleteObjectRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/DeleteObject func (c MediaStoreData) DeleteObjectRequest(input DeleteObjectInput) (req request.Request, output DeleteObjectOutput) { op := &request.Operation{ Name: opDeleteObject, HTTPMethod: "DELETE", HTTPPath: "/{Path+}", } if input == nil { input = &DeleteObjectInput{} } output = &DeleteObjectOutput{} req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler) return } // DeleteObject API operation for AWS Elemental MediaStore Data Plane. // // Deletes an object at the specified path. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS Elemental MediaStore Data Plane's // API operation DeleteObject for usage and error information. // // Returned Error Types: // // - ContainerNotFoundException // The specified container was not found for the specified account. // // - ObjectNotFoundException // Could not perform an operation on an object that does not exist. // // - InternalServerError // The service is temporarily unavailable. // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/DeleteObject func (c MediaStoreData) DeleteObject(input DeleteObjectInput) (DeleteObjectOutput, error) { req, out := c.DeleteObjectRequest(input) return out, req.Send() } // DeleteObjectWithContext is the same as DeleteObject with the addition of // the ability to pass a context and additional request options. // // See DeleteObject for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) DeleteObjectWithContext(ctx aws.Context, input DeleteObjectInput, opts ...request.Option) (DeleteObjectOutput, error) { req, out := c.DeleteObjectRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opDescribeObject = "DescribeObject" // DescribeObjectRequest generates a "aws/request.Request" representing the // client's request for the DescribeObject operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See DescribeObject for more information on using the DescribeObject // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the DescribeObjectRequest method. // req, resp := client.DescribeObjectRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/DescribeObject func (c MediaStoreData) DescribeObjectRequest(input DescribeObjectInput) (req request.Request, output DescribeObjectOutput) { op := &request.Operation{ Name: opDescribeObject, HTTPMethod: "HEAD", HTTPPath: "/{Path+}", } if input == nil { input = &DescribeObjectInput{} } output = &DescribeObjectOutput{} req = c.newRequest(op, input, output) return } // DescribeObject API operation for AWS Elemental MediaStore Data Plane. // // Gets the headers for an object at the specified path. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS Elemental MediaStore Data Plane's // API operation DescribeObject for usage and error information. // // Returned Error Types: // // - ContainerNotFoundException // The specified container was not found for the specified account. // // - ObjectNotFoundException // Could not perform an operation on an object that does not exist. // // - InternalServerError // The service is temporarily unavailable. // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/DescribeObject func (c MediaStoreData) DescribeObject(input DescribeObjectInput) (DescribeObjectOutput, error) { req, out := c.DescribeObjectRequest(input) return out, req.Send() } // DescribeObjectWithContext is the same as DescribeObject with the addition of // the ability to pass a context and additional request options. // // See DescribeObject for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) DescribeObjectWithContext(ctx aws.Context, input DescribeObjectInput, opts ...request.Option) (DescribeObjectOutput, error) { req, out := c.DescribeObjectRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetObject = "GetObject" // GetObjectRequest generates a "aws/request.Request" representing the // client's request for the GetObject operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetObject for more information on using the GetObject // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetObjectRequest method. // req, resp := client.GetObjectRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/GetObject func (c MediaStoreData) GetObjectRequest(input GetObjectInput) (req request.Request, output GetObjectOutput) { op := &request.Operation{ Name: opGetObject, HTTPMethod: "GET", HTTPPath: "/{Path+}", } if input == nil { input = &GetObjectInput{} } output = &GetObjectOutput{} req = c.newRequest(op, input, output) return } // GetObject API operation for AWS Elemental MediaStore Data Plane. // // Downloads the object at the specified path. If the object’s upload availability // is set to streaming, AWS Elemental MediaStore downloads the object even if // it’s still uploading the object. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS Elemental MediaStore Data Plane's // API operation GetObject for usage and error information. // // Returned Error Types: // // - ContainerNotFoundException // The specified container was not found for the specified account. // // - ObjectNotFoundException // Could not perform an operation on an object that does not exist. // // - RequestedRangeNotSatisfiableException // The requested content range is not valid. // // - InternalServerError // The service is temporarily unavailable. // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/GetObject func (c MediaStoreData) GetObject(input GetObjectInput) (GetObjectOutput, error) { req, out := c.GetObjectRequest(input) return out, req.Send() } // GetObjectWithContext is the same as GetObject with the addition of // the ability to pass a context and additional request options. // // See GetObject for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) GetObjectWithContext(ctx aws.Context, input GetObjectInput, opts ...request.Option) (GetObjectOutput, error) { req, out := c.GetObjectRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListItems = "ListItems" // ListItemsRequest generates a "aws/request.Request" representing the // client's request for the ListItems operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListItems for more information on using the ListItems // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListItemsRequest method. // req, resp := client.ListItemsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/ListItems func (c MediaStoreData) ListItemsRequest(input ListItemsInput) (req request.Request, output ListItemsOutput) { op := &request.Operation{ Name: opListItems, HTTPMethod: "GET", HTTPPath: "/", Paginator: &request.Paginator{ InputTokens: []string{"NextToken"}, OutputTokens: []string{"NextToken"}, LimitToken: "MaxResults", TruncationToken: "", }, } if input == nil { input = &ListItemsInput{} } output = &ListItemsOutput{} req = c.newRequest(op, input, output) return } // ListItems API operation for AWS Elemental MediaStore Data Plane. // // Provides a list of metadata entries about folders and objects in the specified // folder. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS Elemental MediaStore Data Plane's // API operation ListItems for usage and error information. // // Returned Error Types: // // - ContainerNotFoundException // The specified container was not found for the specified account. // // - InternalServerError // The service is temporarily unavailable. // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/ListItems func (c MediaStoreData) ListItems(input ListItemsInput) (ListItemsOutput, error) { req, out := c.ListItemsRequest(input) return out, req.Send() } // ListItemsWithContext is the same as ListItems with the addition of // the ability to pass a context and additional request options. // // See ListItems for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) ListItemsWithContext(ctx aws.Context, input ListItemsInput, opts ...request.Option) (ListItemsOutput, error) { req, out := c.ListItemsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListItemsPages iterates over the pages of a ListItems operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListItems method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListItems operation. // pageNum := 0 // err := client.ListItemsPages(params, // func(page mediastoredata.ListItemsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c MediaStoreData) ListItemsPages(input ListItemsInput, fn func(ListItemsOutput, bool) bool) error { return c.ListItemsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListItemsPagesWithContext same as ListItemsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) ListItemsPagesWithContext(ctx aws.Context, input ListItemsInput, fn func(ListItemsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (request.Request, error) { var inCpy ListItemsInput if input != nil { tmp := input inCpy = &tmp } req, _ := c.ListItemsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(ListItemsOutput), !p.HasNextPage()) { break } } return p.Err() } const opPutObject = "PutObject" // PutObjectRequest generates a "aws/request.Request" representing the // client's request for the PutObject operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See PutObject for more information on using the PutObject // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the PutObjectRequest method. // req, resp := client.PutObjectRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/PutObject func (c MediaStoreData) PutObjectRequest(input PutObjectInput) (req request.Request, output PutObjectOutput) { op := &request.Operation{ Name: opPutObject, HTTPMethod: "PUT", HTTPPath: "/{Path+}", } if input == nil { input = &PutObjectInput{} } output = &PutObjectOutput{} req = c.newRequest(op, input, output) req.Handlers.Sign.Remove(v4.SignRequestHandler) handler := v4.BuildNamedHandler("v4.CustomSignerHandler", v4.WithUnsignedPayload) req.Handlers.Sign.PushFrontNamed(handler) return } // PutObject API operation for AWS Elemental MediaStore Data Plane. // // Uploads an object to the specified path. Object sizes are limited to 25 MB // for standard upload availability and 10 MB for streaming upload availability. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for AWS Elemental MediaStore Data Plane's // API operation PutObject for usage and error information. // // Returned Error Types: // // - ContainerNotFoundException // The specified container was not found for the specified account. // // - InternalServerError // The service is temporarily unavailable. // // See also, https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01/PutObject func (c MediaStoreData) PutObject(input PutObjectInput) (PutObjectOutput, error) { req, out := c.PutObjectRequest(input) return out, req.Send() } // PutObjectWithContext is the same as PutObject with the addition of // the ability to pass a context and additional request options. // // See PutObject for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c MediaStoreData) PutObjectWithContext(ctx aws.Context, input PutObjectInput, opts ...request.Option) (PutObjectOutput, error) { req, out := c.PutObjectRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // The specified container was not found for the specified account. type ContainerNotFoundException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ContainerNotFoundException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ContainerNotFoundException) GoString() string { return s.String() } func newErrorContainerNotFoundException(v protocol.ResponseMetadata) error { return &ContainerNotFoundException{ RespMetadata: v, } } // Code returns the exception type name. func (s ContainerNotFoundException) Code() string { return "ContainerNotFoundException" } // Message returns the exception's message. func (s ContainerNotFoundException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ContainerNotFoundException) OrigErr() error { return nil } func (s ContainerNotFoundException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ContainerNotFoundException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ContainerNotFoundException) RequestID() string { return s.RespMetadata.RequestID } type DeleteObjectInput struct { _ struct{} `type:"structure" nopayload:"true"` // The path (including the file name) where the object is stored in the container. // Format: <folder name>/<folder name>/<file name> // // Path is a required field Path string `location:"uri" locationName:"Path" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteObjectInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteObjectInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DeleteObjectInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteObjectInput"} if s.Path == nil { invalidParams.Add(request.NewErrParamRequired("Path")) } if s.Path != nil && len(s.Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("Path", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetPath sets the Path field's value. func (s DeleteObjectInput) SetPath(v string) DeleteObjectInput { s.Path = &v return s } type DeleteObjectOutput struct { _ struct{} `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteObjectOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DeleteObjectOutput) GoString() string { return s.String() } type DescribeObjectInput struct { _ struct{} `type:"structure" nopayload:"true"` // The path (including the file name) where the object is stored in the container. // Format: <folder name>/<folder name>/<file name> // // Path is a required field Path string `location:"uri" locationName:"Path" min:"1" type:"string" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DescribeObjectInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DescribeObjectInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s DescribeObjectInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DescribeObjectInput"} if s.Path == nil { invalidParams.Add(request.NewErrParamRequired("Path")) } if s.Path != nil && len(s.Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("Path", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetPath sets the Path field's value. func (s DescribeObjectInput) SetPath(v string) DescribeObjectInput { s.Path = &v return s } type DescribeObjectOutput struct { _ struct{} `type:"structure"` // An optional CacheControl header that allows the caller to control the object's // cache behavior. Headers can be passed in as specified in the HTTP at https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9 // (https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9). // // Headers with a custom user-defined value are also accepted. CacheControl string `location:"header" locationName:"Cache-Control" type:"string"` // The length of the object in bytes. ContentLength int64 `location:"header" locationName:"Content-Length" type:"long"` // The content type of the object. ContentType string `location:"header" locationName:"Content-Type" type:"string"` // The ETag that represents a unique instance of the object. ETag string `location:"header" locationName:"ETag" min:"1" type:"string"` // The date and time that the object was last modified. LastModified time.Time `location:"header" locationName:"Last-Modified" type:"timestamp"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DescribeObjectOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DescribeObjectOutput) GoString() string { return s.String() } // SetCacheControl sets the CacheControl field's value. func (s DescribeObjectOutput) SetCacheControl(v string) DescribeObjectOutput { s.CacheControl = &v return s } // SetContentLength sets the ContentLength field's value. func (s DescribeObjectOutput) SetContentLength(v int64) DescribeObjectOutput { s.ContentLength = &v return s } // SetContentType sets the ContentType field's value. func (s DescribeObjectOutput) SetContentType(v string) DescribeObjectOutput { s.ContentType = &v return s } // SetETag sets the ETag field's value. func (s DescribeObjectOutput) SetETag(v string) DescribeObjectOutput { s.ETag = &v return s } // SetLastModified sets the LastModified field's value. func (s DescribeObjectOutput) SetLastModified(v time.Time) DescribeObjectOutput { s.LastModified = &v return s } type GetObjectInput struct { _ struct{} `type:"structure" nopayload:"true"` // The path (including the file name) where the object is stored in the container. // Format: <folder name>/<folder name>/<file name> // // For example, to upload the file mlaw.avi to the folder path premium\canada // in the container movies, enter the path premium/canada/mlaw.avi. // // Do not include the container name in this path. // // If the path includes any folders that don't exist yet, the service creates // them. For example, suppose you have an existing premium/usa subfolder. If // you specify premium/canada, the service creates a canada subfolder in the // premium folder. You then have two subfolders, usa and canada, in the premium // folder. // // There is no correlation between the path to the source and the path (folders) // in the container in AWS Elemental MediaStore. // // For more information about folders and how they exist in a container, see // the AWS Elemental MediaStore User Guide (http://docs.aws.amazon.com/mediastore/latest/ug/). // // The file name is the name that is assigned to the file that you upload. The // file can have the same name inside and outside of AWS Elemental MediaStore, // or it can have the same name. The file name can include or omit an extension. // // Path is a required field Path string `location:"uri" locationName:"Path" min:"1" type:"string" required:"true"` // The range bytes of an object to retrieve. For more information about the // Range header, see http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.35 // (http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.35). AWS Elemental // MediaStore ignores this header for partially uploaded objects that have streaming // upload availability. Range string `location:"header" locationName:"Range" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetObjectInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetObjectInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetObjectInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetObjectInput"} if s.Path == nil { invalidParams.Add(request.NewErrParamRequired("Path")) } if s.Path != nil && len(s.Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("Path", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetPath sets the Path field's value. func (s GetObjectInput) SetPath(v string) GetObjectInput { s.Path = &v return s } // SetRange sets the Range field's value. func (s GetObjectInput) SetRange(v string) GetObjectInput { s.Range = &v return s } type GetObjectOutput struct { _ struct{} `type:"structure" payload:"Body"` // The bytes of the object. Body io.ReadCloser `type:"blob"` // An optional CacheControl header that allows the caller to control the object's // cache behavior. Headers can be passed in as specified in the HTTP spec at // https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9 (https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9). // // Headers with a custom user-defined value are also accepted. CacheControl string `location:"header" locationName:"Cache-Control" type:"string"` // The length of the object in bytes. ContentLength int64 `location:"header" locationName:"Content-Length" type:"long"` // The range of bytes to retrieve. ContentRange string `location:"header" locationName:"Content-Range" type:"string"` // The content type of the object. ContentType string `location:"header" locationName:"Content-Type" type:"string"` // The ETag that represents a unique instance of the object. ETag string `location:"header" locationName:"ETag" min:"1" type:"string"` // The date and time that the object was last modified. LastModified time.Time `location:"header" locationName:"Last-Modified" type:"timestamp"` // The HTML status code of the request. Status codes ranging from 200 to 299 // indicate success. All other status codes indicate the type of error that // occurred. // // StatusCode is a required field StatusCode int64 `location:"statusCode" type:"integer" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetObjectOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetObjectOutput) GoString() string { return s.String() } // SetBody sets the Body field's value. func (s GetObjectOutput) SetBody(v io.ReadCloser) GetObjectOutput { s.Body = v return s } // SetCacheControl sets the CacheControl field's value. func (s GetObjectOutput) SetCacheControl(v string) GetObjectOutput { s.CacheControl = &v return s } // SetContentLength sets the ContentLength field's value. func (s GetObjectOutput) SetContentLength(v int64) GetObjectOutput { s.ContentLength = &v return s } // SetContentRange sets the ContentRange field's value. func (s GetObjectOutput) SetContentRange(v string) GetObjectOutput { s.ContentRange = &v return s } // SetContentType sets the ContentType field's value. func (s GetObjectOutput) SetContentType(v string) GetObjectOutput { s.ContentType = &v return s } // SetETag sets the ETag field's value. func (s GetObjectOutput) SetETag(v string) GetObjectOutput { s.ETag = &v return s } // SetLastModified sets the LastModified field's value. func (s GetObjectOutput) SetLastModified(v time.Time) GetObjectOutput { s.LastModified = &v return s } // SetStatusCode sets the StatusCode field's value. func (s GetObjectOutput) SetStatusCode(v int64) GetObjectOutput { s.StatusCode = &v return s } // The service is temporarily unavailable. type InternalServerError struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InternalServerError) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InternalServerError) GoString() string { return s.String() } func newErrorInternalServerError(v protocol.ResponseMetadata) error { return &InternalServerError{ RespMetadata: v, } } // Code returns the exception type name. func (s InternalServerError) Code() string { return "InternalServerError" } // Message returns the exception's message. func (s InternalServerError) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InternalServerError) OrigErr() error { return nil } func (s InternalServerError) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InternalServerError) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InternalServerError) RequestID() string { return s.RespMetadata.RequestID } // A metadata entry for a folder or object. type Item struct { _ struct{} `type:"structure"` // The length of the item in bytes. ContentLength int64 `type:"long"` // The content type of the item. ContentType string `type:"string"` // The ETag that represents a unique instance of the item. ETag string `min:"1" type:"string"` // The date and time that the item was last modified. LastModified time.Time `type:"timestamp"` // The name of the item. Name string `type:"string"` // The item type (folder or object). Type string `type:"string" enum:"ItemType"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Item) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Item) GoString() string { return s.String() } // SetContentLength sets the ContentLength field's value. func (s Item) SetContentLength(v int64) Item { s.ContentLength = &v return s } // SetContentType sets the ContentType field's value. func (s Item) SetContentType(v string) Item { s.ContentType = &v return s } // SetETag sets the ETag field's value. func (s Item) SetETag(v string) Item { s.ETag = &v return s } // SetLastModified sets the LastModified field's value. func (s Item) SetLastModified(v time.Time) Item { s.LastModified = &v return s } // SetName sets the Name field's value. func (s Item) SetName(v string) Item { s.Name = &v return s } // SetType sets the Type field's value. func (s Item) SetType(v string) Item { s.Type = &v return s } type ListItemsInput struct { _ struct{} `type:"structure" nopayload:"true"` // The maximum number of results to return per API request. For example, you // submit a ListItems request with MaxResults set at 500. Although 2,000 items // match your request, the service returns no more than the first 500 items. // (The service also returns a NextToken value that you can use to fetch the // next batch of results.) The service might return fewer results than the MaxResults // value. // // If MaxResults is not included in the request, the service defaults to pagination // with a maximum of 1,000 results per page. MaxResults int64 `location:"querystring" locationName:"MaxResults" min:"1" type:"integer"` // The token that identifies which batch of results that you want to see. For // example, you submit a ListItems request with MaxResults set at 500. The service // returns the first batch of results (up to 500) and a NextToken value. To // see the next batch of results, you can submit the ListItems request a second // time and specify the NextToken value. // // Tokens expire after 15 minutes. NextToken string `location:"querystring" locationName:"NextToken" type:"string"` // The path in the container from which to retrieve items. Format: <folder name>/<folder // name>/<file name> Path string `location:"querystring" locationName:"Path" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListItemsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListItemsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ListItemsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListItemsInput"} if s.MaxResults != nil && s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetMaxResults sets the MaxResults field's value. func (s ListItemsInput) SetMaxResults(v int64) ListItemsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s ListItemsInput) SetNextToken(v string) ListItemsInput { s.NextToken = &v return s } // SetPath sets the Path field's value. func (s ListItemsInput) SetPath(v string) ListItemsInput { s.Path = &v return s } type ListItemsOutput struct { _ struct{} `type:"structure"` // The metadata entries for the folders and objects at the requested path. Items []Item `type:"list"` // The token that can be used in a request to view the next set of results. // For example, you submit a ListItems request that matches 2,000 items with // MaxResults set at 500. The service returns the first batch of results (up // to 500) and a NextToken value that can be used to fetch the next batch of // results. NextToken string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListItemsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListItemsOutput) GoString() string { return s.String() } // SetItems sets the Items field's value. func (s ListItemsOutput) SetItems(v []Item) ListItemsOutput { s.Items = v return s } // SetNextToken sets the NextToken field's value. func (s ListItemsOutput) SetNextToken(v string) ListItemsOutput { s.NextToken = &v return s } // Could not perform an operation on an object that does not exist. type ObjectNotFoundException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ObjectNotFoundException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ObjectNotFoundException) GoString() string { return s.String() } func newErrorObjectNotFoundException(v protocol.ResponseMetadata) error { return &ObjectNotFoundException{ RespMetadata: v, } } // Code returns the exception type name. func (s ObjectNotFoundException) Code() string { return "ObjectNotFoundException" } // Message returns the exception's message. func (s ObjectNotFoundException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ObjectNotFoundException) OrigErr() error { return nil } func (s ObjectNotFoundException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ObjectNotFoundException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ObjectNotFoundException) RequestID() string { return s.RespMetadata.RequestID } type PutObjectInput struct { _ struct{} `type:"structure" payload:"Body"` // The bytes to be stored. // // To use an non-seekable io.Reader for this request wrap the io.Reader with // "aws.ReadSeekCloser". The SDK will not retry request errors for non-seekable // readers. This will allow the SDK to send the reader's payload as chunked // transfer encoding. // // Body is a required field Body io.ReadSeeker `type:"blob" required:"true"` // An optional CacheControl header that allows the caller to control the object's // cache behavior. Headers can be passed in as specified in the HTTP at https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9 // (https://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.9). // // Headers with a custom user-defined value are also accepted. CacheControl string `location:"header" locationName:"Cache-Control" type:"string"` // The content type of the object. ContentType string `location:"header" locationName:"Content-Type" type:"string"` // The path (including the file name) where the object is stored in the container. // Format: <folder name>/<folder name>/<file name> // // For example, to upload the file mlaw.avi to the folder path premium\canada // in the container movies, enter the path premium/canada/mlaw.avi. // // Do not include the container name in this path. // // If the path includes any folders that don't exist yet, the service creates // them. For example, suppose you have an existing premium/usa subfolder. If // you specify premium/canada, the service creates a canada subfolder in the // premium folder. You then have two subfolders, usa and canada, in the premium // folder. // // There is no correlation between the path to the source and the path (folders) // in the container in AWS Elemental MediaStore. // // For more information about folders and how they exist in a container, see // the AWS Elemental MediaStore User Guide (http://docs.aws.amazon.com/mediastore/latest/ug/). // // The file name is the name that is assigned to the file that you upload. The // file can have the same name inside and outside of AWS Elemental MediaStore, // or it can have the same name. The file name can include or omit an extension. // // Path is a required field Path string `location:"uri" locationName:"Path" min:"1" type:"string" required:"true"` // Indicates the storage class of a Put request. Defaults to high-performance // temporal storage class, and objects are persisted into durable storage shortly // after being received. StorageClass string `location:"header" locationName:"x-amz-storage-class" min:"1" type:"string" enum:"StorageClass"` // Indicates the availability of an object while it is still uploading. If the // value is set to streaming, the object is available for downloading after // some initial buffering but before the object is uploaded completely. If the // value is set to standard, the object is available for downloading only when // it is uploaded completely. The default value for this header is standard. // // To use this header, you must also set the HTTP Transfer-Encoding header to // chunked. UploadAvailability string `location:"header" locationName:"x-amz-upload-availability" min:"1" type:"string" enum:"UploadAvailability"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PutObjectInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PutObjectInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s PutObjectInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "PutObjectInput"} if s.Body == nil { invalidParams.Add(request.NewErrParamRequired("Body")) } if s.Path == nil { invalidParams.Add(request.NewErrParamRequired("Path")) } if s.Path != nil && len(s.Path) < 1 { invalidParams.Add(request.NewErrParamMinLen("Path", 1)) } if s.StorageClass != nil && len(s.StorageClass) < 1 { invalidParams.Add(request.NewErrParamMinLen("StorageClass", 1)) } if s.UploadAvailability != nil && len(s.UploadAvailability) < 1 { invalidParams.Add(request.NewErrParamMinLen("UploadAvailability", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetBody sets the Body field's value. func (s PutObjectInput) SetBody(v io.ReadSeeker) PutObjectInput { s.Body = v return s } // SetCacheControl sets the CacheControl field's value. func (s PutObjectInput) SetCacheControl(v string) PutObjectInput { s.CacheControl = &v return s } // SetContentType sets the ContentType field's value. func (s PutObjectInput) SetContentType(v string) PutObjectInput { s.ContentType = &v return s } // SetPath sets the Path field's value. func (s PutObjectInput) SetPath(v string) PutObjectInput { s.Path = &v return s } // SetStorageClass sets the StorageClass field's value. func (s PutObjectInput) SetStorageClass(v string) PutObjectInput { s.StorageClass = &v return s } // SetUploadAvailability sets the UploadAvailability field's value. func (s PutObjectInput) SetUploadAvailability(v string) PutObjectInput { s.UploadAvailability = &v return s } type PutObjectOutput struct { _ struct{} `type:"structure"` // The SHA256 digest of the object that is persisted. ContentSHA256 string `min:"64" type:"string"` // Unique identifier of the object in the container. ETag string `min:"1" type:"string"` // The storage class where the object was persisted. The class should be “Temporal”. StorageClass string `min:"1" type:"string" enum:"StorageClass"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PutObjectOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s PutObjectOutput) GoString() string { return s.String() } // SetContentSHA256 sets the ContentSHA256 field's value. func (s PutObjectOutput) SetContentSHA256(v string) PutObjectOutput { s.ContentSHA256 = &v return s } // SetETag sets the ETag field's value. func (s PutObjectOutput) SetETag(v string) PutObjectOutput { s.ETag = &v return s } // SetStorageClass sets the StorageClass field's value. func (s PutObjectOutput) SetStorageClass(v string) PutObjectOutput { s.StorageClass = &v return s } // The requested content range is not valid. type RequestedRangeNotSatisfiableException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RequestedRangeNotSatisfiableException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s RequestedRangeNotSatisfiableException) GoString() string { return s.String() } func newErrorRequestedRangeNotSatisfiableException(v protocol.ResponseMetadata) error { return &RequestedRangeNotSatisfiableException{ RespMetadata: v, } } // Code returns the exception type name. func (s RequestedRangeNotSatisfiableException) Code() string { return "RequestedRangeNotSatisfiableException" } // Message returns the exception's message. func (s RequestedRangeNotSatisfiableException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s RequestedRangeNotSatisfiableException) OrigErr() error { return nil } func (s RequestedRangeNotSatisfiableException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s RequestedRangeNotSatisfiableException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s *RequestedRangeNotSatisfiableException) RequestID() string { return s.RespMetadata.RequestID } const ( // ItemTypeObject is a ItemType enum value ItemTypeObject = "OBJECT" // ItemTypeFolder is a ItemType enum value ItemTypeFolder = "FOLDER" ) // ItemType_Values returns all elements of the ItemType enum func ItemType_Values() []string { return []string{ ItemTypeObject, ItemTypeFolder, } } const ( // StorageClassTemporal is a StorageClass enum value StorageClassTemporal = "TEMPORAL" ) // StorageClass_Values returns all elements of the StorageClass enum func StorageClass_Values() []string { return []string{ StorageClassTemporal, } } const ( // UploadAvailabilityStandard is a UploadAvailability enum value UploadAvailabilityStandard = "STANDARD" // UploadAvailabilityStreaming is a UploadAvailability enum value UploadAvailabilityStreaming = "STREAMING" ) // UploadAvailability_Values returns all elements of the UploadAvailability enum func UploadAvailability_Values() []string { return []string{ UploadAvailabilityStandard, UploadAvailabilityStreaming, } }	52.4 KB	2025-05-25 12:27
📄 doc.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. // Package mediastoredata provides the client and types for making API // requests to AWS Elemental MediaStore Data Plane. // // An AWS Elemental MediaStore asset is an object, similar to an object in the // Amazon S3 service. Objects are the fundamental entities that are stored in // AWS Elemental MediaStore. // // See https://docs.aws.amazon.com/goto/WebAPI/mediastore-data-2017-09-01 for more information on this service. // // See mediastoredata package documentation for more information. // https://docs.aws.amazon.com/sdk-for-go/api/service/mediastoredata/ // // # Using the Client // // To contact AWS Elemental MediaStore Data Plane with the SDK use the New function to create // a new service client. With that client you can make API requests to the service. // These clients are safe to use concurrently. // // See the SDK's documentation for more information on how to use the SDK. // https://docs.aws.amazon.com/sdk-for-go/api/ // // See aws.Config documentation for more information on configuring SDK clients. // https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config // // See the AWS Elemental MediaStore Data Plane client MediaStoreData for more // information on creating client for this service. // https://docs.aws.amazon.com/sdk-for-go/api/service/mediastoredata/#New package mediastoredata	1.35 KB	2025-05-25 12:27
📄 endpoint_example_test.go package mediastoredata_test import ( "fmt" "log" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/mediastore" "github.com/aws/aws-sdk-go/service/mediastoredata" ) func ExampleMediaStoreData_describeEndpoint() { sess, err := session.NewSession(aws.NewConfig()) if err != nil { log.Fatal("Failed to create aws session", err) } // we need to use a MediaStore client to get a media store container endpoint address ctrlSvc := mediastore.New(sess) descResp, err := ctrlSvc.DescribeContainer(&mediastore.DescribeContainerInput{ // specify a container name ContainerName: aws.String("some-container"), }) if err != nil { log.Fatal("failed to get media store container endpoint", err) } // create a MediaStoreData client and use the retrieved container endpoint dataSvc := mediastoredata.New(sess, &aws.Config{ Endpoint: descResp.Container.Endpoint, }) output, err := dataSvc.ListItems(&mediastoredata.ListItemsInput{}) if err != nil { log.Fatal("failed to make mediastoredata API call", err) } // prints the string representation of ListItemsOutput fmt.Println(output.GoString()) }	1.15 KB	2025-05-25 12:27
📄 errors.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package mediastoredata import ( "github.com/aws/aws-sdk-go/private/protocol" ) const ( // ErrCodeContainerNotFoundException for service response error code // "ContainerNotFoundException". // // The specified container was not found for the specified account. ErrCodeContainerNotFoundException = "ContainerNotFoundException" // ErrCodeInternalServerError for service response error code // "InternalServerError". // // The service is temporarily unavailable. ErrCodeInternalServerError = "InternalServerError" // ErrCodeObjectNotFoundException for service response error code // "ObjectNotFoundException". // // Could not perform an operation on an object that does not exist. ErrCodeObjectNotFoundException = "ObjectNotFoundException" // ErrCodeRequestedRangeNotSatisfiableException for service response error code // "RequestedRangeNotSatisfiableException". // // The requested content range is not valid. ErrCodeRequestedRangeNotSatisfiableException = "RequestedRangeNotSatisfiableException" ) var exceptionFromCode = map[string]func(protocol.ResponseMetadata) error{ "ContainerNotFoundException": newErrorContainerNotFoundException, "InternalServerError": newErrorInternalServerError, "ObjectNotFoundException": newErrorObjectNotFoundException, "RequestedRangeNotSatisfiableException": newErrorRequestedRangeNotSatisfiableException, }	1.45 KB	2025-05-25 12:27
📁 mediastoredataiface	-	2025-05-25 12:27
📄 service.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package mediastoredata import ( "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/client" "github.com/aws/aws-sdk-go/aws/client/metadata" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/aws/signer/v4" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/restjson" ) // MediaStoreData provides the API operation methods for making requests to // AWS Elemental MediaStore Data Plane. See this package's package overview docs // for details on the service. // // MediaStoreData methods are safe to use concurrently. It is not safe to // modify mutate any of the struct's properties though. type MediaStoreData struct { client.Client } // Used for custom client initialization logic var initClient func(client.Client) // Used for custom request initialization logic var initRequest func(request.Request) // Service information constants const ( ServiceName = "data.mediastore" // Name of service. EndpointsID = ServiceName // ID to lookup a service endpoint with. ServiceID = "MediaStore Data" // ServiceID is a unique identifier of a specific service. ) // New creates a new instance of the MediaStoreData client with a session. // If additional configuration is needed for the client instance use the optional // aws.Config parameter to add your extra config. // // Example: // // mySession := session.Must(session.NewSession()) // // // Create a MediaStoreData client from just a session. // svc := mediastoredata.New(mySession) // // // Create a MediaStoreData client with additional configuration // svc := mediastoredata.New(mySession, aws.NewConfig().WithRegion("us-west-2")) func New(p client.ConfigProvider, cfgs ...aws.Config) MediaStoreData { c := p.ClientConfig(EndpointsID, cfgs...) if c.SigningNameDerived \|\| len(c.SigningName) == 0 { c.SigningName = "mediastore" } return newClient(c.Config, c.Handlers, c.PartitionID, c.Endpoint, c.SigningRegion, c.SigningName, c.ResolvedRegion) } // newClient creates, initializes and returns a new service client instance. func newClient(cfg aws.Config, handlers request.Handlers, partitionID, endpoint, signingRegion, signingName, resolvedRegion string) MediaStoreData { svc := &MediaStoreData{ Client: client.New( cfg, metadata.ClientInfo{ ServiceName: ServiceName, ServiceID: ServiceID, SigningName: signingName, SigningRegion: signingRegion, PartitionID: partitionID, Endpoint: endpoint, APIVersion: "2017-09-01", ResolvedRegion: resolvedRegion, }, handlers, ), } // Handlers svc.Handlers.Sign.PushBackNamed(v4.SignRequestHandler) svc.Handlers.Build.PushBackNamed(restjson.BuildHandler) svc.Handlers.Unmarshal.PushBackNamed(restjson.UnmarshalHandler) svc.Handlers.UnmarshalMeta.PushBackNamed(restjson.UnmarshalMetaHandler) svc.Handlers.UnmarshalError.PushBackNamed( protocol.NewUnmarshalErrorHandler(restjson.NewUnmarshalTypedError(exceptionFromCode)).NamedHandler(), ) // Run custom client initialization if present if initClient != nil { initClient(svc.Client) } return svc } // newRequest creates a new request for a MediaStoreData operation and runs any // custom request initialization. func (c MediaStoreData) newRequest(op request.Operation, params, data interface{}) request.Request { req := c.NewRequest(op, params, data) // Run custom request initialization if present if initRequest != nil { initRequest(req) } return req }	3.49 KB	2025-05-25 12:27

Terminal