metric

Documentation

Index

• Variables
• type APIData
• type CheckManager
  • func NewChecker(file stream.FileReadExister) CheckManager
  • func (c CheckManager) Check() bool
• type Checker
• type Collector
• type Data
• type DataCollectorManager
  • func NewDataCollector(userId UserIdGenerator, ritchieHomeDir string, file stream.FileReader) DataCollectorManager
  • func (d DataCollectorManager) Collect(commandExecutionTime float64, ritVersion string, commandError ...string) (APIData, error)
• type Id
  • func (i Id) String() string
• type SendManagerHttp
  • func NewHttpSender(url string, client *http.Client) SendManagerHttp
  • func (sm SendManagerHttp) Send(APIData APIData)
• type SendManagerRpc
  • func NewRpcSender(processClient pb.ProcessorClient) SendManagerRpc
  • func (sm SendManagerRpc) Send(apiData APIData)
• type Sender
• type UserId
  • func (u UserId) String() string
• type UserIdGenerator
• type UserIdManager
  • func NewUserIdGenerator() UserIdManager
  • func (us UserIdManager) Generate() (UserId, error)

Variables

var (
	CommonsRepoAdded = ""
	RepoName         = ""
)

var (
	BasicUser = ""
	BasicPass = ""
)

var (
	ServerRestURL = ""
	ServerGrpcURL = ""
	FilePath      = filepath.Join(api.RitchieHomeDir(), "metrics")
)

Types

type APIData

type APIData struct {
	Id         Id          `json:"metricId"`
	UserId     UserId      `json:"userId"`
	Timestamp  time.Time   `json:"timestamp"`
	Os         string      `json:"os"`
	RitVersion string      `json:"ritVersion"`
	Data       interface{} `json:"data"`
}

type CheckManager

type CheckManager struct {
	// contains filtered or unexported fields
}

func NewChecker

func NewChecker(file stream.FileReadExister) CheckManager

func (CheckManager) Check

func (c CheckManager) Check() bool

type Checker

type Checker interface {
	Check() bool
}

type Collector

type Collector interface {
	Collect(commandExecutionTime float64, ritVersion string, commandError ...string) (APIData, error)
}

type Data

type Data struct {
	CommandError         string       `json:"commandError,omitempty"`
	CommonsRepoAdded     string       `json:"commonsRepoAdded,omitempty"`
	CommandExecutionTime float64      `json:"commandExecutionTime"`
	MetricsAcceptance    string       `json:"metricsAcceptance,omitempty"`
	FormulaRepo          formula.Repo `json:"repo,omitempty"`
	Flags                []string     `json:"flags,omitempty"`
}

type DataCollectorManager

type DataCollectorManager struct {
	// contains filtered or unexported fields
}

func NewDataCollector

func NewDataCollector(
	userId UserIdGenerator,
	ritchieHomeDir string,
	file stream.FileReader,
) DataCollectorManager

func (DataCollectorManager) Collect

func (d DataCollectorManager) Collect(
	commandExecutionTime float64,
	ritVersion string,
	commandError ...string,
) (APIData, error)

type Id

type Id string

func (Id) String

func (i Id) String() string

type SendManagerHttp

type SendManagerHttp struct {
	URL string
	// contains filtered or unexported fields
}

func NewHttpSender

func NewHttpSender(url string, client *http.Client) SendManagerHttp

func (SendManagerHttp) Send

func (sm SendManagerHttp) Send(APIData APIData)

type SendManagerRpc

type SendManagerRpc struct {
	// contains filtered or unexported fields
}

func NewRpcSender

func NewRpcSender(processClient pb.ProcessorClient) SendManagerRpc

 Example of how to create a grpc client and processor client:
 ctx, cancel := context.WithTimeout(context.Background(), time.Second)
	defer cancel()
	conn, _ := grpc.DialContext(ctx, "localhost:50080", grpc.WithInsecure(), grpc.WithBlock())

	if conn != nil {
		defer conn.Close()
	}

	processorClient := pb.NewProcessorClient(conn)

func (SendManagerRpc) Send

func (sm SendManagerRpc) Send(apiData APIData)

type Sender

type Sender interface {
	Send(metric APIData)
}

type UserId

type UserId string

func (UserId) String

func (u UserId) String() string

type UserIdGenerator

type UserIdGenerator interface {
	Generate() (UserId, error)
}

type UserIdManager

type UserIdManager struct {
	// contains filtered or unexported fields
}

func NewUserIdGenerator

func NewUserIdGenerator() UserIdManager

func (UserIdManager) Generate

func (us UserIdManager) Generate() (UserId, error)