Documentation
¶
Overview ¶
Package sdk provides go bindings for pebl's system calls.
For more detailed guides on utilizing pebl, check out the docs
Index ¶
- func Cron(name, schedule string, method func()) error
- func InternalService(app http.Handler, endpoint string) error
- func KVGet(key string) (string, bool, error)
- func KVSet(key, value string) error
- func Mount(name, path string) error
- func Publish(topic, data string) error
- func Read(path string) (io.ReadCloser, error)
- func Service(app http.Handler, endpoint string) error
- func Subscribe(topic string, cb func(string)) error
- func Write(path string) (io.WriteCloser, error)
- type MysqlConn
- type RedisConn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Cron ¶
Cron creates a scheduled task.
The name identifies the scheduled task, and subsequent uses of the same name will overwrite the same logical task.
The schedule must be valid cron schedule with 5 fields separated by spaces. It also accepts @hourly and @daily, which are shorthand for "0 * * * *" and "0 0 * * *" respectively.
func InternalService ¶
InternalService takes an http.Handler and creates a private service at the endpoint. A private service can only be reached by other workloads in the cluster using the provided `endpoint` argument.
Unlike `Service`, the `endpoint` used here can be any valid domain. Though in general we recommend a scheme to easily identify internal vs. external services, something like `foo.local` or `bar.private`.
func Read ¶
func Read(path string) (io.ReadCloser, error)
Read returns an object with io.ReadCloser interface.
Interleaving Read and Write on the same path may result in unexpected behavior.
Source Files