utils

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

type RPCTestMsg struct {
	Msg proto.Message
}

type RemoteJobStream struct {
	JobType   string                    `json:"jobType"`
	Metadata  RemoteJobStreamMetadata   `json:"metadata"`
	Consumers []RemoteJobStreamConsumer `json:"consumers"`
}

type RemoteJobStreamConsumer struct {
	ID       string `json:"id"`
	Receiver string `json:"receiver"`
}

type RemoteJobStreamMetadata struct {
	Worker         string   `json:"worker"`
	Timeout        int64    `json:"timeout"`
	FetchVariables []string `json:"fetchVariables"`
}

type SerializerMixin interface {
	Validate(string, string) error
	AsJSON(string, interface{}, bool) (string, error)
}