54 lines
1.4 KiB
Go
54 lines
1.4 KiB
Go
package message
|
|
|
|
import (
|
|
"context"
|
|
|
|
"git.asio.asia/nixevol/NixMsg/internal/app/port"
|
|
"git.asio.asia/nixevol/NixMsg/internal/protocol"
|
|
)
|
|
|
|
// Stub 是测试用假实现：方法返回 ErrNotImplemented 或固定空结果。
|
|
type Stub struct{}
|
|
|
|
func NewStub() *Stub { return &Stub{} }
|
|
|
|
func (s *Stub) Submit(context.Context, string, port.ConnInfo, *protocol.Send) (SubmitResult, error) {
|
|
return SubmitResult{}, ErrNotImplemented
|
|
}
|
|
|
|
func (s *Stub) Ack(context.Context, string, *protocol.Ack) (AckResult, error) {
|
|
return AckResult{}, ErrNotImplemented
|
|
}
|
|
|
|
func (s *Stub) Recall(context.Context, string, *protocol.Recall) (protocol.RecallData, error) {
|
|
return protocol.RecallData{}, ErrNotImplemented
|
|
}
|
|
|
|
func (s *Stub) Status(context.Context, string, *protocol.Status) (any, error) {
|
|
return nil, ErrNotImplemented
|
|
}
|
|
|
|
func (s *Stub) ReceiptAck(context.Context, string, *protocol.ReceiptAck) error {
|
|
return ErrNotImplemented
|
|
}
|
|
|
|
func (s *Stub) DispatchDue(context.Context, int64, int) (int, error) {
|
|
return 0, nil
|
|
}
|
|
|
|
func (s *Stub) PushPending(context.Context, string, port.ConnID) error {
|
|
return nil
|
|
}
|
|
|
|
func (s *Stub) OnPublishDropped(context.Context, string, port.ConnID, []byte) error {
|
|
return nil
|
|
}
|
|
|
|
func (s *Stub) CleanupOnce(context.Context, int64) error { return nil }
|
|
|
|
func (s *Stub) RecoverOnStart(context.Context) error { return nil }
|
|
|
|
func (s *Stub) WakePush(string) {}
|
|
|
|
var _ Service = (*Stub)(nil)
|