resourceadapters

Documentation

Index

• func CleanUpBlob(st *corestate.State, persist corestate.Persistence, storagePath string) error
• func DeployResources(serviceID string, chID charmstore.CharmID, csMac *macaroon.Macaroon, ...) (ids map[string]string, err error)
• func NewAPIClient(newAPICaller func() (api.Connection, error)) (*client.Client, error)
• func NewDownloadHandler(args apihttp.NewHandlerArgs) http.Handler
• func NewLatestCharmHandler(st *state.State) (charmrevisionupdater.LatestCharmHandler, error)
• func NewPublicFacade(st *corestate.State, _ *common.Resources, authorizer common.Authorizer) (*server.Facade, error)
• func NewResourcePersistence(persist corestate.Persistence) corestate.ResourcesPersistence
• func NewResourceState(persist corestate.Persistence, base *corestate.State) corestate.Resources
• func NewUploadHandler(args apihttp.NewHandlerArgs) http.Handler
• type CSRetryClient
  • func (client CSRetryClient) GetResource(req charmstore.ResourceRequest) (charmstore.ResourceData, error)
• type CharmCmdBase
  • func (c *CharmCmdBase) Connect(ctx *jujucmd.Context) (cmd.CharmResourceLister, error)

Functions

func CleanUpBlob

func CleanUpBlob(st *corestate.State, persist corestate.Persistence, storagePath string) error

CleanUpBlob is a cleanup handler that will be used in state cleanup.

func DeployResources

func DeployResources(serviceID string, chID charmstore.CharmID, csMac *macaroon.Macaroon, filesAndRevisions map[string]string, resources map[string]charmresource.Meta, conn api.Connection) (ids map[string]string, err error)

DeployResources uploads the bytes for the given files to the server and creates pending resource metadata for the all resource mentioned in the metadata. It returns a map of resource name to pending resource IDs.

func NewAPIClient

func NewAPIClient(newAPICaller func() (api.Connection, error)) (*client.Client, error)

NewAPIClient is mostly a copy of the newClient code in component/all/resources.go. It lives here because it simplifies this code immensely.

func NewDownloadHandler

func NewDownloadHandler(args apihttp.NewHandlerArgs) http.Handler

NewDownloadHandler returns a new HTTP handler for the given args.

func NewLatestCharmHandler

func NewLatestCharmHandler(st *state.State) (charmrevisionupdater.LatestCharmHandler, error)

NewLatestCharmHandler returns a LatestCharmHandler that uses the given Juju state.

func NewPublicFacade

func NewPublicFacade(st *corestate.State, _ *common.Resources, authorizer common.Authorizer) (*server.Facade, error)

NewPublicFacade provides the public API facade for resources. It is passed into common.RegisterStandardFacade.

func NewResourcePersistence

func NewResourcePersistence(persist corestate.Persistence) corestate.ResourcesPersistence

NewResourcePersistence is a function that may be passed to state.SetResourcesPersistence(). It will be used in the core state package to produce the resource persistence.

func NewResourceState

func NewResourceState(persist corestate.Persistence, base *corestate.State) corestate.Resources

NewResourceState is a function that may be passed to state.SetResourcesComponent().

func NewUploadHandler

func NewUploadHandler(args apihttp.NewHandlerArgs) http.Handler

NewUploadHandler returns a new HTTP handler for the given args.

Types

type CSRetryClient

type CSRetryClient struct {
	charmstore.Client
	// contains filtered or unexported fields
}

CSRetryClient is a wrapper around a Juju charm store client that retries GetResource() calls.

func (CSRetryClient) GetResource

func (client CSRetryClient) GetResource(req charmstore.ResourceRequest) (charmstore.ResourceData, error)

GetResource returns a reader for the resource's data.

type CharmCmdBase

type CharmCmdBase struct {
	*charmcmd.CommandBase
}

CharmCmdBase is an adapter for charmcmd.CommandBase.

func (*CharmCmdBase) Connect

func (c *CharmCmdBase) Connect(ctx *jujucmd.Context) (cmd.CharmResourceLister, error)

Connect implements cmd.CommandBase.