Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

v0.4.0 Latest Latest Go to latest Published: Nov 30, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/foohq/foojank

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Marshal(data any) ([]byte, error)
func ReplyMessageSubject(agentID, msgID string) string
func StartWorkerSubject(agentID, workerID string) string
func StopWorkerSubject(agentID, workerID string) string
func Unmarshal(b []byte) (any, error)
func UpdateClientInfoSubject(agentID string) string
func UpdateWorkerStatusSubject(agentID, workerID string) string
func WriteWorkerStdinSubject(agentID, workerID string) string
func WriteWorkerStdoutSubject(agentID, workerID string) string
type StartWorkerRequest
type StartWorkerResponse
type StopWorkerRequest
type StopWorkerResponse
type UpdateClientInfo
type UpdateWorkerStatus
type UpdateWorkerStdio

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrUnknownMessage = errors.New("unknown message")
)

Functions ¶

func Marshal ¶ added in v0.4.0

func Marshal(data any) ([]byte, error)

func ReplyMessageSubject ¶ added in v0.4.0

func ReplyMessageSubject(agentID, msgID string) string

func StartWorkerSubject ¶ added in v0.4.0

func StartWorkerSubject(agentID, workerID string) string

func StopWorkerSubject ¶ added in v0.4.0

func StopWorkerSubject(agentID, workerID string) string

func Unmarshal ¶ added in v0.4.0

func Unmarshal(b []byte) (any, error)

func UpdateClientInfoSubject ¶ added in v0.4.0

func UpdateClientInfoSubject(agentID string) string

func UpdateWorkerStatusSubject ¶ added in v0.4.0

func UpdateWorkerStatusSubject(agentID, workerID string) string

func WriteWorkerStdinSubject ¶ added in v0.4.0

func WriteWorkerStdinSubject(agentID, workerID string) string

func WriteWorkerStdoutSubject ¶ added in v0.4.0

func WriteWorkerStdoutSubject(agentID, workerID string) string

Types ¶

type StartWorkerRequest ¶ added in v0.4.0

type StartWorkerRequest struct {
	Command string
	Args    []string
	Env     []string
}

type StartWorkerResponse ¶ added in v0.4.0

type StartWorkerResponse struct {
	Error error
}

type StopWorkerRequest ¶ added in v0.4.0

type StopWorkerRequest struct{}

type StopWorkerResponse ¶ added in v0.4.0

type StopWorkerResponse struct {
	Error error
}

type UpdateClientInfo ¶ added in v0.4.0

type UpdateClientInfo struct {
	Username string
	Hostname string
	System   string
	Address  string
}

type UpdateWorkerStatus ¶ added in v0.4.0

type UpdateWorkerStatus struct {
	Status int64
}

type UpdateWorkerStdio ¶ added in v0.4.0

type UpdateWorkerStdio struct {
	Data []byte
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
capnp