service

Documentation

Index

• Constants
• func BasicAuthHandler(h http.Handler, username, password string) http.Handler
• type RiakService
  • func NewRiakService(c *config.ServiceConfig, client client.Client) *RiakService
  • func (s *RiakService) BindInstance(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) BindInstanceEvent(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) CheckInstanceStatus(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) CreateInstance(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) GetPlans(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) JSONEndpoints() map[string]map[string]server.JSONEndpoint
  • func (s *RiakService) JSONMiddleware(j server.JSONEndpoint) server.JSONEndpoint
  • func (s *RiakService) Middleware(h http.Handler) http.Handler
  • func (s *RiakService) Prefix() string
  • func (s *RiakService) RemoveInstance(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) UnbindInstance(r *http.Request) (int, interface{}, error)
  • func (s *RiakService) UnbindInstanceEvent(r *http.Request) (int, interface{}, error)

Constants

const (
	// MissingParamsMsg message when parameters are required
	MissingParamsMsg = "Missing parameters"
	// BucketCreationFailMsg message when bucket creation fails
	BucketCreationFailMsg = "Error declaring bucket type"
	// ErrorBucketStatusMsg message when bucket status is in error state
	ErrorBucketStatusMsg = "Bucket error"
	// UserGrantingFailMsg message when granting access to users fails
	UserGrantingFailMsg = "Error granting user"
	// UserRevokingFailMsg message when revoking access to users fails
	UserRevokingFailMsg = "Error revoking user"
)

Functions

func BasicAuthHandler

func BasicAuthHandler(h http.Handler, username, password string) http.Handler

BasicAuthHandler checks if the request is authorized

Types

type RiakService

type RiakService struct {

	// Application configuration
	Cfg *config.ServiceConfig

	// resources client (normally riak)
	Client client.Client
}

RiakService expose tsuru api for riak service

func NewRiakService

func NewRiakService(c *config.ServiceConfig, client client.Client) *RiakService

NewRiakService creates a new services ready to register on the server

func (*RiakService) BindInstance

func (s *RiakService) BindInstance(r *http.Request) (int, interface{}, error)

BindInstance Binds an app to an instance on Tsuru, this translates to a new authentication credentias and authorization for teh desired bucket

func (*RiakService) BindInstanceEvent

func (s *RiakService) BindInstanceEvent(r *http.Request) (int, interface{}, error)

BindInstanceEvent Processes the event from tsuru when an app is binded to a service instance

func (*RiakService) CheckInstanceStatus

func (s *RiakService) CheckInstanceStatus(r *http.Request) (int, interface{}, error)

CheckInstanceStatus Checks the status of an instance on tsuru. Translated to riak, Checks the status of the bucket

func (*RiakService) CreateInstance

func (s *RiakService) CreateInstance(r *http.Request) (int, interface{}, error)

CreateInstance Creates a new instance on Tsuru, this translates to a new bucket of the desired bucket type on Riak

func (*RiakService) GetPlans

func (s *RiakService) GetPlans(r *http.Request) (int, interface{}, error)

GetPlans returns a json with the available plans on tsuru. Translated to riak, this are the bucket types

func (*RiakService) JSONEndpoints

func (s *RiakService) JSONEndpoints() map[string]map[string]server.JSONEndpoint

JSONEndpoints maps the routes with the endpoints

func (*RiakService) JSONMiddleware

func (s *RiakService) JSONMiddleware(j server.JSONEndpoint) server.JSONEndpoint

JSONMiddleware wraps all the requests around these middlewares

func (*RiakService) Middleware

func (s *RiakService) Middleware(h http.Handler) http.Handler

Middleware wraps all the requests around thesse middlewares

func (*RiakService) Prefix

func (s *RiakService) Prefix() string

Prefix returns the url prefix for all the endpoints of this service

func (*RiakService) RemoveInstance

func (s *RiakService) RemoveInstance(r *http.Request) (int, interface{}, error)

RemoveInstance Remove instance Removes the instance from tsuru. Translated to riak, delete all the keys from the bucket (causing bucket deletion) -> not a good choice, not deleting bucket Bucket will persist 'forever'

func (*RiakService) UnbindInstance

func (s *RiakService) UnbindInstance(r *http.Request) (int, interface{}, error)

UnbindInstance Unbinds the instance from the app on Tsuru, this translates to remove credentials from the desired bucket

func (*RiakService) UnbindInstanceEvent

func (s *RiakService) UnbindInstanceEvent(r *http.Request) (int, interface{}, error)

UnbindInstanceEvent Processes the event from tsuru when an app is unbinded from a service instance