From e4e7b6d101f6f2cc1616100a061df034121ad9d0 Mon Sep 17 00:00:00 2001 From: Avi Zimmerman Date: Tue, 12 Jan 2021 10:20:30 +0200 Subject: [PATCH] add region to minio plugins --- examples/plugins/minio/miniosink.go | 1 + examples/plugins/minio/miniosrc.go | 1 + 2 files changed, 2 insertions(+) diff --git a/examples/plugins/minio/miniosink.go b/examples/plugins/minio/miniosink.go index d04f1fa..1bf48c5 100644 --- a/examples/plugins/minio/miniosink.go +++ b/examples/plugins/minio/miniosink.go @@ -204,6 +204,7 @@ func (m *minioSink) Start(self *base.GstBaseSink) bool { client, err := minio.New(m.settings.endpoint, &minio.Options{ Creds: credentials.NewStaticV4(m.settings.accessKeyID, m.settings.secretAccessKey, ""), Secure: m.settings.useTLS, + Region: m.settings.region, }) if err != nil { diff --git a/examples/plugins/minio/miniosrc.go b/examples/plugins/minio/miniosrc.go index 3facc33..6f5701c 100644 --- a/examples/plugins/minio/miniosrc.go +++ b/examples/plugins/minio/miniosrc.go @@ -226,6 +226,7 @@ func (m *minioSrc) Start(self *base.GstBaseSrc) bool { client, err := minio.New(m.settings.endpoint, &minio.Options{ Creds: credentials.NewStaticV4(m.settings.accessKeyID, m.settings.secretAccessKey, ""), Secure: m.settings.useTLS, + Region: m.settings.region, }) if err != nil {