Response

This script defines the Response class and its associated types for handling responses from the control interface. It includes methods for parsing the received messages and converting them into appropriate Python objects.

Classes

• Response:

  Represents a response from the control interface.

• UpdateStateSuccess:

  Represents a response for a successful update state request.

• LogEntry:

  Represents a log entry from a workload instance.

• LogsStopResponse:

  Represents a response for marking the end of the log stream from a workload instance.

Enums

• ResponseType:

  Enumeration for the different types of response. It includes ERROR, COMPLETE_STATE, and UPDATE_STATE_SUCCESS and CONNECTION_CLOSED.

Union Types

• LogResponse:

  Union type for log responses, which can be either LogEntry or LogsStopResponse.

Usage

• Get response content:

  response = Response()
  (content_type, content) = response.get_content()
  

• Check if the request_id matches:

  response = Response()
  if response.check_request_id("1234"):
      print("Request ID matches")
  

• Convert the update state success to a dictionary:

  update_state_success = UpdateStateSuccess()
  update_state_success.to_dict()
  

Response Class

class ankaios_sdk._components.response.Response(message_buffer)

Bases: object

Represents a response received from the Ankaios system.

buffer

The received message buffer.

Type:

bytes

content_type

The type of the response content (e.g., “error”, “complete_state”, “update_state_success”).

Type:

str

content

The content of the response, which can be a string, CompleteState, or UpdateStateSuccess.

__init__(message_buffer)

Initializes the Response object with the received message buffer.

Parameters:

message_buffer (bytes) – The received message buffer.

get_request_id()

Gets the request id of the response.

Returns:

The request id of the response.

Return type:

str

get_content()

Gets the content of the response. It can be either:

• a string (error / connection closed)

• a CompleteState object

• an UpdateStateSuccess object

• a list of log entires

• a log stop response

Returns:

the content type and the content.

Return type:

tuple[ResponseType, any]

UpdateStateSuccess Class

class ankaios_sdk._components.response.UpdateStateSuccess

Bases: object

Represents an object that holds the added and deleted workloads. This is automatically returned whenever a state update is successful.

__init__()

Initializes the UpdateStateSuccess.

to_dict()

Converts the UpdateStateSuccess to a dictionary.

Returns:

The dictionary representation.

Return type:

dict

__str__()

Converts the UpdateStateSuccess to a string.

Returns:

The string representation.

Return type:

str

ResponseType Enum

class ankaios_sdk._components.response.ResponseType(value)

Bases: Enum

Enumeration for the different types of response.

ERROR = 1

Got an error from Ankaios.

Type:

(int)

CONTROL_INTERFACE_ACCEPTED = 2

Control interface connection accepted.

Type:

(int)

COMPLETE_STATE = 3

Got the complete state.

Type:

(int)

UPDATE_STATE_SUCCESS = 4

Got a successful update state response.

Type:

(int)

LOGS_ENTRY = 5

Got logs entry.

Type:

(int)

LOGS_REQUEST_ACCEPTED = 6

Logs request accepted, waiting for logs.

Type:

(int)

LOGS_STOP_RESPONSE = 7

Got logs stop response.

Type:

(int)

LOGS_CANCEL_ACCEPTED = 8

Logs cancel request accepted.

Type:

(int)

CONNECTION_CLOSED = 9

Connection closed by the server.

Type:

(int)

__str__()

Converts the ResponseType to a string.

Returns:

The string representation of the ResponseType.

Return type:

str

LogResponse Union Type

ankaios_sdk._components.response.LogResponse

alias of LogEntry | LogsStopResponse

LogEntry Class

class ankaios_sdk._components.response.LogEntry(workload_instance_name, message)

Bases: object

Represents a log entry from a workload instance.

__init__(workload_instance_name, message)

workload_instance_name: WorkloadInstanceName

The name of the workload instance from which the log entry was received.

message: str

The log message.

__str__()

Converts the LogEntry to a string.

Returns:

The string representation of the LogEntry.

Return type:

str

LogsStopResponse Class

class ankaios_sdk._components.response.LogsStopResponse(workload_instance_name)

Bases: object

Represents a response for marking the end of the log stream from a workload instance.

__init__(workload_instance_name)

workload_instance_name: WorkloadInstanceName

The name of the workload instance from which no more logs will be sent.

__str__()

Converts the LogsStopResponse to a string.

Returns:

The string representation of the LogsStopResponse.

Return type:

str