Class: Langfuse::CLI::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/langfuse/cli/client.rb

Defined Under Namespace

Classes: APIError, AuthenticationError, NotFoundError, RateLimitError, TimeoutError

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(config) ⇒ Client



16
17
18
19
20
21
# File 'lib/langfuse/cli/client.rb', line 16

def initialize(config)
  @host = config.host
  @public_key = config.public_key
  @secret_key = config.secret_key
  @connection = build_connection
end

Instance Attribute Details

#hostObject (readonly)

Returns the value of attribute host.



14
15
16
# File 'lib/langfuse/cli/client.rb', line 14

def host
  @host
end

#public_keyObject (readonly)

Returns the value of attribute public_key.



14
15
16
# File 'lib/langfuse/cli/client.rb', line 14

def public_key
  @public_key
end

Instance Method Details

#get_observation(observation_id) ⇒ Object



49
50
51
# File 'lib/langfuse/cli/client.rb', line 49

def get_observation(observation_id)
  request(:get, "/api/public/observations/#{observation_id}")
end

#get_score(score_id) ⇒ Object



64
65
66
# File 'lib/langfuse/cli/client.rb', line 64

def get_score(score_id)
  request(:get, "/api/public/scores/#{score_id}")
end

#get_session(session_id) ⇒ Object



39
40
41
# File 'lib/langfuse/cli/client.rb', line 39

def get_session(session_id)
  request(:get, "/api/public/sessions/#{session_id}")
end

#get_trace(trace_id) ⇒ Object



29
30
31
# File 'lib/langfuse/cli/client.rb', line 29

def get_trace(trace_id)
  request(:get, "/api/public/traces/#{trace_id}")
end

#list_observations(filters = {}) ⇒ Object

Observations API



44
45
46
47
# File 'lib/langfuse/cli/client.rb', line 44

def list_observations(filters = {})
  params = build_observation_params(filters)
  paginate('/api/public/observations', params)
end

#list_scores(filters = {}) ⇒ Object

Scores API



59
60
61
62
# File 'lib/langfuse/cli/client.rb', line 59

def list_scores(filters = {})
  params = build_score_params(filters)
  paginate('/api/public/scores', params)
end

#list_sessions(filters = {}) ⇒ Object

Sessions API



34
35
36
37
# File 'lib/langfuse/cli/client.rb', line 34

def list_sessions(filters = {})
  params = build_session_params(filters)
  paginate('/api/public/sessions', params)
end

#list_traces(filters = {}) ⇒ Object

Traces API



24
25
26
27
# File 'lib/langfuse/cli/client.rb', line 24

def list_traces(filters = {})
  params = build_trace_params(filters)
  paginate('/api/public/traces', params)
end

#query_metrics(query_params) ⇒ Object

Metrics API



54
55
56
# File 'lib/langfuse/cli/client.rb', line 54

def query_metrics(query_params)
  request(:post, '/api/public/metrics', query_params)
end