transaction

type AWSTransactionHandler ¶

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

func NewAWSTransactionHandler(maxTimeout time.Duration) *AWSTransactionHandler

func (h *AWSTransactionHandler) Handle(
	ctx *gin.Context,
	session_id string,
)

type AWSTransactionWriter ¶

type AWSTransactionWriter struct {
	backwards_invocation.BackwardsInvocationWriter
	// contains filtered or unexported fields
}

AWSTransactionWriter is a writer that implements the backwards_invocation.BackwardsInvocationWriter interface it is used to write data to the plugin runtime

func NewAWSTransactionWriter(
	session *session_manager.Session,
	writeFlushCloser WriteFlushCloser,
) *AWSTransactionWriter

func (w *AWSTransactionWriter) Done()

func (w *AWSTransactionWriter) Write(event session_manager.PLUGIN_IN_STREAM_EVENT, data any) error

type FullDuplexTransactionWriter ¶

type FullDuplexTransactionWriter struct {
	backwards_invocation.BackwardsInvocationWriter
	// contains filtered or unexported fields
}

FullDuplexTransactionWriter is a writer that implements the backwards_invocation.BackwardsInvocationWriter interface write data into session

func NewFullDuplexEventWriter(session *session_manager.Session) *FullDuplexTransactionWriter

func (w *FullDuplexTransactionWriter) Done()

func (w *FullDuplexTransactionWriter) Write(event session_manager.PLUGIN_IN_STREAM_EVENT, data any) error

type WriteFlushCloser ¶

type WriteFlushCloser interface {
	io.WriteCloser

	Flush()
}