response.go

package kubemq

import (
	"context"
	"time"
)

type Response struct {
	RequestId  string
	ResponseTo string
	Metadata   string
	Body       []byte
	ClientId   string
	ExecutedAt time.Time
	Err        error
	Tags       map[string]string
	transport  Transport
	trace      *Trace
}

func NewResponse() *Response {
	return &Response{}
}

// SetId - set response corresponded requestId - mandatory
func (r *Response) SetRequestId(id string) *Response {
	r.RequestId = id
	return r
}

// SetResponseTo - set response channel as received in CommandReceived or QueryReceived object - mandatory
func (r *Response) SetResponseTo(channel string) *Response {
	r.ResponseTo = channel
	return r
}

// SetMetadata - set metadata response, for query only
func (r *Response) SetMetadata(metadata string) *Response {
	r.Metadata = metadata
	return r
}

// SetMetadata - set body response, for query only
func (r *Response) SetBody(body []byte) *Response {
	r.Body = body
	return r
}

// SetTags - set response tags
func (r *Response) SetTags(tags map[string]string) *Response {
	r.Tags = tags
	return r
}

// SetClientID - set clientId response, if not set default clientId will be used
func (r *Response) SetClientId(clientId string) *Response {
	r.ClientId = clientId
	return r
}

// SetError - set query or command execution error
func (r *Response) SetError(err error) *Response {
	r.Err = err
	return r
}

// SetExecutedAt - set query or command execution time
func (r *Response) SetExecutedAt(executedAt time.Time) *Response {
	r.ExecutedAt = executedAt
	return r
}

// AddTrace - add tracing support to response
func (r *Response) AddTrace(name string) *Trace {
	r.trace = CreateTrace(name)
	return r.trace
}

// Send - sending response to command or query request
func (r *Response) Send(ctx context.Context) error {
	return r.transport.SendResponse(ctx, r)
}

func (r *Response) String() string {
	return "Response: RequestId: " + r.RequestId + ", ResponseTo: " + r.ResponseTo + ", Metadata: " + r.Metadata + ", Body: " + string(r.Body) + ", ClientId: " + r.ClientId + ", ExecutedAt: " + r.ExecutedAt.String() + ", Err: " + r.Err.Error()
}