Stream

(Stream)

Overview

Operations related to livestream api

Available Operations

CreateClip - Create a clip
GetAll - Retrieve streams
Create - Create a stream
Delete - Delete a stream
Get - Retrieve a stream
Update - Update a stream
GetClips - Retrieve clips of a livestream
AddMultistreamTarget - Add a multistream target
RemoveMultistreamTarget - Remove a multistream target
StartPull - Start ingest for a pull stream
Terminate - Terminates a live stream

CreateClip

Create a clip

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"github.com/livepeer/livepeer-go/models/components"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    request := components.ClipPayload{
        EndTime: livepeergo.Float64(1587667174725),
        Name: livepeergo.String("My Clip"),
        PlaybackID: "eaw4nk06ts2d0mzb",
        SessionID: livepeergo.String("de7818e7-610a-4057-8f6f-b785dc1e6f88"),
        StartTime: 1587667174725,
    }
    ctx := context.Background()
    res, err := s.Stream.CreateClip(ctx, request)
    if err != nil {
        log.Fatal(err)
    }
    if res.Data != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`request`	components.ClipPayload	✔️	The request object to use for the request.

Response

*operations.CreateClipResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

GetAll

Retrieve streams

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var streamsonly *string = livepeergo.String("<value>")
    ctx := context.Background()
    res, err := s.Stream.GetAll(ctx, streamsonly)
    if err != nil {
        log.Fatal(err)
    }
    if res.Data != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`streamsonly`	*string	➖	N/A

Response

*operations.GetStreamsResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Create

The only parameter you are required to set is the name of your stream, but we also highly recommend that you define transcoding profiles parameter that suits your specific broadcasting configuration.

If you do not define transcoding rendition profiles when creating the stream, a default set of profiles will be used. These profiles include 240p, 360p, 480p and 720p.

The playback policy is set to public by default for new streams. It can also be added upon the creation of a new stream by adding "playbackPolicy": {"type": "jwt"}

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"github.com/livepeer/livepeer-go/models/components"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    request := components.NewStreamPayload{
        Multistream: &components.Multistream{
            Targets: []components.Target{
                components.Target{
                    ID: livepeergo.String("PUSH123"),
                    Profile: "720p",
                    Spec: &components.TargetSpec{
                        Name: livepeergo.String("My target"),
                        URL: "rtmps://live.my-service.tv/channel/secretKey",
                    },
                    VideoOnly: livepeergo.Bool(false),
                },
            },
        },
        Name: "test_stream",
        PlaybackPolicy: &components.PlaybackPolicy{
            RefreshInterval: livepeergo.Float64(600),
            Type: components.TypeWebhook,
            WebhookContext: map[string]any{
                "streamerId": "my-custom-id",
            },
            WebhookID: livepeergo.String("1bde4o2i6xycudoy"),
        },
        Profiles: []components.FfmpegProfile{
            components.FfmpegProfile{
                Bitrate: 3000000,
                Fps: 30,
                FpsDen: livepeergo.Int64(1),
                Gop: livepeergo.String("2"),
                Height: 486589,
                Name: "720p",
                Profile: components.FfmpegProfileProfileH264Baseline.ToPointer(),
                Quality: livepeergo.Int64(23),
                Width: 1280,
            },
        },
        Pull: &components.Pull{
            Headers: map[string]string{
                "Authorization": "Bearer 123",
            },
            Location: &components.Location{
                Lat: 39.739,
                Lon: -104.988,
            },
            Source: "https://myservice.com/live/stream.flv",
        },
        Record: livepeergo.Bool(false),
        RecordingSpec: &components.NewStreamPayloadRecordingSpec{
            Profiles: []components.TranscodeProfile{
                components.TranscodeProfile{
                    Bitrate: 3000000,
                    Encoder: components.EncoderH264.ToPointer(),
                    Fps: livepeergo.Int64(30),
                    FpsDen: livepeergo.Int64(1),
                    Gop: livepeergo.String("2"),
                    Name: livepeergo.String("720p"),
                    Profile: components.ProfileH264Baseline.ToPointer(),
                    Quality: livepeergo.Int64(23),
                    Width: livepeergo.Int64(1280),
                },
            },
        },
    }
    ctx := context.Background()
    res, err := s.Stream.Create(ctx, request)
    if err != nil {
        log.Fatal(err)
    }
    if res.Stream != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`request`	components.NewStreamPayload	✔️	The request object to use for the request.

Response

*operations.CreateStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Delete

This will also suspend any active stream sessions, so make sure to wait until the stream has finished. To explicitly interrupt an active session, consider instead updating the suspended field in the stream using the PATCH stream API.

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.Delete(ctx, id)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the stream

Response

*operations.DeleteStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Get

Retrieve a stream

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.Get(ctx, id)
    if err != nil {
        log.Fatal(err)
    }
    if res.Stream != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the stream

Response

*operations.GetStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Update

Update a stream

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"github.com/livepeer/livepeer-go/models/components"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"

    streamPatchPayload := components.StreamPatchPayload{
        Multistream: &components.Multistream{
            Targets: []components.Target{
                components.Target{
                    ID: livepeergo.String("PUSH123"),
                    Profile: "720p",
                    Spec: &components.TargetSpec{
                        Name: livepeergo.String("My target"),
                        URL: "rtmps://live.my-service.tv/channel/secretKey",
                    },
                    VideoOnly: livepeergo.Bool(false),
                },
            },
        },
        PlaybackPolicy: &components.PlaybackPolicy{
            RefreshInterval: livepeergo.Float64(600),
            Type: components.TypeWebhook,
            WebhookContext: map[string]any{
                "streamerId": "my-custom-id",
            },
            WebhookID: livepeergo.String("1bde4o2i6xycudoy"),
        },
        Profiles: []components.FfmpegProfile{
            components.FfmpegProfile{
                Bitrate: 3000000,
                Fps: 30,
                FpsDen: livepeergo.Int64(1),
                Gop: livepeergo.String("2"),
                Height: 857478,
                Name: "720p",
                Profile: components.FfmpegProfileProfileH264Baseline.ToPointer(),
                Quality: livepeergo.Int64(23),
                Width: 1280,
            },
        },
        Record: livepeergo.Bool(false),
        RecordingSpec: &components.RecordingSpec{
            Profiles: []components.TranscodeProfile{
                components.TranscodeProfile{
                    Bitrate: 3000000,
                    Encoder: components.EncoderH264.ToPointer(),
                    Fps: livepeergo.Int64(30),
                    FpsDen: livepeergo.Int64(1),
                    Gop: livepeergo.String("2"),
                    Name: livepeergo.String("720p"),
                    Profile: components.ProfileH264Baseline.ToPointer(),
                    Quality: livepeergo.Int64(23),
                    Width: livepeergo.Int64(1280),
                },
            },
        },
    }
    ctx := context.Background()
    res, err := s.Stream.Update(ctx, id, streamPatchPayload)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the stream
`streamPatchPayload`	components.StreamPatchPayload	✔️	N/A

Response

*operations.UpdateStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

GetClips

Retrieve clips of a livestream

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.GetClips(ctx, id)
    if err != nil {
        log.Fatal(err)
    }
    if res.Data != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the parent stream or playbackId of parent stream

Response

*operations.GetClipsResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

AddMultistreamTarget

Add a multistream target

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"github.com/livepeer/livepeer-go/models/components"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"

    targetAddPayload := components.TargetAddPayload{
        ID: livepeergo.String("PUSH123"),
        Profile: "720p0",
        Spec: &components.TargetAddPayloadSpec{
            Name: livepeergo.String("My target"),
            URL: "rtmps://live.my-service.tv/channel/secretKey",
        },
        VideoOnly: livepeergo.Bool(false),
    }
    ctx := context.Background()
    res, err := s.Stream.AddMultistreamTarget(ctx, id, targetAddPayload)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the parent stream
`targetAddPayload`	components.TargetAddPayload	✔️	N/A

Response

*operations.AddMultistreamTargetResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

RemoveMultistreamTarget

Remove a multistream target

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"

    var targetID string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.RemoveMultistreamTarget(ctx, id, targetID)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the parent stream
`targetID`	string	✔️	ID of the multistream target

Response

*operations.RemoveMultistreamTargetResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

StartPull

POST /stream/{id}/start-pull can be used to start ingest for a stream configured with a pull source. If the stream has recording configured, it will also start recording.

A 204 No Content status response indicates the stream was successfully started.

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.StartPull(ctx, id)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the stream

Response

*operations.StartPullStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Terminate

DELETE /stream/{id}/terminate can be used to terminate an ongoing session on a live stream. Unlike suspending the stream, it allows the streamer to restart streaming even immediately, but it will force terminate the current session and stop the recording.

A 204 No Content status response indicates the stream was successfully terminated.

Example Usage

package main

import(
	livepeergo "github.com/livepeer/livepeer-go"
	"context"
	"log"
)

func main() {
    s := livepeergo.New(
        livepeergo.WithSecurity("<YOUR_BEARER_TOKEN_HERE>"),
    )
    var id string = "<value>"
    ctx := context.Background()
    res, err := s.Stream.Terminate(ctx, id)
    if err != nil {
        log.Fatal(err)
    }
    if res != nil {
        // handle response
    }
}

Parameters

Parameter	Type	Required	Description
`ctx`	context.Context	✔️	The context to use for the request.
`id`	string	✔️	ID of the stream

Response

*operations.TerminateStreamResponse, error

Error Object	Status Code	Content Type
sdkerrors.SDKError	4xx-5xx	/

Files

README.md

Latest commit

History

README.md

File metadata and controls

Stream

Overview

Available Operations

CreateClip

Example Usage

Parameters

Response

GetAll

Example Usage

Parameters

Response

Create

Example Usage

Parameters

Response

Delete

Example Usage

Parameters

Response

Get

Example Usage

Parameters

Response

Update

Example Usage

Parameters

Response

GetClips

Example Usage

Parameters

Response

AddMultistreamTarget

Example Usage

Parameters

Response

RemoveMultistreamTarget

Example Usage

Parameters

Response

StartPull

Example Usage

Parameters

Response

Terminate

Example Usage

Parameters

Response