protocol

type Observations struct {

	// Height of the blockchain block when processing the service request through a relay
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// Shannon protocol-specific observations
	Shannon *ShannonObservationsList `protobuf:"bytes,3,opt,name=shannon,proto3" json:"shannon,omitempty"`
	// contains filtered or unexported fields
}

type ShannonEndpointErrorType int32

type ShannonEndpointObservation struct {

	// Supplier of the endpoint handling the request
	Supplier string `protobuf:"bytes,1,opt,name=supplier,proto3" json:"supplier,omitempty"`
	// URL of the endpoint handling the request
	EndpointUrl string `protobuf:"bytes,2,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	// Application address associated with the endpoint
	EndpointAppAddress string `protobuf:"bytes,3,opt,name=endpoint_app_address,json=endpointAppAddress,proto3" json:"endpoint_app_address,omitempty"`
	// Service ID of the session associated with the endpoint.
	SessionServiceId string `protobuf:"bytes,4,opt,name=session_service_id,json=sessionServiceId,proto3" json:"session_service_id,omitempty"`
	// Session ID of the session associated with the endpoint.
	SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// session start height
	SessionStartHeight int64 `protobuf:"varint,6,opt,name=session_start_height,json=sessionStartHeight,proto3" json:"session_start_height,omitempty"`
	// session end height
	SessionEndHeight int64 `protobuf:"varint,7,opt,name=session_end_height,json=sessionEndHeight,proto3" json:"session_end_height,omitempty"`
	// Timestamp marking the sending of the request to the endpoint.
	EndpointQueryTimestamp *timestamppb.Timestamp `` /* 129-byte string literal not displayed */
	// Timestamp marking the reception of the endpoint's response.
	// Only set if the endpoint did not timeout.
	EndpointResponseTimestamp *timestamppb.Timestamp `` /* 144-byte string literal not displayed */
	// Error type if relay to this endpoint failed
	ErrorType *ShannonEndpointErrorType `` /* 140-byte string literal not displayed */
	// Additional error details when available
	ErrorDetails *string `protobuf:"bytes,11,opt,name=error_details,json=errorDetails,proto3,oneof" json:"error_details,omitempty"`
	// RelayMiner error details if the endpoint returned a RelayMinerError
	RelayMinerError *ShannonRelayMinerError `protobuf:"bytes,12,opt,name=relay_miner_error,json=relayMinerError,proto3,oneof" json:"relay_miner_error,omitempty"`
	// HTTP status code of the endpoint response
	EndpointBackendServiceHttpResponseStatusCode *int32 `` /* 211-byte string literal not displayed */
	// HTTP Response payload size
	EndpointBackendServiceHttpResponsePayloadSize *int64 `` /* 214-byte string literal not displayed */
	// TODO_TECHDEBT(@adshmh): Separate fallback endpoints into a separate message:
	// Most of fields above (e.g. session_id) only apply to a Shannon endpoint.
	//
	// TODO_CONSIDERATION(@adshmh): Consider renaming to is_gateway_owned OR is_off_protocol.
	//
	// Tracks whether the endpoint is a fallback endpoint.
	IsFallbackEndpoint bool `protobuf:"varint,15,opt,name=is_fallback_endpoint,json=isFallbackEndpoint,proto3" json:"is_fallback_endpoint,omitempty"`
	// contains filtered or unexported fields
}

type ShannonHTTPEndpointObservations struct {

	// Multiple observations possible if:
	// - Original endpoint returns invalid response
	// - Retry mechanism activates
	EndpointObservations []*ShannonEndpointObservation `protobuf:"bytes,1,rep,name=endpoint_observations,json=endpointObservations,proto3" json:"endpoint_observations,omitempty"`
	// contains filtered or unexported fields
}

type ShannonObservationsList struct {
	Observations []*ShannonRequestObservations `protobuf:"bytes,1,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

type ShannonRelayMinerError struct {

	// Codespace from the RelayMinerError
	Codespace string `protobuf:"bytes,1,opt,name=codespace,proto3" json:"codespace,omitempty"`
	// Code from the RelayMinerError
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// Message from the RelayMinerError
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ShannonRequestError struct {

	// Type of request error, e.g. internal
	ErrorType ShannonRequestErrorType `` /* 132-byte string literal not displayed */
	// Details of the request error.
	ErrorDetails string `protobuf:"bytes,2,opt,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// contains filtered or unexported fields
}

type ShannonRequestErrorType int32

type ShannonRequestObservations struct {

	// Service ID (i.e. chain ID) for which the observation was made
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// Error encountered processing the request, if any.
	RequestError *ShannonRequestError `protobuf:"bytes,2,opt,name=request_error,json=requestError,proto3,oneof" json:"request_error,omitempty"`
	// Observation data - exactly one of the following will be set
	//
	// Types that are valid to be assigned to ObservationData:
	//
	//	*ShannonRequestObservations_HttpObservations
	//	*ShannonRequestObservations_WebsocketConnectionObservation
	//	*ShannonRequestObservations_WebsocketMessageObservation
	ObservationData isShannonRequestObservations_ObservationData `protobuf_oneof:"observation_data"`
	// contains filtered or unexported fields
}

type ShannonRequestObservations_HttpObservations struct {
	// HTTP endpoint observations (multiple possible due to retries)
	HttpObservations *ShannonHTTPEndpointObservations `protobuf:"bytes,3,opt,name=http_observations,json=httpObservations,proto3,oneof"`
}

type ShannonRequestObservations_WebsocketConnectionObservation struct {
	// Single Websocket connection lifecycle observation
	WebsocketConnectionObservation *ShannonWebsocketConnectionObservation `protobuf:"bytes,4,opt,name=websocket_connection_observation,json=websocketConnectionObservation,proto3,oneof"`
}

type ShannonRequestObservations_WebsocketMessageObservation struct {
	// Single Websocket message observation
	WebsocketMessageObservation *ShannonWebsocketMessageObservation `protobuf:"bytes,5,opt,name=websocket_message_observation,json=websocketMessageObservation,proto3,oneof"`
}

type ShannonWebsocketConnectionObservation struct {

	// Supplier of the endpoint handling the Websocket connection
	Supplier string `protobuf:"bytes,1,opt,name=supplier,proto3" json:"supplier,omitempty"`
	// URL of the Websocket endpoint
	EndpointUrl string `protobuf:"bytes,2,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	// Application address associated with the endpoint
	EndpointAppAddress string `protobuf:"bytes,3,opt,name=endpoint_app_address,json=endpointAppAddress,proto3" json:"endpoint_app_address,omitempty"`
	// Service ID of the session associated with the endpoint.
	SessionServiceId string `protobuf:"bytes,4,opt,name=session_service_id,json=sessionServiceId,proto3" json:"session_service_id,omitempty"`
	// Session ID of the session associated with the endpoint.
	SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// session start height
	SessionStartHeight int64 `protobuf:"varint,6,opt,name=session_start_height,json=sessionStartHeight,proto3" json:"session_start_height,omitempty"`
	// session end height
	SessionEndHeight int64 `protobuf:"varint,7,opt,name=session_end_height,json=sessionEndHeight,proto3" json:"session_end_height,omitempty"`
	// Error type if Websocket connection establishment or operation failed
	ErrorType *ShannonEndpointErrorType `` /* 139-byte string literal not displayed */
	// Additional error details when available
	ErrorDetails *string `protobuf:"bytes,9,opt,name=error_details,json=errorDetails,proto3,oneof" json:"error_details,omitempty"`
	// Tracks whether the endpoint is a fallback endpoint
	IsFallbackEndpoint bool `protobuf:"varint,10,opt,name=is_fallback_endpoint,json=isFallbackEndpoint,proto3" json:"is_fallback_endpoint,omitempty"`
	// Connection lifecycle timestamps
	ConnectionEstablishedTimestamp *timestamppb.Timestamp                                    `` /* 154-byte string literal not displayed */
	ConnectionClosedTimestamp      *timestamppb.Timestamp                                    `` /* 145-byte string literal not displayed */
	EventType                      ShannonWebsocketConnectionObservation_ConnectionEventType `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ShannonWebsocketConnectionObservation_ConnectionEventType int32

type ShannonWebsocketMessageObservation struct {

	// Supplier of the endpoint handling the Websocket message
	Supplier string `protobuf:"bytes,1,opt,name=supplier,proto3" json:"supplier,omitempty"`
	// URL of the Websocket endpoint
	EndpointUrl string `protobuf:"bytes,2,opt,name=endpoint_url,json=endpointUrl,proto3" json:"endpoint_url,omitempty"`
	// Application address associated with the endpoint
	EndpointAppAddress string `protobuf:"bytes,3,opt,name=endpoint_app_address,json=endpointAppAddress,proto3" json:"endpoint_app_address,omitempty"`
	// Service ID of the session associated with the endpoint.
	SessionServiceId string `protobuf:"bytes,4,opt,name=session_service_id,json=sessionServiceId,proto3" json:"session_service_id,omitempty"`
	// Session ID of the session associated with the endpoint.
	SessionId string `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// session start height
	SessionStartHeight int64 `protobuf:"varint,6,opt,name=session_start_height,json=sessionStartHeight,proto3" json:"session_start_height,omitempty"`
	// session end height
	SessionEndHeight int64 `protobuf:"varint,7,opt,name=session_end_height,json=sessionEndHeight,proto3" json:"session_end_height,omitempty"`
	// Timestamp marking when the message was sent to the endpoint
	// For subscription events, this represents when the event was received from endpoint
	MessageTimestamp *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=message_timestamp,json=messageTimestamp,proto3" json:"message_timestamp,omitempty"`
	// Size of the message payload in bytes
	MessagePayloadSize int64 `protobuf:"varint,9,opt,name=message_payload_size,json=messagePayloadSize,proto3" json:"message_payload_size,omitempty"`
	// Error type if message processing failed
	ErrorType *ShannonEndpointErrorType `` /* 140-byte string literal not displayed */
	// Additional error details when available
	ErrorDetails *string `protobuf:"bytes,11,opt,name=error_details,json=errorDetails,proto3,oneof" json:"error_details,omitempty"`
	// RelayMiner error details if the endpoint returned a RelayMinerError for this message
	RelayMinerError *ShannonRelayMinerError `protobuf:"bytes,12,opt,name=relay_miner_error,json=relayMinerError,proto3,oneof" json:"relay_miner_error,omitempty"`
	// Tracks whether the endpoint is a fallback endpoint
	IsFallbackEndpoint bool `protobuf:"varint,13,opt,name=is_fallback_endpoint,json=isFallbackEndpoint,proto3" json:"is_fallback_endpoint,omitempty"`
	// contains filtered or unexported fields
}