Documentation ¶
Index ¶
- Constants
- func FileRemove(path string) error
- func FileRemoveAll(path string) error
- func PacketDepKey() string
- type Arena
- type ArenaMode
- type File
- type FileOptions
- type Middleware
- type Packet
- type PrpcClient
- type PrpcConnection
- type PrpcServer
- type PrpcTopic
- type PubSubTopic
- type Publisher
- type Reader
- type ReaderInit
- type ReaderIter
- type ReaderSync
- type RpcClient
- type RpcRequest
- type RpcServer
- type RpcTopic
- type Subscriber
- type SubscriberSync
- type Writer
Constants ¶
View Source
const ( A0_OK = C.A0_OK A0_ERR_SYS = C.A0_ERR_SYS A0_ERR_CUSTOM_MSG = C.A0_ERR_CUSTOM_MSG A0_ERR_INVALID_ARG = C.A0_ERR_INVALID_ARG A0_ERR_RANGE = C.A0_ERR_RANGE A0_ERR_AGAIN = C.A0_ERR_AGAIN A0_ERR_ITER_DONE = C.A0_ERR_ITER_DONE A0_ERR_NOT_FOUND = C.A0_ERR_NOT_FOUND A0_ERR_FRAME_LARGE = C.A0_ERR_FRAME_LARGE A0_ERR_BAD_TOPIC = C.A0_ERR_BAD_TOPIC )
View Source
const ( INIT_OLDEST ReaderInit = C.A0_INIT_OLDEST INIT_MOST_RECENT = C.A0_INIT_MOST_RECENT INIT_AWAIT_NEW = C.A0_INIT_AWAIT_NEW )
Variables ¶
This section is empty.
Functions ¶
func FileRemove ¶
func FileRemoveAll ¶
func PacketDepKey ¶
func PacketDepKey() string
Types ¶
type ArenaMode ¶
type ArenaMode C.a0_arena_mode_t
const ( MODE_SHARED ArenaMode = C.A0_ARENA_MODE_SHARED MODE_EXCLUSIVE ArenaMode = C.A0_ARENA_MODE_EXCLUSIVE MODE_READONLY ArenaMode = C.A0_ARENA_MODE_READONLY )
type FileOptions ¶
type FileOptions struct { CreateOptions struct { Size int Mode int DirMode int } OpenOptions struct { ArenaMode ArenaMode } }
func MakeDefaultFileOptions ¶
func MakeDefaultFileOptions() (opts FileOptions)
type Middleware ¶
type Middleware struct {
// contains filtered or unexported fields
}
func AddStandardHeaders ¶
func AddStandardHeaders() Middleware
func AddTimeMonoHeader ¶
func AddTimeMonoHeader() Middleware
func AddTimeWallHeader ¶
func AddTimeWallHeader() Middleware
func AddTransportSeqHeader ¶
func AddTransportSeqHeader() Middleware
func AddWriterIdHeader ¶
func AddWriterIdHeader() Middleware
func AddWriterSeqHeader ¶
func AddWriterSeqHeader() Middleware
type Packet ¶
func ReaderReadOne ¶
func ReaderReadOne(file File, init ReaderInit, flags int) (pkt Packet, err error)
func SubscriberReadOne ¶
func SubscriberReadOne(topic PubSubTopic, init ReaderInit, flags int) (pkt Packet, err error)
type PrpcClient ¶
type PrpcClient struct {
// contains filtered or unexported fields
}
func NewPrpcClient ¶
func NewPrpcClient(topic PrpcTopic) (rc *PrpcClient, err error)
func (*PrpcClient) Cancel ¶
func (rc *PrpcClient) Cancel(reqId string) error
func (*PrpcClient) Close ¶
func (rc *PrpcClient) Close() (err error)
type PrpcConnection ¶
type PrpcConnection struct {
// contains filtered or unexported fields
}
func (*PrpcConnection) Packet ¶
func (conn *PrpcConnection) Packet() Packet
type PrpcServer ¶
type PrpcServer struct {
// contains filtered or unexported fields
}
func NewPrpcServer ¶
func NewPrpcServer(topic PrpcTopic, onconnect func(PrpcConnection), oncancel func(string)) (ps *PrpcServer, err error)
func (*PrpcServer) Close ¶
func (ps *PrpcServer) Close() (err error)
type PrpcTopic ¶
type PrpcTopic struct { Name string FileOptions *FileOptions }
type PubSubTopic ¶
type PubSubTopic struct { Name string FileOptions *FileOptions }
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
func NewPublisher(topic PubSubTopic) (p *Publisher, err error)
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func NewReader ¶
func NewReader(arena Arena, init ReaderInit, iter ReaderIter, callback func(Packet)) (r *Reader, err error)
type ReaderInit ¶
type ReaderInit int
type ReaderIter ¶
type ReaderIter int
const ( ITER_NEXT ReaderIter = C.A0_ITER_NEXT ITER_NEWEST = C.A0_ITER_NEWEST )
type ReaderSync ¶
type ReaderSync struct {
// contains filtered or unexported fields
}
func NewReaderSync ¶
func NewReaderSync(arena Arena, init ReaderInit, iter ReaderIter) (rs *ReaderSync, err error)
func (*ReaderSync) Close ¶
func (rs *ReaderSync) Close() (err error)
func (*ReaderSync) HasNext ¶
func (rs *ReaderSync) HasNext() (hasNext bool, err error)
func (*ReaderSync) Next ¶
func (rs *ReaderSync) Next() (pkt Packet, err error)
type RpcClient ¶
type RpcClient struct {
// contains filtered or unexported fields
}
func NewRpcClient ¶
type RpcRequest ¶
type RpcRequest struct {
// contains filtered or unexported fields
}
func (*RpcRequest) Packet ¶
func (req *RpcRequest) Packet() Packet
func (*RpcRequest) Reply ¶
func (req *RpcRequest) Reply(resp Packet) error
type RpcServer ¶
type RpcServer struct {
// contains filtered or unexported fields
}
func NewRpcServer ¶
func NewRpcServer(topic RpcTopic, onrequest func(RpcRequest), oncancel func(string)) (rs *RpcServer, err error)
type RpcTopic ¶
type RpcTopic struct { Name string FileOptions *FileOptions }
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func NewSubscriber ¶
func NewSubscriber(topic PubSubTopic, init ReaderInit, iter ReaderIter, callback func(Packet)) (s *Subscriber, err error)
func (*Subscriber) Close ¶
func (s *Subscriber) Close() (err error)
type SubscriberSync ¶
type SubscriberSync struct {
// contains filtered or unexported fields
}
func NewSubscriberSync ¶
func NewSubscriberSync(topic PubSubTopic, init ReaderInit, iter ReaderIter) (ss *SubscriberSync, err error)
func (*SubscriberSync) Close ¶
func (ss *SubscriberSync) Close() (err error)
func (*SubscriberSync) HasNext ¶
func (ss *SubscriberSync) HasNext() (hasNext bool, err error)
func (*SubscriberSync) Next ¶
func (ss *SubscriberSync) Next() (pkt Packet, err error)
Click to show internal directories.
Click to hide internal directories.