diff --git a/debug/service/client.go b/debug/service/client.go index 805a84a3..44da0568 100644 --- a/debug/service/client.go +++ b/debug/service/client.go @@ -17,16 +17,6 @@ type debugClient struct { Client pb.DebugService } -// NewClient provides a debug client -func NewClient(name string) *debugClient { - // create default client - cli := client.DefaultClient - - return &debugClient{ - Client: pb.NewDebugService(name, cli), - } -} - // Logs queries the services logs and returns a channel to read the logs from func (d *debugClient) Log(since time.Time, count int, stream bool) (log.Stream, error) { req := &pb.LogRequest{} @@ -86,3 +76,13 @@ func (d *debugClient) streamLogs(lg *logStream, stream pb.Debug_LogService) { } } } + +// NewClient provides a debug client +func NewClient(name string) *debugClient { + // create default client + cli := client.DefaultClient + + return &debugClient{ + Client: pb.NewDebugService(name, cli), + } +} diff --git a/util/ring/buffer.go b/util/ring/buffer.go index bb8febcf..e49f1312 100644 --- a/util/ring/buffer.go +++ b/util/ring/buffer.go @@ -26,11 +26,11 @@ type Entry struct { // Stream is used to stream the buffer type Stream struct { // Id of the stream - Id string + Id string // Buffered entries Entries chan *Entry // Stop channel - Stop chan bool + Stop chan bool } // Put adds a new value to ring buffer @@ -142,4 +142,3 @@ func New(i int) *Buffer { streams: make(map[string]*Stream), } } -