decoder

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 16, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Arguments

type Arguments struct {
	InputCh     <-chan connector.Message
	DataSubject string
	DataCh      chan<- Message
	StdinCh     chan<- Message
}

type ExecuteRequest

type ExecuteRequest struct {
	Args     []string
	FilePath string
}

type ExecuteResponse

type ExecuteResponse struct {
	Code int64
}

type Message

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

func (Message) Data

func (m Message) Data() any

func (Message) Reply

func (m Message) Reply(data any) error

func (Message) ReplyError

func (m Message) ReplyError(code string, description string, data any) error

type MessageError

type MessageError struct {
	Code        string
	Description string
}

type MessageResponse

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

func (MessageResponse) Data

func (m MessageResponse) Data() any

func (MessageResponse) Error

func (m MessageResponse) Error() *MessageError

func (MessageResponse) Request

func (m MessageResponse) Request() connector.Message

type Service

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

func New

func New(args Arguments) *Service

func (*Service) Start

func (s *Service) Start(ctx context.Context) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL