connection

package

Go to main page

Versions in this module

v3

v3.2.0

Apr 7, 2021

Changes in this version

type BaseCommandConnection

+ func (bcc *BaseCommandConnection) GetObjectModel() (*machine.MachineModel, error)

+ func (bcc *BaseCommandConnection) GetSerializedObjectModel() (json.RawMessage, error)

+ func (bcc *BaseCommandConnection) InstallPlugin(pluginFile string) error

+ func (bcc *BaseCommandConnection) LockObjectModel() error

+ func (bcc *BaseCommandConnection) PatchObjectModel(key, value string) error

+ func (bcc *BaseCommandConnection) SetObjectModel(path, value string) (bool, error)

+ func (bcc *BaseCommandConnection) SetPluginData(plugin, key, value string) error

+ func (bcc *BaseCommandConnection) SetUpdateStatus(updating bool) error

+ func (bcc *BaseCommandConnection) StartPlugin(plugin string) error

+ func (bcc *BaseCommandConnection) StopPlugin(plugin string) error

+ func (bcc *BaseCommandConnection) SyncObjectModel() error

+ func (bcc *BaseCommandConnection) UninstallPlugin(plugin string) error

+ func (bcc *BaseCommandConnection) UnlockObjectModel() error

+ func (bcc *BaseCommandConnection) WriteMessage(message messages.Message, outputMessage, logMessage bool) error

+ func (bcc *BaseCommandConnection) WriteTextMessage(mType messages.MessageType, message string, outputMessage, logMessage bool) error

type InterceptConnection

+ Channels []types.CodeChannel

+ Filters []string

+ PriorityCodes bool

type SubscribeConnection

+ Filters []string

v3.1.1

May 19, 2020

v3.1.0

May 18, 2020

Changes in this version

+ const DefaultBacklog

+ const FullSocketPath

+ const IncompatibleVersionException

+ const SocketDirectory

+ const SocketFile

+ const TaskCanceledException

+ func CloseOnSignals(c Closer)

+ type BaseCommandConnection struct

+ func (bcc *BaseCommandConnection) AddHttpEndpoint(t httpendpoints.HttpEndpointType, ns, path string, backlog uint64) (*HttpEndpointUnixSocket, error)

+ func (bcc *BaseCommandConnection) AddUserSession(access usersessions.AccessLevel, t usersessions.SessionType, origin string, ...) (int, error)

+ func (bcc *BaseCommandConnection) Flush(channel types.CodeChannel) (bool, error)

+ func (bcc *BaseCommandConnection) GetFileInfo(fileName string) (*job.ParsedFileInfo, error)

+ func (bcc *BaseCommandConnection) GetMachineModel() (*machine.MachineModel, error)

+ func (bcc *BaseCommandConnection) GetSerializedMachineModel() (json.RawMessage, error)

+ func (bcc *BaseCommandConnection) LockMachineModel() error

+ func (bcc *BaseCommandConnection) PerformCode(code *commands.Code) (*commands.CodeResult, error)

+ func (bcc *BaseCommandConnection) PerformSimpleCode(code string, channel types.CodeChannel) (string, error)

+ func (bcc *BaseCommandConnection) RemoveHttpEndpoint(t httpendpoints.HttpEndpointType, ns, path string) (bool, error)

+ func (bcc *BaseCommandConnection) RemoveUserSession(id int) (bool, error)

+ func (bcc *BaseCommandConnection) ResolvePath(path string) (string, error)

+ func (bcc *BaseCommandConnection) SetMachineModel(path, value string) (bool, error)

+ func (bcc *BaseCommandConnection) SyncMachineModel() error

+ func (bcc *BaseCommandConnection) UnlockMachineModel() error

+ type BaseConnection struct

+ Debug bool

+ func (bc *BaseConnection) Close() error

+ func (bc *BaseConnection) Connect(initMessage initmessages.ClientInitMessage, socketPath string) error

+ func (bc *BaseConnection) PerformCommand(command commands.Command) (commands.Response, error)

+ func (bc *BaseConnection) Receive(responseContainer interface{}) error

+ func (bc *BaseConnection) ReceiveJSONString() (string, error)

+ func (bc *BaseConnection) ReceiveJson() ([]byte, error)

+ func (bc *BaseConnection) ReceiveResponse() (commands.Response, error)

+ func (bc *BaseConnection) Send(data interface{}) error

+ type Closer interface

+ Close func() error

+ type CommandConnection struct

+ func (cc *CommandConnection) Connect(socketPath string) error

+ type DecodeError struct

+ Err error

+ Target string

+ func (e *DecodeError) Error() string

+ func (e *DecodeError) Unwrap() error

+ type HttpEndpointConnection struct

+ func NewHttpEndpointConnection(c net.Conn, isWebSocket bool) *HttpEndpointConnection

+ func (h *HttpEndpointConnection) Close() error

+ func (h *HttpEndpointConnection) ReadRequest() (*commands.ReceivedHttpRequest, error)

+ func (h *HttpEndpointConnection) Receive(responseContainer interface{}) error

+ func (h *HttpEndpointConnection) ReceiveJson() (string, error)

+ func (h *HttpEndpointConnection) Send(data interface{}) error

+ func (h *HttpEndpointConnection) SendResponse(statusCode uint16, response string, t commands.HttpResponseType) error

+ type HttpEndpointHandler interface

+ Handle func(h *HttpEndpointUnixSocket, c *HttpEndpointConnection)

+ type HttpEndpointUnixSocket struct

+ EndpointPath string

+ EndpointType httpendpoints.HttpEndpointType

+ Handler HttpEndpointHandler

+ Namespace string

+ SocketPath string

+ func NewHttpEndpointUnixSocket(t httpendpoints.HttpEndpointType, ns, path, socketPath string, backlog uint64) (*HttpEndpointUnixSocket, error)

+ func (h *HttpEndpointUnixSocket) Close() error

+ type InterceptConnection struct

+ Mode initmessages.InterceptionMode

+ func (ic *InterceptConnection) CancelCode() error

+ func (ic *InterceptConnection) Connect(mode initmessages.InterceptionMode, socketPath string) error

+ func (ic *InterceptConnection) IgnoreCode() error

+ func (ic *InterceptConnection) ReceiveCode() (*commands.Code, error)

+ func (ic *InterceptConnection) ResolveCode(mType messages.MessageType, content string) error

+ type SubscribeConnection struct

+ Filter string

+ Mode initmessages.SubscriptionMode

+ func (sc *SubscribeConnection) Connect(mode initmessages.SubscriptionMode, filter, socketPath string) error

+ func (sc *SubscribeConnection) GetMachineModel() (*machine.MachineModel, error)

+ func (sc *SubscribeConnection) GetMachineModelPatch() (string, error)

Other modules containing this package

github.com/Duet3D/DSF-APIs/godsfapi

github.com/Duet3D/DSF-APIs/godsfapi/v2

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