Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for TargetType (0.09 sec)

  1. internal/logger/target/types/targettype_string.go

    func (i TargetType) String() string {
    	i -= 1
    	if i >= TargetType(len(_TargetType_index)-1) {
    		return "TargetType(" + strconv.FormatInt(int64(i+1), 10) + ")"
    	}
    	return _TargetType_name[_TargetType_index[i]:_TargetType_index[i+1]]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 703 bytes
    - Viewed (0)
  2. internal/logger/target/types/types.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package types
    
    // TargetType indicates type of the target e.g. console, http, kafka
    type TargetType uint8
    
    //go:generate stringer -type=TargetType -trimprefix=Target $GOFILE
    
    // Constants for target types
    const (
    	_ TargetType = iota
    	TargetConsole
    	TargetHTTP
    	TargetKafka
    )
    
    // TargetStats contains statistics for a target.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry interface{}) error
    	Type() types.TargetType
    }
    
    type targetsList struct {
    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    	return &targetsList{}
    }
    
    func (tl *targetsList) get() []Target {
    	tl.mu.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. internal/logger/target/testlogger/testlogger.go

    					continue
    				}
    				msg += fmt.Sprintf("\n%s", m)
    			}
    			logf("%s", msg)
    		}
    	default:
    		logf("%+v (%T)", v, v)
    	}
    	return nil
    }
    
    func (t *testLogger) Type() types.TargetType {
    	return types.TargetConsole
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. cmd/consolelogger.go

    	sys.RUnlock()
    
    	return
    }
    
    // Cancel - cancels the target
    func (sys *HTTPConsoleLoggerSys) Cancel() {
    }
    
    // Type - returns type of the target
    func (sys *HTTPConsoleLoggerSys) Type() types.TargetType {
    	return types.TargetConsole
    }
    
    // Send log message 'e' to console and publish to console
    // log pubsub system
    func (sys *HTTPConsoleLoggerSys) Send(ctx context.Context, entry interface{}) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top