coolmsg

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

type ClientOptions struct {
	MaxResponseSize uint64
	// If nil, defaults to DefaultRegistry
	Registry *Registry
}

type Clunk struct{}

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

type ConnServerOptions struct {
	MaxRequestSize uint64
	// Each connection will stop reading new
	// requests if this is exceeded, zero
	// means unlimited.
	MaxOutstandingRequests uint64
	// This function is used to create the root object
	// a client can send messages to.
	//
	// It takes a connection object as a way for out of band connection
	// information to be used while creating the root object.
	// One example is using a unix socket to get the remote user id,
	// and then using that for authentication.
	BootstrapFunc func(io.ReadWriteCloser) Object
	// If nil, defaults to DefaultRegistry
	Registry *Registry
}

type Error struct {
	Code    uint64
	Display string
	Debug   string
}

type Message interface {
	CoolMsg_TypeId() uint64
	CoolMsg_Marshal() []byte
	// The buffer is guaranteed to be read only.
	// This means zero copy references into the
	// buffer are okay (and encouraged).
	CoolMsg_Unmarshal([]byte) bool
}

type Object interface {
	Message(context.Context, *ConnServer, Message, RespondFunc)
	UnknownMessage(context.Context, *ConnServer, uint64, []byte, RespondFunc)
	Clunk(*ConnServer)
}

type ObjectRef struct {
	Id uint64
}

type Ok struct{}

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

type Request struct {
	RequestId   uint64
	ObjectId    uint64
	MessageType uint64
	// Modifying this buffer is an error.
	MessageData []byte
}

type RespondFunc func(Message)

type Response struct {
	RequestId    uint64
	ResponseType uint64
	// Modifying this buffer is an error.
	ResponseData []byte
}

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

type ServerOptions struct {
	ConnOptions ConnServerOptions
}