controllers

Documentation

Index

• func CreateQueue(c *gin.Context)
• func CreateTopic(c *gin.Context)
• func DeleteQueue(c *gin.Context)
• func DeleteTopic(c *gin.Context)
• func ExtractAccessKey(req *http.Request) string
• func ExtractAccessKeyV2(auth string) string
• func ExtractAccessKeyV4(auth string) string
• func GetBucketNotification(c *gin.Context)
• func HandleNfsExport(req *http.Request, body []byte)
• func InheritNfsPermission(request *http.Request)
• func IsAdminUserPath(path string) bool
• func ListQueues(c *gin.Context)
• func ListSubscriptions(c *gin.Context)
• func ListTopics(c *gin.Context)
• func LoggingOps(resp *http.Response)
• func PatchBucketPermission(c *gin.Context)
• func PostForm(c *gin.Context, key string) string
• func PutBucketNotification(c *gin.Context)
• func ReceiveMessage(c *gin.Context)
• func ReverseProxy() gin.HandlerFunc
• func Search(c *gin.Context)
• func Subscribe(c *gin.Context)
• func Unsubscribe(c *gin.Context)
• type ACL
• type CreateQueueResponse
• type CreateTopicResponse
• type CustomMetadataEntry
• type CustomString
• type DeleteQueueResponse
• type DeleteTopicResponse
• type ErrorResponse
• type Grant
• type ListQueuesResponse
• type ListSubscriptionsResponse
• type ListTopicsResponse
• type Message
• type Object
• type ObjectType
• type OperationLog
• type Policy
• type ReceiveMessageResponse
• type RgwKey
• type RgwUser
• type SearchResponse
• type SubscribeResponse
• type SubscriptionARN
• type TopicARN
• type UnsubscribeResponse

Functions

func CreateQueue

func CreateQueue(c *gin.Context)

func CreateTopic

func CreateTopic(c *gin.Context)

func DeleteQueue

func DeleteQueue(c *gin.Context)

func DeleteTopic

func DeleteTopic(c *gin.Context)

func ExtractAccessKey

func ExtractAccessKey(req *http.Request) string

func ExtractAccessKeyV2

func ExtractAccessKeyV2(auth string) string

func ExtractAccessKeyV4

func ExtractAccessKeyV4(auth string) string

func GetBucketNotification

func GetBucketNotification(c *gin.Context)

func HandleNfsExport

func HandleNfsExport(req *http.Request, body []byte)

func InheritNfsPermission

func InheritNfsPermission(request *http.Request)

func IsAdminUserPath

func IsAdminUserPath(path string) bool

func ListQueues

func ListQueues(c *gin.Context)

func ListSubscriptions

func ListSubscriptions(c *gin.Context)

func ListTopics

func ListTopics(c *gin.Context)

func LoggingOps

func LoggingOps(resp *http.Response)

func PatchBucketPermission

func PatchBucketPermission(c *gin.Context)

func PostForm

func PostForm(c *gin.Context, key string) string

func PutBucketNotification

func PutBucketNotification(c *gin.Context)

func ReceiveMessage

func ReceiveMessage(c *gin.Context)

func ReverseProxy

func ReverseProxy() gin.HandlerFunc

func Search

func Search(c *gin.Context)

func Subscribe

func Subscribe(c *gin.Context)

func Unsubscribe

func Unsubscribe(c *gin.Context)

Types

type ACL

type ACL struct {
	GrantMap []Grant `json:"grant_map"`
}

type CreateQueueResponse

type CreateQueueResponse struct {
	XMLName   xml.Name `xml:"CreateQueueResponse"`
	QueueURL  string   `xml:"CreateQueueResult>QueueUrl"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}

type CreateTopicResponse

type CreateTopicResponse struct {
	XMLName   xml.Name `xml:"CreateTopicResponse"`
	TopicARN  string   `xml:"CreateTopicResult>TopicArn"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}

type CustomMetadataEntry

type CustomMetadataEntry struct {
	Name  string `json:"Name"`
	Value string `json:"Value"`
}

type CustomString

type CustomString struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type DeleteQueueResponse

type DeleteQueueResponse struct {
	XMLName   xml.Name `xml:"DeleteQueueResponse"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}

type DeleteTopicResponse

type DeleteTopicResponse struct {
	XMLName   xml.Name `xml:"DeleteTopicResponse"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}

type ErrorResponse

type ErrorResponse struct {
	XMLName   xml.Name `xml:"ErrorResponse" json:"-"`
	Type      string   `xml:"Error>Type"`
	Code      string   `xml:"Error>Code"`
	Message   string   `xml:"Error>Message"`
	RequestID string   `xml:"RequestId"`
}

type Grant

type Grant struct {
	ID string `json:id`
}

type ListQueuesResponse

type ListQueuesResponse struct {
	XMLName   xml.Name `xml:"ListQueuesResponse"`
	QueueURLs []string `xml:"ListQueuesResult>QueueUrl"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}

type ListSubscriptionsResponse

type ListSubscriptionsResponse struct {
	XMLName          xml.Name          `xml:"ListSubscriptionsResponse"`
	SubscriptionARNs []SubscriptionARN `xml:"ListSubscriptionsResult>Subscriptions>member"`
	RequestID        string            `xml:"ResponseMetadata>RequestId"`
}

type ListTopicsResponse

type ListTopicsResponse struct {
	XMLName   xml.Name   `xml:"ListTopicsResponse"`
	TopicARNs []TopicARN `xml:"ListTopicsResult>Topics>member"`
	RequestID string     `xml:"ResponseMetadata>RequestId"`
}

type Message

type Message struct {
	XMLName       xml.Name `xml:"Message"`
	MessageID     string   `xml:"MessageId"`
	ReceiptHandle string   `xml:"ReceiptHandle"`
	MD5OfBody     string   `xml:"MD5OfBody"`
	Body          string   `xml:"Body"`
}

type Object

type Object struct {
	Bucket         string    `json:"Bucket"`
	Key            string    `json:"Key"`
	Instance       string    `json:"Instance"`
	VersionedEpoch int64     `json:"VersionedEpoch"`
	LastModified   time.Time `json:"LastModified"`
	Size           int64     `json:"Size"`
	Etag           string    `json:"ETag"`
	ContentType    string    `json:"ContentType"`
	Owner          struct {
		ID          string `json:"ID"`
		DisplayName string `json:"DisplayName"`
	} `json:"Owner"`
	CustomMetadata []CustomMetadataEntry `json:"CustomMetadata"`
}

type ObjectType

type ObjectType struct {
	Bucket   string `json:"bucket"`
	Instance string `json:"instance"`
	Name     string `json:"name"`
	Owner    struct {
		DisplayName string `json:"display_name"`
		ID          string `json:"id"`
	} `json:"owner"`
	Meta struct {
		ContentType           string         `json:"content_type"`
		Etag                  string         `json:"etag"`
		Mtime                 time.Time      `json:"mtime"`
		Size                  int64          `json:"size"`
		TailTag               string         `json:"tail_tag"`
		XAmzAcl               string         `json:"x-amz-acl"`
		XAmzContentSha256     string         `json:"x-amz-content-sha256"`
		XAmzCopySource        string         `json:"x-amz-copy-source"`
		XAmzDate              string         `json:"x-amz-date"`
		XAmzMetadataDirective string         `json:"x-amz-metadata-directive"`
		XAmzStorageClass      string         `json:"x-amz-storage-class"`
		CustomString          []CustomString `json:"custom-string"`
	} `json:"meta"`
	Permissions    []string `json:"permissions"`
	VersionedEpoch int64    `json:"versioned_epoch"`
}

type OperationLog

type OperationLog struct {
	Project      string `json:"project"`
	ProjectId    string `json:"project_id"`
	User         string `json:"user"`
	Date         string `json:"date"`
	Method       string `json:"method"`
	StatusCode   string `json:"status_code"`
	Bucket       string `json:"bucket"`
	Uri          string `json:"uri"`
	ByteSend     int    `json:"byte_sned"`
	ByteRecieved int    `json:"byte_recieved"`
}

type Policy

type Policy struct {
	ACL ACL `json:"acl"`
}

type ReceiveMessageResponse

type ReceiveMessageResponse struct {
	XMLName   xml.Name  `xml:"ReceiveMessageResponse"`
	Messages  []Message `xml:"ReceiveMessageResult>Message"`
	RequestID string    `xml:"ResponseMetadata>RequestId"`
}

type RgwKey

type RgwKey struct {
	User      string `json:"user"`
	AccessKey string `json:"access_key"`
	SecretKey string `json:"secret_key"`
}

type RgwUser

type RgwUser struct {
	UserId      string   `json:"user_id"`
	DisplayName string   `json:"display_name"`
	MaxBuckets  int      `json:"max_buckets"`
	Keys        []RgwKey `json:"keys"`
}

type SearchResponse

type SearchResponse struct {
	Marker      string
	IsTruncated string
	Objects     []Object
}

type SubscribeResponse

type SubscribeResponse struct {
	XMLName         xml.Name `xml:"SubscribeResponse"`
	SubscriptionARN string   `xml:"SubscribeResult>SubscriptionArn"`
	RequestID       string   `xml:"ResponseMetadata>RequestId"`
}

type SubscriptionARN

type SubscriptionARN struct {
	TopicARN string `xml:"TopicArn"`
	Protocol string `xml:"Protocol"`
	ARN      string `xml:"SubscriptionArn"`
	Owner    string `xml:"Owner"`
	Endpoint string `xml:"Endpoint"`
}

type TopicARN

type TopicARN struct {
	Name string `xml:"TopicArn"`
}

type UnsubscribeResponse

type UnsubscribeResponse struct {
	XMLName   xml.Name `xml:"UnsubscribeResponse"`
	RequestID string   `xml:"ResponseMetadata>RequestId"`
}