session

Documentation

Index

• Constants
• type Body
• type Request
• type Response
• type Session
  • func NewSession(ctx context.Context, endpoint string, machineID string, ...) *Session
  • func (s *Session) Stop()

Constants

const DefaultQuerySince = 30 * time.Minute

Types

type Body

type Body struct {
	Data  []byte `json:"data,omitempty"`
	ReqID string `json:"req_id,omitempty"`
}

type Request

type Request struct {
	Method        string        `json:"method,omitempty"`
	Components    []string      `json:"components,omitempty"`
	StartTime     time.Time     `json:"start_time"`
	EndTime       time.Time     `json:"end_time"`
	Since         time.Duration `json:"since"`
	UpdateVersion string        `json:"update_version,omitempty"`
}

type Response

type Response struct {
	Error   error            `json:"error,omitempty"`
	States  v1.LeptonStates  `json:"states,omitempty"`
	Events  v1.LeptonEvents  `json:"events,omitempty"`
	Metrics v1.LeptonMetrics `json:"metrics,omitempty"`
}

type Session

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

func NewSession

func NewSession(ctx context.Context, endpoint string, machineID string, pipeInterval time.Duration) *Session

func (*Session) Stop

func (s *Session) Stop()