faasinfra

Documentation

Index

• Constants
• func BatchCreate(ctx context.Context, param interface{}) ([]primitive.ObjectID, error)
• func Count(ctx context.Context, param interface{}) (int64, error)
• func Create(ctx context.Context, param interface{}) (*structs.RecordOnlyId, error)
• func Delete(ctx context.Context, param interface{}) error
• func Distinct(ctx context.Context, param interface{}, results interface{}) error
• func DoRequestFile(ctx context.Context, contentType string, body *bytes.Buffer) ([]byte, error)
• func DoRequestRedis(ctx context.Context, param interface{}) ([]byte, map[string]interface{}, error)
• func Find(ctx context.Context, param, results interface{}) error
• func FindOne(ctx context.Context, param, result interface{}) error
• func GetFaaSInfraPathFile() string
• func GetFaaSInfraPathMongodb() string
• func GetFaaSInfraPathRedis() string
• func GetInstance() request.IRequestFaaSInfra
• func GetPathInvokeFunction(namespace string) string
• func GetPathInvokeFunctionAsync(namespace string) string
• func GetPathInvokeFunctionDistributed(namespace string) string
• func ReadFromURL(ctx context.Context, targetURL string) ([]byte, error)
• func Update(ctx context.Context, param interface{}) error
• func UploadWithContent(ctx context.Context, name string, content []byte, option *structs.Option) (*structs.UploadResult, error)

Constants

const (
	PathInvokeFunction            = "/cloudfunction/v1/namespaces/:namespace/function/invokeSync"
	PathInvokeFunctionAsync       = "/faasAsyncTask/v1/namespaces/:namespace/asyncTask/CreateAsyncTask"
	PathInvokeFunctionDistributed = "/distributedTask/v1/namespaces/:namespace/create"
	PathFaaSInfraPathMongodb      = "/resource/v3/namespaces/:namespace/db"
	PathFaaSInfraPathRedis        = "/resource/v2/namespaces/:namespace/cache"
	FaaSInfraPathFile             = "/resource/v2/namespaces/:namespace/file"
)

Functions

func BatchCreate

func BatchCreate(ctx context.Context, param interface{}) ([]primitive.ObjectID, error)

func Count

func Count(ctx context.Context, param interface{}) (int64, error)

func Create

func Create(ctx context.Context, param interface{}) (*structs.RecordOnlyId, error)

func Delete

func Delete(ctx context.Context, param interface{}) error

func Distinct

func Distinct(ctx context.Context, param interface{}, results interface{}) error

func DoRequestFile

func DoRequestFile(ctx context.Context, contentType string, body *bytes.Buffer) ([]byte, error)

func DoRequestRedis

func DoRequestRedis(ctx context.Context, param interface{}) ([]byte, map[string]interface{}, error)

func Find

func Find(ctx context.Context, param, results interface{}) error

func FindOne

func FindOne(ctx context.Context, param, result interface{}) error

func GetFaaSInfraPathFile

func GetFaaSInfraPathFile() string

func GetFaaSInfraPathMongodb

func GetFaaSInfraPathMongodb() string

func GetFaaSInfraPathRedis

func GetFaaSInfraPathRedis() string

func GetInstance

func GetInstance() request.IRequestFaaSInfra

func GetPathInvokeFunction

func GetPathInvokeFunction(namespace string) string

func GetPathInvokeFunctionAsync

func GetPathInvokeFunctionAsync(namespace string) string

func GetPathInvokeFunctionDistributed

func GetPathInvokeFunctionDistributed(namespace string) string

func ReadFromURL

func ReadFromURL(ctx context.Context, targetURL string) ([]byte, error)

func Update

func Update(ctx context.Context, param interface{}) error

func UploadWithContent

func UploadWithContent(ctx context.Context, name string, content []byte, option *structs.Option) (*structs.UploadResult, error)