pili

package

Go to main page

Versions in this module

v1

v1.5.2

Feb 28, 2016

Changes in this version

type StreamList

+ End bool

v1.5.1

Oct 30, 2015

Changes in this version

type OptionalArguments

+ Hub string

+ Idonly string

+ Status string

+ UserPipeline string

+ type StreamId struct

+ Id string

+ type StreamIdList struct

+ Items []*StreamId

+ Marker string

type StreamSegmentList

+ Duration int64

+ End int64

+ Start int64

type StreamStatus

+ StartFrom string

v1.5.0

Aug 24, 2015

Changes in this version

+ const DEFAULT_API_VERSION

+ const SDK_USER_AGENT

+ type Credentials struct

+ AccessKey string

+ SecretKey string

+ func NewCredentials(accessKey, secretKey string) *Credentials

+ func (c *Credentials) MACToken(req *http.Request) (token string, err error)

type ErrorInfo

+ Details map[string]error

+ ErrCode int

+ Message string

+ type Hub struct

+ func NewHub(creds *Credentials, hubName string) Hub

+ func (c Hub) CreateStream(args OptionalArguments) (stream Stream, err error)

+ func (c Hub) GetStream(id string) (stream Stream, err error)

+ func (c Hub) ListStreams(args OptionalArguments) (ret StreamList, err error)

type OptionalArguments

+ Time int64

+ type RPC struct

+ func NewRPC(creds *Credentials) *RPC

+ func (r RPC) Del(url string) (resp *http.Response, err error)

+ func (r RPC) DelCall(ret interface{}, url string) (err error)

+ func (r RPC) Do(req *http.Request) (resp *http.Response, err error)

+ func (r RPC) Get(url string) (resp *http.Response, err error)

+ func (r RPC) GetCall(ret interface{}, url string) (err error)

+ func (r RPC) Post(url string, data interface{}) (resp *http.Response, err error)

+ func (r RPC) PostCall(ret interface{}, url string, params interface{}) (err error)

+ func (r RPC) RequestWith(method string, url string, bodyType string, body io.Reader, bodyLength int) (resp *http.Response, err error)

type Stream

+ func (s Stream) HttpFlvLiveUrls() (urls map[string]string, err error)

+ func (s Stream) Snapshot(name, format string, args OptionalArguments) (ret StreamSnapshotResponse, err error)

+ type StreamSnapshotResponse struct

+ PersistentId string

+ TargetUrl string

type StreamStatus

+ BytesPerSecond float64

+ FramesPerSecond struct{ ... }

v1.3.0

Aug 9, 2015

Changes in this version

type OptionalArguments

+ NotifyUrl string

type Stream

+ func (s Stream) SaveAs(name, format string, start, end int64, args OptionalArguments) (ret StreamSaveAsResponse, err error)

+ type StreamSaveAsResponse struct

+ PersistentId string

+ TargetUrl string

+ Url string

v1.2.0

Aug 9, 2015

Changes in this version

+ const ORIGIN

+ type Client struct

+ func (c Client) CreateStream(args OptionalArguments) (stream Stream, err error)

+ func (c Client) GetStream(id string) (stream Stream, err error)

+ func (c Client) ListStreams(args OptionalArguments) (ret StreamList, err error)

+ type OptionalArguments struct

+ Disabled bool

+ End int64

+ Limit uint

+ Marker string

+ PublishKey string

+ PublishSecurity string

+ Start int64

+ Title string

type Stream

+ Hosts struct{ ... }

+ Profiles []string

+ func (s Stream) Delete() (ret interface{}, err error)

+ func (s Stream) Disable() (stream Stream, err error)

+ func (s Stream) Enable() (stream Stream, err error)

+ func (s Stream) HlsLiveUrls() (urls map[string]string, err error)

+ func (s Stream) HlsPlaybackUrls(start, end int64) (urls map[string]string, err error)

+ func (s Stream) Refresh() (stream Stream, err error)

+ func (s Stream) RtmpLiveUrls() (urls map[string]string, err error)

+ func (s Stream) Segments(args OptionalArguments) (ret StreamSegmentList, err error)

+ func (s Stream) Status() (ret StreamStatus, err error)

+ func (s Stream) ToJSONString() (jsonBlob string, err error)

+ func (s Stream) Update(args OptionalArguments) (stream Stream, err error)

v1.1.0

May 26, 2015

Changes in this version

+ func URI_GetStreamStatus(id string) string

type API_Client

+ func (app API_Client) GetStreamStatus(id string) (ret StreamStatus, err error)

type Stream

+ Disabled bool

+ func (s Stream) HlsLiveUrl(hlsPlayHost, profile string) (url string)

+ func (s Stream) HlsPlaybackUrl(hlsPlayHost, profile string, start, end int64) (url string)

+ func (s Stream) PublishToken(rtmpPublishHost string, nonce int64) (token string)

+ func (s Stream) RtmpLiveUrl(rtmpPlayHost, profile string) (url string)

+ func (s Stream) RtmpPublishUrl(rtmpPublishHost string, nonce int64) (url string)

+ type StreamStatus struct

+ Addr string

+ Status string

v1.0.2

May 14, 2015

Changes in this version

+ const API_VERSION

+ const DEFAULT_API_HOST

+ const SDK_VERSION

+ var API_BASE_URL = fmt.Sprintf("%s://%s/%s", getHttpScheme(), getApiHost(), API_VERSION)

+ var API_HOST string

+ var DefaultClient = RPC_Client

+ var USE_HTTPS bool

+ func ResponseError(resp *http.Response) (err error)

+ func Sign(secret, data []byte) (token string)

+ func URI_DelStream(id string) string

+ func URI_GetStream(id string) string

+ func URI_GetStreamSegments(id string, options map[string]interface{}) (httpurl string)

+ func URI_ListStreams(hub string, options map[string]interface{}) (httpurl string)

+ func URI_NewStream() string

+ func URI_SetStream(id string) string

+ func UserAgent() string

+ type API_Client struct

+ Conn RPC_Client

+ func NewClient(mac *Mac) API_Client

+ func (app API_Client) CreateStream(hub, title, publishKey, publishSecurity string) (ret Stream, err error)

+ func (app API_Client) DelStream(id string) (ret interface{}, err error)

+ func (app API_Client) GetStream(id string) (ret Stream, err error)

+ func (app API_Client) GetStreamSegments(id string, startTime, endTime int64) (ret StreamSegmentList, err error)

+ func (app API_Client) ListStreams(hub, marker string, limit int64) (ret StreamList, err error)

+ func (app API_Client) SetStream(id, publishKey, publishSecurity string) (ret Stream, err error)

+ type Error struct

+ Err int

+ Msg string

+ type ErrorInfo struct

+ Code int

+ func (r *ErrorInfo) Error() string

+ type ErrorRet struct

+ Details map[string]Error

+ Err int

+ Msg string

+ type Mac struct

+ AccessKey string

+ SecretKey string

+ func Creds(accessKey, secretKey string) *Mac

+ func (mac *Mac) SignRequest(req *http.Request) (token string, err error)

+ type PlayPolicy struct

+ HlsPlayHost string

+ RtmpPlayHost string

+ StreamId string

+ func (p PlayPolicy) HlsLiveUrl(preset string) (url string)

+ func (p PlayPolicy) HlsPlaybackUrl(start, end int64, preset string) (url string)

+ func (p PlayPolicy) RtmpLiveUrl(preset string) (url string)

+ type PublishPolicy struct

+ Nonce int64

+ RtmpPublishHost string

+ StreamId string

+ StreamPublishKey string

+ StreamPublishSecurity string

+ func (p PublishPolicy) NonceVal() (nonce int64)

+ func (p PublishPolicy) Token() (token string)

+ func (p PublishPolicy) Url() (url string)

+ type RPC_Client struct

+ func (r RPC_Client) Del(url string) (resp *http.Response, err error)

+ func (r RPC_Client) DelCall(ret interface{}, url string) (err error)

+ func (r RPC_Client) Do(req *http.Request) (resp *http.Response, err error)

+ func (r RPC_Client) Get(url string) (resp *http.Response, err error)

+ func (r RPC_Client) GetCall(ret interface{}, url string) (err error)

+ func (r RPC_Client) Post(url string, data interface{}) (resp *http.Response, err error)

+ func (r RPC_Client) PostCall(ret interface{}, url string, params interface{}) (err error)

+ func (r RPC_Client) RequestWith(method string, url string, bodyType string, body io.Reader, bodyLength int) (resp *http.Response, err error)

+ type Stream struct

+ CreatedAt time.Time

+ Hub string

+ Id string

+ PublishKey string

+ PublishSecurity string

+ Title string

+ UpdatedAt time.Time

+ type StreamList struct

+ Items []*Stream

+ Marker string

+ type StreamSegment struct

+ End int64

+ Start int64

+ type StreamSegmentList struct

+ Segments []*StreamSegment

+ type Transport struct

+ func NewTransport(mac *Mac, transport http.RoundTripper) *Transport

+ func (t *Transport) RoundTrip(req *http.Request) (resp *http.Response, err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL