diff --git a/cluster/node/node.go b/cluster/node/node.go index a455d6d1..6eac5520 100644 --- a/cluster/node/node.go +++ b/cluster/node/node.go @@ -96,7 +96,7 @@ func New(config Config) *Node { n.config = coreConfig n.skills = coreSkills - n.core = NewCore(n.id, n.logger.WithComponent("ClusterCore").WithField("address", address)) + n.core = NewCore(n.id, n.logger.WithComponent("ClusterCore")) n.core.SetEssentials(address, coreConfig) n.coreLastErr = err diff --git a/http/client/client.go b/http/client/client.go index b77b46a9..0016260e 100644 --- a/http/client/client.go +++ b/http/client/client.go @@ -58,7 +58,7 @@ type RestClient interface { FilesystemAddFile(storage, path string, data io.Reader) error // PUT /v3/fs/{storage}/{path} Events(ctx context.Context, filters api.EventFilters) (<-chan api.LogEvent, error) // POST /v3/events - MediaEvents(ctx context.Context, storage, pattern string) (<-chan api.MediaEvent, error) // GET /v3/fs/{storage}, GET /v3/(rtmp|srt) + MediaEvents(ctx context.Context, storage, pattern string) (<-chan api.MediaEvent, error) // GET /v3/events/media/{storage} ProcessList(opts ProcessListOptions) ([]api.Process, error) // GET /v3/process ProcessAdd(p *app.Config, metadata map[string]any) error // POST /v3/process