From b35b371065165c014bf4f3673d322fb0d7027b04 Mon Sep 17 00:00:00 2001 From: Terin Stock Date: Wed, 20 Nov 2019 11:10:58 -0800 Subject: feat: add open source code Add the initial open source version of K9P with support for viewing namespaces and deployments. Current support is entirely read-only. Performance is pretty terrible. Needs much more love and care. --- pkg/resources/files.go | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 pkg/resources/files.go (limited to 'pkg/resources/files.go') diff --git a/pkg/resources/files.go b/pkg/resources/files.go new file mode 100644 index 0000000..64cf892 --- /dev/null +++ b/pkg/resources/files.go @@ -0,0 +1,60 @@ +package resources + +import ( + "context" + "math/rand" + "time" + + "github.com/docker/go-p9p" + "github.com/rs/zerolog/log" +) + +type Static struct { + name string + offset int64 + content []byte + info *p9p.Dir + session Session +} + +func (r *Static) Info() p9p.Dir { + if r.info != nil { + return *r.info + } + + dir := p9p.Dir{} + dir.Qid.Path = rand.Uint64() + dir.Qid.Version = 0 + + dir.Name = r.name + dir.Mode = 0664 + dir.Length = 0 + dir.AccessTime = time.Now() + dir.ModTime = time.Now() + dir.MUID = "none" + + uname, _ := r.session.GetAuth() + dir.UID = uname + dir.GID = uname + + dir.Qid.Type |= p9p.QTFILE + + r.info = &dir + return dir +} + +func (r *Static) Get(name string) (Ref, error) { + return nil, p9p.ErrWalknodir +} + +func (r *Static) Read(ctx context.Context, p []byte, offset int64) (n int, err error) { + log.Debug().Int64("offset", r.offset).Str("name", r.name).Send() + if offset != r.offset { + return 0, p9p.ErrBadoffset + } + + n = copy(p, r.content[offset:]) + r.offset += int64(n) + + return n, nil +} -- cgit v1.2.3