| Index: logdog/client/cmd/logdog_annotee/filesystemClient.go
|
| diff --git a/logdog/client/cmd/logdog_annotee/filesystemClient.go b/logdog/client/cmd/logdog_annotee/filesystemClient.go
|
| index f0a4e554f94356d6c449c68b9fe20fe5801f493b..7470032986fe937f4ab30f1fe3c367f952b00a46 100644
|
| --- a/logdog/client/cmd/logdog_annotee/filesystemClient.go
|
| +++ b/logdog/client/cmd/logdog_annotee/filesystemClient.go
|
| @@ -74,6 +74,7 @@ func (c *filesystemClient) getFilename(base, ext string) string {
|
| func (c *filesystemClient) NewStream(f streamproto.Flags) (streamclient.Stream, error) {
|
| s := filesystemClientStream{
|
| filesystemClient: c,
|
| + props: f.Properties(),
|
| baseName: sanitize(string(f.Name)),
|
| contentType: f.ContentType,
|
| streamType: logpb.StreamType(f.Type),
|
| @@ -86,6 +87,7 @@ func (c *filesystemClient) NewStream(f streamproto.Flags) (streamclient.Stream,
|
| type filesystemClientStream struct {
|
| *filesystemClient
|
|
|
| + props *streamproto.Properties
|
| baseName string
|
| contentType string
|
| streamType logpb.StreamType
|
| @@ -172,3 +174,5 @@ func (s *filesystemClientStream) Close() error {
|
| }
|
| return nil
|
| }
|
| +
|
| +func (s *filesystemClientStream) Properties() *streamproto.Properties { return s.props.Clone() }
|
|
|