yakurl

Documentation

Index

• Variables
• func CreateUrlFromString(raw string) (*ypb.YakURL, error)
• func GetQueryParam(params []*ypb.KVPair, key string) string
• func LoadGetResource(u string) (*ypb.RequestYakURLResponse, error)
• type Action
  • func GetWebsiteViewerAction() Action
• type ActionService
  • func GetActionService() *ActionService
  • func (s *ActionService) CreateAction(schema string) Action
  • func (s *ActionService) GetAction(schema string) Action
  • func (s *ActionService) Stop()
• type BaseAction
  • func (b *BaseAction) Delete(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
  • func (b *BaseAction) Do(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
  • func (b *BaseAction) Get(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
  • func (b *BaseAction) Head(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
  • func (b *BaseAction) Post(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
  • func (b *BaseAction) Put(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
• type BaseActionHandler

Variables

var OP_NEW_MONITOR = "new"

var OP_STOP_MONITOR = "stop"

var YakRunnerMonitor *filesys.YakFileMonitor

Functions

func CreateUrlFromString

func CreateUrlFromString(raw string) (*ypb.YakURL, error)

func GetQueryParam

func GetQueryParam(params []*ypb.KVPair, key string) string

func LoadGetResource

func LoadGetResource(u string) (*ypb.RequestYakURLResponse, error)

Types

type Action

type Action interface {
	Get(*ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
	Post(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
	Put(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
	Delete(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
	Head(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
	Do(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)
}

func GetWebsiteViewerAction

func GetWebsiteViewerAction() Action

type ActionService

type ActionService struct {
	// contains filtered or unexported fields
}

func GetActionService

func GetActionService() *ActionService

func (*ActionService) CreateAction

func (s *ActionService) CreateAction(schema string) Action

func (*ActionService) GetAction

func (s *ActionService) GetAction(schema string) Action

func (*ActionService) Stop

func (s *ActionService) Stop()

type BaseAction

type BaseAction struct {
	// contains filtered or unexported fields
}

func (*BaseAction) Delete

func (b *BaseAction) Delete(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*BaseAction) Do

func (b *BaseAction) Do(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*BaseAction) Get

func (b *BaseAction) Get(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*BaseAction) Head

func (b *BaseAction) Head(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*BaseAction) Post

func (b *BaseAction) Post(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*BaseAction) Put

func (b *BaseAction) Put(params *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

type BaseActionHandler

type BaseActionHandler func(getParam func(key string) (string, error), body []byte, raw []*ypb.KVPair) (*ypb.RequestYakURLResponse, error)