Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1141 - 1150 of 1,425 for Func (0.02 sec)

  1. internal/ioutil/append-file_nix.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package ioutil
    
    import (
    	"io"
    	"os"
    )
    
    // AppendFile - appends the file "src" to the file "dst"
    func AppendFile(dst string, src string, osync bool) error {
    	flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE
    	if osync {
    		flags |= os.O_SYNC
    	}
    	appendFile, err := os.OpenFile(dst, flags, 0o666)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  2. internal/grid/trace.go

    // traceRequests adds request tracing to the connection.
    func (c *Connection) traceRequests(p *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	c.trace = &tracer{
    		Publisher: p,
    		TraceType: madmin.TraceInternal,
    		Prefix:    "grid",
    		Local:     c.Local,
    		Remote:    c.Remote,
    		Subroute:  "",
    	}
    }
    
    // subroute adds a specific subroute to the request.
    func (c *tracer) subroute(subroute string) *tracer {
    	if c == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. internal/config/lambda/event/arn.go

    	TargetID
    	region string
    }
    
    // String - returns string representation.
    func (arn ARN) String() string {
    	if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:s3-object-lambda:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // ParseARN - parses string to ARN.
    func ParseARN(s string) (*ARN, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  4. cmd/bucket-versioning-handler.go

    	maxBucketVersioningConfigSize = 1 * humanize.MiByte
    )
    
    // PutBucketVersioningHandler - PUT Bucket Versioning.
    // ----------
    func (api objectAPIHandlers) PutBucketVersioningHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketVersioning")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. tensorflow/c/c_api_experimental_test.cc

      TF_Output outputs[] = {{neg, 0}};
      *func = TF_GraphToFunction(func_graph.get(), name, append_hash, -1,
                                 /*opers=*/nullptr, 1, inputs, 1, outputs,
                                 /*output_names=*/nullptr,
                                 /*opts=*/nullptr, description, s.get());
      ASSERT_EQ(TF_OK, TF_GetCode(s.get())) << TF_Message(s.get());
      ASSERT_NE(*func, nullptr);
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Jan 17 22:27:52 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  6. cmd/object-api-listobjects_test.go

    func testListObjectsOnVersionedBuckets(obj ObjectLayer, instanceType string, t1 TestErrHandler) {
    	_testListObjects(obj, instanceType, t1, true)
    }
    
    // Unit test for ListObjects.
    func testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler) {
    	_testListObjects(obj, instanceType, t1, false)
    }
    
    func _testListObjects(obj ObjectLayer, instanceType string, t1 TestErrHandler, versioned bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-erasure-set.go

    		"Health of the erasure set in a pool for write operations (1=healthy, 0=unhealthy)",
    		poolIDL, setIDL)
    )
    
    func b2f(v bool) float64 {
    	if v {
    		return 1
    	}
    	return 0
    }
    
    // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure
    // set metrics.
    func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	result, _ := c.esetHealthResult.Get()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. internal/disk/stat_windows.go

    // It returns free space available to the user (including quota limitations)
    //
    // https://msdn.microsoft.com/en-us/library/windows/desktop/aa364937(v=vs.85).aspx
    func GetInfo(path string, _ bool) (info Info, err error) {
    	// Stat to know if the path exists.
    	if _, err = os.Stat(path); err != nil {
    		return Info{}, err
    	}
    
    	lpFreeBytesAvailable := int64(0)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  9. istioctl/cmd/istioctl/istioctl_test.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package main
    
    import (
    	"os"
    	"testing"
    )
    
    func TestIstioctlMain(_ *testing.T) {
    	os.Args = []string{"istioctl", "version", "--remote=false"}
    	main()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 738 bytes
    - Viewed (0)
  10. internal/crypto/auto-encryption.go

    	EnvKMSAutoEncryption = "MINIO_KMS_AUTO_ENCRYPTION"
    )
    
    // LookupAutoEncryption returns true if and only if
    // the MINIO_KMS_AUTO_ENCRYPTION env. variable is
    // set to "on".
    func LookupAutoEncryption() bool {
    	auto, _ := config.ParseBool(env.Get(EnvKMSAutoEncryption, config.EnableOff))
    	return auto
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 1.4K bytes
    - Viewed (0)
Back to top