minio/cmd/s3-peer-router.go

/*
 * Minio Cloud Storage, (C) 2014-2016 Minio, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package cmd

import (
	"net/rpc"

	router "github.com/gorilla/mux"
)

const (
	s3Path = "/s3/remote"
)

type s3PeerAPIHandlers struct {
	loginServer
	bms BucketMetaState
}

func registerS3PeerRPCRouter(mux *router.Router) error {
	s3PeerHandlers := &s3PeerAPIHandlers{
		loginServer{},
		&localBucketMetaState{
			ObjectAPI: newObjectLayerFn,
		},
	}

	s3PeerRPCServer := rpc.NewServer()
	err := s3PeerRPCServer.RegisterName("S3", s3PeerHandlers)
	if err != nil {
		return traceError(err)
	}

	s3PeerRouter := mux.NewRoute().PathPrefix(reservedBucket).Subrouter()
	s3PeerRouter.Path(s3Path).Handler(s3PeerRPCServer)
	return nil
}