MCPcopy
hub / github.com/micro/go-micro / Write

Method Write

codec/bytes/bytes.go:43–57  ·  view source on GitHub ↗
(m *codec.Message, b interface{})

Source from the content-addressed store, hash-verified

41}
42
43func (c *Codec) Write(m *codec.Message, b interface{}) error {
44 var v []byte
45 switch vb := b.(type) {
46 case *Frame:
47 v = vb.Data
48 case *[]byte:
49 v = *vb
50 case []byte:
51 v = vb
52 default:
53 return fmt.Errorf("failed to write: %v is not type of *[]byte or []byte", b)
54 }
55 _, err := c.Conn.Write(v)
56 return err
57}
58
59func (c *Codec) Close() error {
60 return c.Conn.Close()

Callers

nothing calls this directly

Implementers 15

rpcCodecclient/rpc_codec.go
grpcCodecclient/grpc/codec.go
memoryModelmodel/memory.go
postgresModelmodel/postgres/postgres.go
sqliteModelmodel/sqlite/sqlite.go
fileStorestore/file.go
noopStorestore/noop.go
memoryStorestore/memory.go
sqlStorestore/postgres/postgres.go
sqlStorestore/postgres/pgx/pgx.go
natsStorestore/nats-js-kv/nats.go
sqlStorestore/mysql/mysql.go

Calls 2

WriteMethod · 0.65
ErrorfMethod · 0.45

Tested by

no test coverage detected