pkg/stub/mangos.go

   1 /*
   2 ==================================================================================
   3   Copyright (c) 2019 AT&T Intellectual Property.
   4   Copyright (c) 2019 Nokia
   5
   6    Licensed under the Apache License, Version 2.0 (the "License");
   7    you may not use this file except in compliance with the License.
   8    You may obtain a copy of the License at
   9
  10        http://www.apache.org/licenses/LICENSE-2.0
  11
  12    Unless required by applicable law or agreed to in writing, software
  13    distributed under the License is distributed on an "AS IS" BASIS,
  14    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15    See the License for the specific language governing permissions and
  16    limitations under the License.
  17 ==================================================================================
  18 */
  19 /*
  20   Mnemonic:     mangos.go
  21   Abstract:
  22   Date:         3 May 2019
  23 */
  24
  25 package stub
  26
  27 import "errors"
  28
  29 type MangosMessage struct {
  30         Header []byte
  31         Body []byte
  32         Pipe MangosPipe
  33         bbuf  []byte
  34         hbuf  []byte
  35         bsize int
  36         pool  interface {}
  37 }
  38
  39 type MangosProtocolInfo struct {
  40         Self     uint16
  41         Peer     uint16
  42         SelfName string
  43         PeerName string
  44 }
  45
  46 // Mangos Listener Stub
  47
  48 type MangosListener struct {
  49
  50 }
  51
  52 func (l MangosListener) Listen() error {
  53         return nil
  54 }
  55
  56 func (l MangosListener) Close() error {
  57         return nil
  58 }
  59
  60 func (l MangosListener) Address() string {
  61         return ""
  62 }
  63
  64 func (l MangosListener) SetOption(s string, i interface{}) error {
  65         return nil
  66 }
  67
  68 func (l MangosListener) GetOption(s string) (interface{},error) {
  69         return nil, nil
  70 }
  71
  72 // Mangos Dialer Stub
  73
  74 type MangosDialer struct {
  75         }
  76
  77 func (d MangosDialer) Open() error {
  78         return nil
  79 }
  80
  81 func (d MangosDialer) Close() error {
  82         return nil
  83 }
  84
  85 func (d MangosDialer) Address() string {
  86         return ""
  87 }
  88
  89 func (d MangosDialer) SetOption(s string, i interface{}) error {
  90         return nil
  91 }
  92
  93 func (d MangosDialer) GetOption(s string) (interface{},error) {
  94         return nil, nil
  95 }
  96
  97 // Mangos Context Stub
  98
  99 type MangosContext struct {
 100
 101 }
 102
 103 func (c MangosContext) Close() error {
 104         return nil
 105 }
 106
 107 func (c MangosContext) SetOption(s string, i interface{}) error {
 108         return nil
 109 }
 110
 111 func (c MangosContext) GetOption(s string) (interface{},error) {
 112         return nil, nil
 113 }
 114
 115 func (c MangosContext) Send(b []byte) error {
 116         return nil
 117 }
 118
 119 func (c MangosContext) Recv() ([]byte, error) {
 120         return make([]byte,0), nil
 121 }
 122
 123 func (c MangosContext) SendMsg(*MangosMessage) error {
 124         return nil
 125 }
 126
 127 func (c MangosContext) RecvMsg() (*MangosMessage, error) {
 128         return nil, nil
 129 }
 130
 131 // Mangos Pipe Stub
 132
 133 type MangosPipe struct {
 134
 135 }
 136
 137 func (p MangosPipe) ID() uint32 {
 138         return 0
 139 }
 140
 141 func (p MangosPipe) Listener() MangosListener {
 142         return MangosListener{}
 143 }
 144
 145 func (p MangosPipe) Dialer() MangosDialer {
 146         return MangosDialer{}
 147 }
 148
 149 func (p MangosPipe) Close() error {
 150         return nil
 151 }
 152
 153 func (p MangosPipe) Address() string {
 154         return ""
 155 }
 156
 157 func (p MangosPipe) GetOption(s string) (interface{},error) {
 158         return nil, nil
 159 }
 160
 161 // Mangos PipeEventHook Stub
 162
 163 type PipeEventHook func(int, MangosPipe)
 164
 165 // Mangos Socket Stub
 166
 167 type MangosSocket struct {
 168         GenerateSocketCloseError bool
 169         GenerateSocketSendError bool
 170         GenerateSocketDialError bool
 171         GenerateSocketListenError bool
 172 }
 173
 174 func (s MangosSocket) Info() MangosProtocolInfo {
 175         return MangosProtocolInfo{}
 176 }
 177
 178 func (s MangosSocket) Close() error {
 179         if s.GenerateSocketCloseError {
 180                 return errors.New("stub generated Socket Close error")
 181         }
 182         return nil
 183 }
 184
 185 func (s MangosSocket) Send(b []byte) error {
 186         if s.GenerateSocketSendError {
 187                 return errors.New("stub generated Socket Send error")
 188         }
 189         return nil
 190 }
 191
 192 func (s MangosSocket) Recv() ([]byte, error) {
 193         return make([]byte,0), nil
 194 }
 195
 196 func (s MangosSocket) SendMsg(*MangosMessage) error {
 197         return nil
 198 }
 199
 200 func (s MangosSocket) RecvMsg() (*MangosMessage, error) {
 201         return nil, nil
 202 }
 203
 204 func (s MangosSocket) Dial(t string) error {
 205         if s.GenerateSocketDialError {
 206                 return errors.New("stub generated Socket Dial error")
 207         }
 208         return nil
 209 }
 210
 211 func (s MangosSocket) DialOptions(t string, m map[string]interface{}) error {
 212         if err := s.Dial(t); err != nil {
 213                 return err
 214         }
 215         return nil
 216 }
 217
 218 func (s MangosSocket) NewDialer(t string, m map[string]interface{}) (MangosDialer, error) {
 219         return MangosDialer{}, nil
 220 }
 221
 222 func (s MangosSocket) Listen(t string) error {
 223         if s.GenerateSocketListenError {
 224                 return errors.New("stub generated Socket Listen error")
 225         }
 226         return nil
 227 }
 228
 229 func (s MangosSocket) ListenOptions(t string, m map[string]interface{}) error {
 230         return nil
 231 }
 232
 233 func (s MangosSocket) NewListener(t string, m map[string]interface{}) (MangosListener, error) {
 234         return MangosListener{}, nil
 235 }
 236
 237 func (s MangosSocket) SetOption(t string, i interface{}) error {
 238         return nil
 239 }
 240
 241 func (s MangosSocket) GetOption(t string) (interface{},error) {
 242         return nil, nil
 243 }
 244
 245 func (s MangosSocket) OpenContext() (MangosContext, error) {
 246         return MangosContext{}, nil
 247 }
 248
 249 func (s MangosSocket) SetPipeEventHook(p PipeEventHook) PipeEventHook {
 250         return nil
 251 }
 252
 253 // Mangos ProtocolPipe Stub
 254
 255 type MangosProtocolPipe struct {
 256
 257 }
 258
 259 func (p MangosProtocolPipe) ID() uint32 {
 260         return 0
 261 }
 262
 263 func (p MangosProtocolPipe) Close() error {
 264         return nil
 265 }
 266
 267 func (p MangosProtocolPipe) SendMsg(m *MangosMessage) error {
 268         return nil
 269 }
 270
 271 func (p MangosProtocolPipe) RecvMsg() *MangosMessage {
 272         return nil
 273 }
 274
 275 // Mangos ProtocolContext Stub
 276
 277 type MangosProtocolContext struct {
 278
 279 }
 280
 281 func (p MangosProtocolContext) Close() error {
 282         return nil
 283 }
 284
 285 func (p MangosProtocolContext) SendMsg(m *MangosMessage) error {
 286         return nil
 287 }
 288
 289 func (p MangosProtocolContext) RecvMsg() (*MangosMessage, error) {
 290         return nil, nil
 291 }
 292
 293 func (p MangosProtocolContext) GetOption(s string) (interface{}, error) {
 294         return nil, nil
 295 }
 296
 297 func (p MangosProtocolContext) SetOption(s string, i interface{}) error {
 298         return nil
 299 }
 300
 301 // Mangos ProtocolBase Stub
 302
 303 type MangosProtocolBase struct {
 304         MangosProtocolContext
 305 }
 306
 307 func (p MangosProtocolBase) Info() MangosProtocolInfo {
 308         return MangosProtocolInfo{}
 309 }
 310
 311 func (p MangosProtocolBase) AddPipe(t MangosProtocolPipe) error {
 312         return nil
 313 }
 314
 315 func (p MangosProtocolBase) RemovePipe(MangosProtocolPipe) {
 316
 317 }
 318
 319 func (p MangosProtocolBase) OpenContext() (MangosProtocolContext, error) {
 320         return MangosProtocolContext{}, nil
 321 }