13873166240

Committed 15 Mar 2025 01:08PM UTC coverage: 59.373% (-1.9%) from 61.277%

Build # 13873166240

Build Type

push

github

Committed by

web-flow

Commit Message

update kernel api - unified support for events and codecs (#117)

* update kernel api - unified support for events and codecs
* go version 1.24

Run Details

66 of 155 new or added lines in 8 files covered. (42.58%)

56 existing lines in 5 files now uncovered.

1023 of 1723 relevant lines covered (59.37%)

0.66 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/errors.go

//
// Copyright (C) 2021 - 2022 Dmitry Kolesnikov
//
// This file may be modified and distributed under the terms
// of the Apache License Version 2.0. See the LICENSE file for details.
// https://github.com/fogfish/swarm
//

package swarm

import (
        "fmt"
        "time"

        "github.com/fogfish/faults"
)

const (
        ErrServiceIO  = faults.Type("service i/o failed")
        ErrEnqueue    = faults.Type("enqueue i/o failed")
        ErrEncoder    = faults.Type("encoder failure")
        ErrDequeue    = faults.Type("dequeue i/o failed")
        ErrDecoder    = faults.Type("decoder failure")
        ErrRouting    = faults.Safe1[string]("routing has failed (cat %s)")
        ErrCatUnknown = faults.Safe1[string]("unknown category %s")
)

type errTimeout struct {
        op    string
        timer time.Duration
}

func ErrTimeout(op string, timer time.Duration) error {
        return errTimeout{
                op:    op,
                timer: timer,
        }
}

func (err errTimeout) Error() string {
        return fmt.Sprintf("timeout %s after %s", err.op, err.timer)
}

func (err errTimeout) Timeout() time.Duration {
        return err.timer
}

1	//
2	// Copyright (C) 2021 - 2022 Dmitry Kolesnikov
3	//
4	// This file may be modified and distributed under the terms
5	// of the Apache License Version 2.0. See the LICENSE file for details.
6	// https://github.com/fogfish/swarm
7	//
8
9	package swarm
10
11	import (
12	"fmt"
13	"time"
14
15	"github.com/fogfish/faults"
16	)
17
18	const (
19	ErrServiceIO = faults.Type("service i/o failed")
20	ErrEnqueue = faults.Type("enqueue i/o failed")
21	ErrEncoder = faults.Type("encoder failure")
22	ErrDequeue = faults.Type("dequeue i/o failed")
23	ErrDecoder = faults.Type("decoder failure")
24	ErrRouting = faults.Safe1[string]("routing has failed (cat %s)")
25	ErrCatUnknown = faults.Safe1[string]("unknown category %s")
26	)
27
28	type errTimeout struct {
29	op string
30	timer time.Duration
31	}
32
UNCOV 33	func ErrTimeout(op string, timer time.Duration) error {	×
UNCOV 34	return errTimeout{	×
UNCOV 35	op: op,	×
UNCOV 36	timer: timer,	×
UNCOV 37	}	×
UNCOV 38	}	×
39
UNCOV 40	func (err errTimeout) Error() string {	×
UNCOV 41	return fmt.Sprintf("timeout %s after %s", err.op, err.timer)	×
UNCOV 42	}	×
43
44	func (err errTimeout) Timeout() time.Duration {	×
45	return err.timer	×
46	}	×

fogfish / swarm / 13873166240

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous