qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject [03/36] qpid-proton git commit: PROTON-827: Switch go directory and symlink locations, problems with some go tools.
Date Mon, 28 Sep 2015 21:22:47 GMT
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/9276ae33/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
----------------------------------------------------------------------
diff --git a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a b/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
new file mode 100644
index 0000000..3bafe9c
--- /dev/null
+++ b/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
@@ -0,0 +1,1100 @@
+!<arch>
+__.PKGDEF       0           0     0     644     63393     `
+go object linux amd64 go1.4.2 X:precisestack
+
+$$
+package messaging
+	import net "net"
+	import runtime "runtime"
+	import time "time"
+	import io "io"
+	import cgo "runtime/cgo"
+	import amqp "qpid.apache.org/proton/go/amqp"
+	import syscall "syscall"
+	import fmt "fmt"
+	import internal "qpid.apache.org/proton/go/internal"
+	import reflect "reflect"
+	import reactor "qpid.apache.org/proton/go/reactor"
+	import unsafe "unsafe"
+	var @"".Closed error
+	type @"".Endpoint interface { Close(? error); Error() (? error); Open() (? error); String() (? string) }
+	type @"".Link interface { Close(? error); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
+	type @"time".zone struct { @"time".name string; @"time".offset int; @"time".isDST bool }
+	type @"time".zoneTrans struct { @"time".when int64; @"time".index uint8; @"time".isstd bool; @"time".isutc bool }
+	type @"time".Location struct { @"time".name string; @"time".zone []@"time".zone; @"time".tx []@"time".zoneTrans; @"time".cacheStart int64; @"time".cacheEnd int64; @"time".cacheZone *@"time".zone }
+	func (@"time".l·2 *@"time".Location "esc:0x0") String () (? string)
+	func (@"time".l·2 *@"time".Location "esc:0x0") @"time".firstZoneUsed () (? bool)
+	func (@"time".l·2 *@"time".Location "esc:0x2") @"time".get () (? *@"time".Location)
+	func (@"time".l·6 *@"time".Location "esc:0x1") @"time".lookup (@"time".sec·7 int64) (@"time".name·1 string, @"time".offset·2 int, @"time".isDST·3 bool, @"time".start·4 int64, @"time".end·5 int64)
+	func (@"time".l·2 *@"time".Location "esc:0x0") @"time".lookupFirstZone () (? int)
+	func (@"time".l·4 *@"time".Location "esc:0x0") @"time".lookupName (@"time".name·5 string "esc:0x0", @"time".unix·6 int64) (@"time".offset·1 int, @"time".isDST·2 bool, @"time".ok·3 bool)
+	type @"time".Duration int64
+	func (@"time".d·2 @"time".Duration) Hours () (? float64) { var @"time".hour·3 @"time".Duration; ; @"time".hour·3 = @"time".d·2 / @"time".Duration(0x34630B8A000); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0x34630B8A000); return float64(@"time".hour·3) + float64(@"time".nsec·4) * 0x9C5FFF26ED75Fp-93 }
+	func (@"time".d·2 @"time".Duration) Minutes () (? float64) { var @"time".min·3 @"time".Duration; ; @"time".min·3 = @"time".d·2 / @"time".Duration(0xDF8475800); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0xDF8475800); return float64(@"time".min·3) + float64(@"time".nsec·4) * 0x9299FF347E9E9p-87 }
+	func (@"time".d·2 @"time".Duration) Nanoseconds () (? int64) { return int64(@"time".d·2) }
+	func (@"time".d·2 @"time".Duration) Seconds () (? float64) { var @"time".sec·3 @"time".Duration; ; @"time".sec·3 = @"time".d·2 / @"time".Duration(0x3B9ACA00); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0x3B9ACA00); return float64(@"time".sec·3) + float64(@"time".nsec·4) * 0x112E0BE826D695p-82 }
+	func (@"time".d·2 @"time".Duration) String () (? string)
+	type @"time".Month int
+	func (@"time".m·2 @"time".Month) String () (? string) { return @"time".months[@"time".m·2 - @"time".Month(0x1)] }
+	type @"time".Weekday int
+	func (@"time".d·2 @"time".Weekday) String () (? string) { return @"time".days[@"time".d·2] }
+	type @"time".Time struct { @"time".sec int64; @"time".nsec int32; @"time".loc *@"time".Location }
+	func (@"time".t·2 @"time".Time "esc:0x2") Add (@"time".d·3 @"time".Duration) (? @"time".Time)
+	func (@"time".t·2 @"time".Time "esc:0x2") AddDate (@"time".years·3 int, @"time".months·4 int, @"time".days·5 int) (? @"time".Time)
+	func (@"time".t·2 @"time".Time "esc:0x0") After (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec > @"time".u·3.@"time".sec || @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec > @"time".u·3.@"time".nsec }
+	func (@"time".t·2 @"time".Time "esc:0x0") Before (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec < @"time".u·3.@"time".sec || @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec < @"time".u·3.@"time".nsec }
+	func (@"time".t·4 @"time".Time "esc:0x0") Clock () (@"time".hour·1 int, @"time".min·2 int, @"time".sec·3 int)
+	func (@"time".t·4 @"time".Time "esc:0x0") Date () (@"time".year·1 int, @"time".month·2 @"time".Month, @"time".day·3 int)
+	func (@"time".t·2 @"time".Time "esc:0x0") Day () (? int)
+	func (@"time".t·2 @"time".Time "esc:0x0") Equal (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec == @"time".u·3.@"time".nsec }
+	func (@"time".t·2 @"time".Time "esc:0x0") Format (@"time".layout·3 string "esc:0x0") (? string)
+	func (@"time".t·2 *@"time".Time "esc:0x0") GobDecode (@"time".data·3 []byte "esc:0x0") (? error)
+	func (@"time".t·3 @"time".Time "esc:0x0") GobEncode () (? []byte, ? error)
+	func (@"time".t·2 @"time".Time "esc:0x0") Hour () (? int)
+	func (@"time".t·3 @"time".Time "esc:0x0") ISOWeek () (@"time".year·1 int, @"time".week·2 int)
+	func (@"time".t·2 @"time".Time "esc:0x2") In (@"time".loc·3 *@"time".Location "esc:0x2") (? @"time".Time)
+	func (@"time".t·2 @"time".Time "esc:0x0") IsZero () (? bool) { return @"time".t·2.@"time".sec == 0x0 && @"time".t·2.@"time".nsec == 0x0 }
+	func (@"time".t·2 @"time".Time "esc:0x2") Local () (? @"time".Time) { @"time".t·2.@"time".loc = @"time".Local; return @"time".t·2 }
+	func (@"time".t·2 @"time".Time "esc:0x2") Location () (? *@"time".Location) { var @"time".l·3 *@"time".Location; ; @"time".l·3 = @"time".t·2.@"time".loc; if @"time".l·3 == nil { @"time".l·3 = @"time".UTC }; return @"time".l·3 }
+	func (@"time".t·3 @"time".Time "esc:0x0") MarshalBinary () (? []byte, ? error)
+	func (@"time".t·3 @"time".Time "esc:0x0") MarshalJSON () (? []byte, ? error)
+	func (@"time".t·3 @"time".Time "esc:0x0") MarshalText () (? []byte, ? error)
+	func (@"time".t·2 @"time".Time "esc:0x0") Minute () (? int)
+	func (@"time".t·2 @"time".Time "esc:0x0") Month () (? @"time".Month)
+	func (@"time".t·2 @"time".Time "esc:0x0") Nanosecond () (? int) { return int(@"time".t·2.@"time".nsec) }
+	func (@"time".t·2 @"time".Time "esc:0x2") Round (@"time".d·3 @"time".Duration) (? @"time".Time)
+	func (@"time".t·2 @"time".Time "esc:0x0") Second () (? int)
+	func (@"time".t·2 @"time".Time "esc:0x0") String () (? string)
+	func (@"time".t·2 @"time".Time "esc:0x0") Sub (@"time".u·3 @"time".Time "esc:0x0") (? @"time".Duration)
+	func (@"time".t·2 @"time".Time "esc:0x2") Truncate (@"time".d·3 @"time".Duration) (? @"time".Time)
+	func (@"time".t·2 @"time".Time "esc:0x2") UTC () (? @"time".Time) { @"time".t·2.@"time".loc = @"time".UTC; return @"time".t·2 }
+	func (@"time".t·2 @"time".Time "esc:0x0") Unix () (? int64) { return @"time".t·2.@"time".sec + -0xE7791F700 }
+	func (@"time".t·2 @"time".Time "esc:0x0") UnixNano () (? int64) { return (@"time".t·2.@"time".sec + -0xE7791F700) * 0x3B9ACA00 + int64(@"time".t·2.@"time".nsec) }
+	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalBinary (@"time".data·3 []byte "esc:0x0") (? error)
+	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalJSON (@"time".data·3 []byte "esc:0x0") (@"time".err·1 error)
+	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalText (@"time".data·3 []byte "esc:0x0") (@"time".err·1 error)
+	func (@"time".t·2 @"time".Time "esc:0x0") Weekday () (? @"time".Weekday)
+	func (@"time".t·2 @"time".Time "esc:0x0") Year () (? int)
+	func (@"time".t·2 @"time".Time "esc:0x0") YearDay () (? int)
+	func (@"time".t·3 @"time".Time "esc:0x0") Zone () (@"time".name·1 string, @"time".offset·2 int)
+	func (@"time".t·2 @"time".Time "esc:0x0") @"time".abs () (? uint64)
+	func (@"time".t·5 @"time".Time "esc:0x0") @"time".date (@"time".full·6 bool) (@"time".year·1 int, @"time".month·2 @"time".Month, @"time".day·3 int, @"time".yday·4 int)
+	func (@"time".t·4 @"time".Time "esc:0x1") @"time".locabs () (@"time".name·1 string, @"time".offset·2 int, @"time".abs·3 uint64)
+	type @"qpid.apache.org/proton/go/amqp".Message interface { Address() (? string); Annotations() (? *map[string]interface {}); Body() (? interface {}); ContentEncoding() (? string); ContentType() (? string); CorrelationId() (? interface {}); CreationTime() (? @"time".Time); DeliveryCount() (? uint32); Durable() (? bool); Encode(@"qpid.apache.org/proton/go/amqp".buffer []byte) (? []byte, ? error); ExpiryTime() (? @"time".Time); FirstAcquirer() (? bool); GroupId() (? string); GroupSequence() (? int32); Inferred() (? bool); Instructions() (? *map[string]interface {}); MessageId() (? interface {}); Priority() (? uint8); Properties() (? *map[string]interface {}); ReplyTo() (? string); ReplyToGroupId() (? string); SetAddress(? string); SetBody(? interface {}); SetContentEncoding(? string); SetContentType(? string); SetCorrelationId(? interface {}); SetCreationTime(? @"time".Time); SetDeliveryCount(? uint32); SetDurable(? bool); SetExpiryTime(? @"time".Time); SetFirstAcquirer(? bool); SetGr
 oupId(? string); SetGroupSequence(? int32); SetInferred(? bool); SetMessageId(? interface {}); SetPriority(? uint8); SetReplyTo(? string); SetReplyToGroupId(? string); SetSubject(? string); SetTTL(? @"time".Duration); SetUserId(? string); Subject() (? string); TTL() (? @"time".Duration); UserId() (? string) }
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_delivery_t struct {}
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_link_t struct {}
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_condition_t struct {}
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_data_t struct {}
+	type @"qpid.apache.org/proton/go/reactor".Data struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_data_t }
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Clear ()
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Free ()
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Data "esc:0x2") Pointer () (? @"unsafe".Pointer) { return @"unsafe".Pointer(@"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn) }
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Rewind ()
+	type @"qpid.apache.org/proton/go/reactor".Condition struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_condition_t }
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Clear ()
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Description () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Info () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".c·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsRedirect () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsSet () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Name () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") RedirectHost () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") RedirectPort () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetDescription (@"qpid.apache.org/proton/go/reactor".description·3 string "esc:0x0") (? int)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetError (@"qpid.apache.org/proton/go/reactor".err·2 error)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetName (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? int)
+	type @"qpid.apache.org/proton/go/reactor".State uint8
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Is (@"qpid.apache.org/proton/go/reactor".bits·3 @"qpid.apache.org/proton/go/reactor".State) (? bool) { return @"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".bits·3 != @"qpid.apache.org/proton/go/reactor".State(0x0) }
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Local () (? @"qpid.apache.org/proton/go/reactor".State) { return @"qpid.apache.org/proton/go/reactor".State(@"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".State(0x7)) }
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Remote () (? @"qpid.apache.org/proton/go/reactor".State) { return @"qpid.apache.org/proton/go/reactor".State(@"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".State(0x38)) }
+	type @"qpid.apache.org/proton/go/reactor".RcvSettleMode uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".RcvSettleMode) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".SndSettleMode uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".SndSettleMode) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_terminus_t struct {}
+	type @"qpid.apache.org/proton/go/reactor".Durability uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Durability) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".ExpiryPolicy uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".ExpiryPolicy) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".DistributionMode uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".DistributionMode) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".TerminusType uint32
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".TerminusType) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".Terminus struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_terminus_t }
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Address () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Capabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Copy (@"qpid.apache.org/proton/go/reactor".src·3 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Durability () (? @"qpid.apache.org/proton/go/reactor".Durability)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") ExpiryPolicy () (? @"qpid.apache.org/proton/go/reactor".ExpiryPolicy)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Filter () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") IsDynamic () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".t·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Outcomes () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Properties () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetAddress (@"qpid.apache.org/proton/go/reactor".address·3 string "esc:0x0") (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDistributionMode (@"qpid.apache.org/proton/go/reactor".mode·3 @"qpid.apache.org/proton/go/reactor".DistributionMode) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDurability (@"qpid.apache.org/proton/go/reactor".durability·3 @"qpid.apache.org/proton/go/reactor".Durability) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDynamic (@"qpid.apache.org/proton/go/reactor".dynamic·3 bool) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetExpiryPolicy (@"qpid.apache.org/proton/go/reactor".policy·3 @"qpid.apache.org/proton/go/reactor".ExpiryPolicy) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetTimeout (@"qpid.apache.org/proton/go/reactor".timeout·3 @"time".Duration) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetType (@"qpid.apache.org/proton/go/reactor".type_·3 @"qpid.apache.org/proton/go/reactor".TerminusType) (? int)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Timeout () (? @"time".Duration)
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Type () (? @"qpid.apache.org/proton/go/reactor".TerminusType)
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_session_t struct {}
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_connection_t struct {}
+	import sync "sync" // indirect
+	type @"sync".Mutex struct { @"sync".state int32; @"sync".sema uint32 }
+	func (@"sync".m·1 *@"sync".Mutex) Lock ()
+	func (@"sync".m·1 *@"sync".Mutex) Unlock ()
+	type @"qpid.apache.org/proton/go/internal".FirstError struct { @"qpid.apache.org/proton/go/internal".err error; @"qpid.apache.org/proton/go/internal".lock @"sync".Mutex }
+	func (@"qpid.apache.org/proton/go/internal".e·2 *@"qpid.apache.org/proton/go/internal".FirstError) Get () (? error)
+	func (@"qpid.apache.org/proton/go/internal".e·2 *@"qpid.apache.org/proton/go/internal".FirstError) Set (@"qpid.apache.org/proton/go/internal".err·3 error) (? error)
+	type @"net".Addr interface { Network() (? string); String() (? string) }
+	type @"net".Conn interface { Close() (? error); LocalAddr() (? @"net".Addr); Read(@"net".b []byte) (@"net".n int, @"net".err error); RemoteAddr() (? @"net".Addr); SetDeadline(@"net".t @"time".Time) (? error); SetReadDeadline(@"net".t @"time".Time) (? error); SetWriteDeadline(@"net".t @"time".Time) (? error); Write(@"net".b []byte) (@"net".n int, @"net".err error) }
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_transport_t struct {}
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_collector_t struct {}
+	type @"qpid.apache.org/proton/go/reactor".bufferChan struct { @"qpid.apache.org/proton/go/reactor".buffers chan []byte; @"qpid.apache.org/proton/go/reactor".buf1 []byte; @"qpid.apache.org/proton/go/reactor".buf2 []byte }
+	func (@"qpid.apache.org/proton/go/reactor".b·2 *@"qpid.apache.org/proton/go/reactor".bufferChan) @"qpid.apache.org/proton/go/reactor".buffer () (? []byte) { @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1, @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf2 = @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf2, @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1; return @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1[:cap(@"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1)] }
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_event_t struct {}
+	type @"qpid.apache.org/proton/go/reactor".EventType int
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".EventType) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".Event struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_event_t; @"qpid.apache.org/proton/go/reactor".eventType @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".Connection; @"qpid.apache.org/proton/go/reactor".session @"qpid.apache.org/proton/go/reactor".Session; @"qpid.apache.org/proton/go/reactor".link @"qpid.apache.org/proton/go/reactor".Link; @"qpid.apache.org/proton/go/reactor".delivery @"qpid.apache.org/proton/go/reactor".Delivery }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".connection }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Delivery () (? @"qpid.apache.org/proton/go/reactor".Delivery) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".delivery }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".eventType == @"qpid.apache.org/proton/go/reactor".EventType(0x0) }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Link () (? @"qpid.apache.org/proton/go/reactor".Link) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".link }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Session () (? @"qpid.apache.org/proton/go/reactor".Session) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".session }
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") String () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") Type () (? @"qpid.apache.org/proton/go/reactor".EventType) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".eventType }
+	type @"qpid.apache.org/proton/go/reactor".EventHandler interface { HandleEvent(@"qpid.apache.org/proton/go/reactor".e @"qpid.apache.org/proton/go/reactor".Event) (? error) }
+	type @"sync".Once struct { @"sync".m @"sync".Mutex; @"sync".done uint32 }
+	func (@"sync".o·1 *@"sync".Once) Do (@"sync".f·2 func() "esc:0x0")
+	type @"qpid.apache.org/proton/go/reactor".Pump struct { @"qpid.apache.org/proton/go/reactor".err @"qpid.apache.org/proton/go/internal".FirstError; @"qpid.apache.org/proton/go/reactor".inject chan func(); @"qpid.apache.org/proton/go/reactor".conn @"net".Conn; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".Connection; @"qpid.apache.org/proton/go/reactor".transport *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_transport_t; @"qpid.apache.org/proton/go/reactor".collector *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_collector_t; @"qpid.apache.org/proton/go/reactor".read *@"qpid.apache.org/proton/go/reactor".bufferChan; @"qpid.apache.org/proton/go/reactor".write *@"qpid.apache.org/proton/go/reactor".bufferChan; @"qpid.apache.org/proton/go/reactor".handlers []@"qpid.apache.org/proton/go/reactor".EventHandler; @"qpid.apache.org/proton/go/reactor".running chan struct {}; @"qpid.apache.org/proton/go/reactor".closeOnce @"sync".Once }
+	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump) Close (@"qpid.apache.org/proton/go/reactor".err·2 error)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x1") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection) { return @"qpid.apache.org/proton/go/reactor".p·2.@"qpid.apache.org/proton/go/reactor".connection }
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Id () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Inject (@"qpid.apache.org/proton/go/reactor".f·3 func()) (? error)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) InjectWait (@"qpid.apache.org/proton/go/reactor".f·3 func()) (@"qpid.apache.org/proton/go/reactor".err·1 error)
+	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump) Run ()
+	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") Server ()
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) String () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".handle (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (? error)
+	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".pop (@"qpid.apache.org/proton/go/reactor".buf·2 *[]byte)
+	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".process () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".push (@"qpid.apache.org/proton/go/reactor".buf·2 []byte "esc:0x0")
+	type @"qpid.apache.org/proton/go/reactor".Connection struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_connection_t }
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Close ()
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Container () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") DesiredCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Free ()
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Hostname () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".c·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") LinkHead (@"qpid.apache.org/proton/go/reactor".s·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Links (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (@"qpid.apache.org/proton/go/reactor".links·1 []@"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") OfferedCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Open ()
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Properties () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Pump () (? *@"qpid.apache.org/proton/go/reactor".Pump)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Release ()
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteContainer () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteDesiredCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteHostname () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteOfferedCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteProperties () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Reset ()
+	func (@"qpid.apache.org/proton/go/reactor".c·3 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Session () (? @"qpid.apache.org/proton/go/reactor".Session, ? error)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SessionHead (@"qpid.apache.org/proton/go/reactor".s·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Session)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Sessions (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (@"qpid.apache.org/proton/go/reactor".sessions·1 []@"qpid.apache.org/proton/go/reactor".Session)
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetContainer (@"qpid.apache.org/proton/go/reactor".container·2 string "esc:0x0")
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetHostname (@"qpid.apache.org/proton/go/reactor".hostname·2 string "esc:0x0")
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetPassword (@"qpid.apache.org/proton/go/reactor".password·2 string "esc:0x0")
+	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetUser (@"qpid.apache.org/proton/go/reactor".user·2 string "esc:0x0")
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") String () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") User () (? string)
+	type @"qpid.apache.org/proton/go/reactor".Session struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_session_t }
+	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Close ()
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Free ()
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IncomingBytes () (? uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IncomingCapacity () (? uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".s·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Next (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Session)
+	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Open ()
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") OutgoingBytes () (? uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") OutgoingWindow () (? uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Receiver (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Sender (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") SetIncomingCapacity (@"qpid.apache.org/proton/go/reactor".capacity·2 uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") SetOutgoingWindow (@"qpid.apache.org/proton/go/reactor".window·2 uint)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
+	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".Link struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_link_t }
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Advance () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Available () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Close ()
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Credit () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Current () (? @"qpid.apache.org/proton/go/reactor".Delivery)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Delivery (@"qpid.apache.org/proton/go/reactor".tag·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Delivery)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Detach ()
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Drain (@"qpid.apache.org/proton/go/reactor".credit·2 int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Drained () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Draining () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Error () (? error)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Flow (@"qpid.apache.org/proton/go/reactor".credit·2 int)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Free ()
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsDrain () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".l·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsReceiver () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsSender () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Name () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Next (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Offered (@"qpid.apache.org/proton/go/reactor".credit·2 int)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Open ()
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Queued () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RcvSettleMode () (? @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Recv (@"qpid.apache.org/proton/go/reactor".buf·3 []byte "esc:0x0") (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteCredit () (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteRcvSettleMode () (? @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteSndSettleMode () (? @"qpid.apache.org/proton/go/reactor".SndSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteSource () (? @"qpid.apache.org/proton/go/reactor".Terminus)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteTarget () (? @"qpid.apache.org/proton/go/reactor".Terminus)
+	func (@"qpid.apache.org/proton/go/reactor".link·3 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Send (@"qpid.apache.org/proton/go/reactor".m·4 @"qpid.apache.org/proton/go/amqp".Message) (? @"qpid.apache.org/proton/go/reactor".Delivery, ? error)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SendBytes (@"qpid.apache.org/proton/go/reactor".bytes·3 []byte "esc:0x0") (? int)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Session () (? @"qpid.apache.org/proton/go/reactor".Session)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetDrain (@"qpid.apache.org/proton/go/reactor".drain·2 bool)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetRcvSettleMode (@"qpid.apache.org/proton/go/reactor".mode·2 @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetSndSettleMode (@"qpid.apache.org/proton/go/reactor".mode·2 @"qpid.apache.org/proton/go/reactor".SndSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SndSettleMode () (? @"qpid.apache.org/proton/go/reactor".SndSettleMode)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Source () (? @"qpid.apache.org/proton/go/reactor".Terminus)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") String () (? string)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Target () (? @"qpid.apache.org/proton/go/reactor".Terminus)
+	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Unsettled () (? int)
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_disposition_t struct {}
+	type @"qpid.apache.org/proton/go/reactor".Disposition struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_disposition_t }
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Annotations () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Data () (? @"qpid.apache.org/proton/go/reactor".Data)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsFailed () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsUndeliverable () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SectionNumber () (? uint16)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SectionOffset () (? uint64)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetFailed (@"qpid.apache.org/proton/go/reactor".failed·2 bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetSectionNumber (@"qpid.apache.org/proton/go/reactor".section_number·2 uint16)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetSectionOffset (@"qpid.apache.org/proton/go/reactor".section_offset·2 uint64)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetUndeliverable (@"qpid.apache.org/proton/go/reactor".undeliverable·2 bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Type () (? uint64)
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_size_t uint64
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_char int8
+	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct___0 struct { @"qpid.apache.org/proton/go/reactor".size @"qpid.apache.org/proton/go/reactor"._Ctype_size_t; @"qpid.apache.org/proton/go/reactor".start *@"qpid.apache.org/proton/go/reactor"._Ctype_char }
+	type @"qpid.apache.org/proton/go/reactor".DeliveryTag struct { @"qpid.apache.org/proton/go/reactor".pn @"qpid.apache.org/proton/go/reactor"._Ctype_struct___0 }
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".DeliveryTag) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".Delivery struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_delivery_t }
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Accept ()
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Buffered () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Clear ()
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Current () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Dump ()
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") HasMessage () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Link () (? @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Local () (? @"qpid.apache.org/proton/go/reactor".Disposition)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") LocalState () (? uint64)
+	func (@"qpid.apache.org/proton/go/reactor".delivery·3 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Message () (@"qpid.apache.org/proton/go/reactor".m·1 @"qpid.apache.org/proton/go/amqp".Message, @"qpid.apache.org/proton/go/reactor".err·2 error)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Partial () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Pending () (? uint)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Readable () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Reject ()
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Release (@"qpid.apache.org/proton/go/reactor".delivered·2 bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Remote () (? @"qpid.apache.org/proton/go/reactor".Disposition)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") RemoteState () (? uint64)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Settle ()
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") SettleAs (@"qpid.apache.org/proton/go/reactor".disposition·2 uint64)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Settled () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Tag () (? @"qpid.apache.org/proton/go/reactor".DeliveryTag)
+	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Update (@"qpid.apache.org/proton/go/reactor".state·2 uint64)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Updated () (? bool)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Writable () (? bool)
+	type @"".Disposition uint64
+	func (@"".d·2 @"".Disposition) String () (? string)
+	type @"".ReceivedMessage struct { Message @"qpid.apache.org/proton/go/amqp".Message; @"".eDelivery @"qpid.apache.org/proton/go/reactor".Delivery; @"".receiver @"".Receiver }
+	func (@"".rm·2 *@"".ReceivedMessage) Accept () (? error)
+	func (@"".rm·2 *@"".ReceivedMessage) Acknowledge (@"".disposition·3 @"".Disposition) (@"".err·1 error)
+	func (@"".rm·2 *@"".ReceivedMessage) Reject () (? error)
+	type @"".Receiver interface { AddCredit(@"".n int); Buffer() (? chan<- @"".ReceivedMessage); Close(? error); Credit() (@"".len int, @"".credit int, @"".max int); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); Receive() (? @"".ReceivedMessage, ? error); SetCapacity(@"".capacity int, @"".prefetch bool); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
+	type @"".errorHolder struct { @"".err @"qpid.apache.org/proton/go/internal".FirstError }
+	func (@"".e·2 *@"".errorHolder) Error () (? error)
+	func (@"".e·2 *@"".errorHolder) @"".setError (@"".err·3 error) (? error)
+	type @"".endpoint struct { ? @"".errorHolder; @"".str string }
+	func (@"".e·2 *@"".endpoint "esc:0x1") String () (? string) { return @"".e·2.@"".str }
+	type @"qpid.apache.org/proton/go/reactor".MessagingEventType int
+	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".MessagingEventType) String () (? string)
+	type @"qpid.apache.org/proton/go/reactor".MessagingHandler interface { HandleMessagingEvent(? @"qpid.apache.org/proton/go/reactor".MessagingEventType, ? @"qpid.apache.org/proton/go/reactor".Event) (? error) }
+	type @"qpid.apache.org/proton/go/reactor".Endpoint interface { Close(); Condition() (? @"qpid.apache.org/proton/go/reactor".Condition); Open(); RemoteCondition() (? @"qpid.apache.org/proton/go/reactor".Condition); State() (? @"qpid.apache.org/proton/go/reactor".State); String() (? string) }
+	type @"qpid.apache.org/proton/go/reactor".endpointDelegator struct { @"qpid.apache.org/proton/go/reactor".remoteOpen @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".remoteClose @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".localOpen @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".localClose @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".opening @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".opened @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".closing @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".closed @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".error @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".
 endpoint func(? @"qpid.apache.org/proton/go/reactor".Event) (? @"qpid.apache.org/proton/go/reactor".Endpoint); @"qpid.apache.org/proton/go/reactor".delegate @"qpid.apache.org/proton/go/reactor".MessagingHandler }
+	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".endpointDelegator) HandleEvent (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
+	type @"qpid.apache.org/proton/go/reactor".MessagingDelegator struct { @"qpid.apache.org/proton/go/reactor".delegate @"qpid.apache.org/proton/go/reactor".MessagingHandler; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".session @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".link @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".handshaker @"qpid.apache.org/proton/go/reactor".EventHandler; @"qpid.apache.org/proton/go/reactor".flowcontroller @"qpid.apache.org/proton/go/reactor".EventHandler; AutoSettle bool; AutoAccept bool; Prefetch int; PeerCloseError bool }
+	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) HandleEvent (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (? error)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) @"qpid.apache.org/proton/go/reactor".incoming (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
+	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) @"qpid.apache.org/proton/go/reactor".outgoing (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
+	type @"".sender struct { ? @"".link; @"".deliveries map[@"qpid.apache.org/proton/go/reactor".Delivery]*@"".SentMessage }
+	func (@"".s·1 *@"".sender) Close (@"".err·2 error)
+	func (@"".s·2 *@"".sender) Open () (@"".err·1 error)
+	func (@"".s·3 *@"".sender) Send (@"".m·4 @"qpid.apache.org/proton/go/amqp".Message) (@"".sm·1 *@"".SentMessage, @"".err·2 error)
+	func (@"".s·1 *@"".sender) @"".close (@"".err·2 error)
+	func (@"".s·1 *@"".sender "esc:0x0") @"".handleDelivery (@"".delivery·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0")
+	type @"".SentMessage struct { @"".sender *@"".sender; @"".eDelivery @"qpid.apache.org/proton/go/reactor".Delivery; @"".done chan struct {}; @"".disposition @"".Disposition }
+	func (@"".sm·3 *@"".SentMessage) Wait () (? @"".Disposition, ? error)
+	func (@"".sm·3 *@"".SentMessage) WaitTimeout (@"".timeout·4 @"time".Duration) (? @"".Disposition, ? error)
+	type @"".Sender interface { Close(? error); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); Send(@"".m @"qpid.apache.org/proton/go/amqp".Message) (@"".sm *@"".SentMessage, @"".err error); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
+	type @"".session struct { ? @"".endpoint; @"".eSession @"qpid.apache.org/proton/go/reactor".Session; @"".connection *@"".Connection }
+	func (@"".s·1 *@"".session) Close (@"".err·2 error)
+	func (@"".s·2 *@"".session "esc:0x1") Connection () (? *@"".Connection) { return @"".s·2.@"".connection }
+	func (@"".s·2 *@"".session) NewReceiver (@"".target·3 string) (@"".rcv·1 @"".Receiver)
+	func (@"".s·2 *@"".session) NewSender (@"".target·3 string) (@"".snd·1 @"".Sender)
+	func (@"".s·2 *@"".session) Open () (? error)
+	func (@"".s·2 *@"".session "esc:0x1") @"".eEndpoint () (? @"qpid.apache.org/proton/go/reactor".Endpoint) { return @"".s·2.@"".eSession }
+	func (@"".s·2 *@"".session "esc:0x1") @"".pump () (? *@"qpid.apache.org/proton/go/reactor".Pump) { return @"".s·2.@"".connection.@"".pump }
+	type @"".link struct { ? @"".endpoint; @"".session *@"".session; @"".isSender bool; @"".eLink @"qpid.apache.org/proton/go/reactor".Link; @"".name string; @"".source string; @"".target string; @"".isOpen bool }
+	func (@"".l·2 *@"".link "esc:0x1") Connection () (? *@"".Connection)
+	func (@"".l·2 *@"".link "esc:0x0") IsOpen () (? bool) { return @"".l·2.@"".isOpen }
+	func (@"".l·2 *@"".link "esc:0x0") IsReceiver () (? bool) { return !@"".l·2.@"".isSender }
+	func (@"".l·2 *@"".link "esc:0x0") IsSender () (? bool) { return @"".l·2.@"".isSender }
+	func (@"".l·2 *@"".link "esc:0x1") Name () (? string) { return @"".l·2.@"".name }
+	func (@"".l·2 *@"".link "esc:0x1") Session () (? @"".Session) { return @"".l·2.@"".session }
+	func (@"".l·1 *@"".link) SetName (@"".s·2 string)
+	func (@"".l·1 *@"".link) SetSource (@"".s·2 string)
+	func (@"".l·1 *@"".link) SetTarget (@"".s·2 string)
+	func (@"".l·2 *@"".link "esc:0x1") Source () (? string) { return @"".l·2.@"".source }
+	func (@"".l·2 *@"".link "esc:0x1") Target () (? string) { return @"".l·2.@"".target }
+	func (@"".l·1 *@"".link) @"".close (@"".err·2 error)
+	func (@"".l·2 *@"".link "esc:0x0") @"".handler () (? *@"".handler)
+	func (@"".l·2 *@"".link) @"".localSetup () (? error)
+	func (@"".l·2 *@"".link) @"".open () (? error)
+	func (@"".l·2 *@"".link "esc:0x0") @"".pump () (? *@"qpid.apache.org/proton/go/reactor".Pump)
+	func (@"".l·1 *@"".link) @"".setPanicIfLink ()
+	func (@"".l·1 *@"".link) @"".setPanicIfOpen ()
+	func (@"".l·1 *@"".link) @"".setString ()
+	type @"".policy interface { Post(? *@"".receiver, ? error); Pre(? *@"".receiver) }
+	type @"".receiver struct { ? @"".link; @"".capacity int; @"".prefetch bool; @"".buffer chan @"".ReceivedMessage; @"".policy @"".policy }
+	func (@"".r·1 *@"".receiver) AddCredit (@"".n·2 int)
+	func (@"".r·2 *@"".receiver "esc:0x1") Buffer () (? chan<- @"".ReceivedMessage) { return @"".r·2.@"".buffer }
+	func (@"".r·2 *@"".receiver "esc:0x0") Capacity () (? int) { return cap(@"".r·2.@"".buffer) }
+	func (@"".r·1 *@"".receiver) Close (@"".err·2 error)
+	func (@"".r·4 *@"".receiver) Credit () (@"".buffered·1 int, @"".credit·2 int, @"".capacity·3 int)
+	func (@"".r·2 *@"".receiver) Open () (@"".err·1 error)
+	func (@"".r·3 *@"".receiver) Receive () (@"".rm·1 @"".ReceivedMessage, @"".err·2 error)
+	func (@"".r·1 *@"".receiver) SetCapacity (@"".capacity·2 int, @"".prefetch·3 bool)
+	func (@"".r·1 *@"".receiver) @"".close (@"".err·2 error)
+	func (@"".r·4 *@"".receiver "esc:0x0") @"".credit () (@"".buffered·1 int, @"".credit·2 int, @"".capacity·3 int)
+	func (@"".r·1 *@"".receiver) @"".handleDelivery (@"".delivery·2 @"qpid.apache.org/proton/go/reactor".Delivery)
+	type @"".handler struct { @"".delegator *@"qpid.apache.org/proton/go/reactor".MessagingDelegator; @"".connection *@"".Connection; @"".receivers map[@"qpid.apache.org/proton/go/reactor".Link]*@"".receiver; @"".senders map[@"qpid.apache.org/proton/go/reactor".Link]*@"".sender; @"".sessions map[@"qpid.apache.org/proton/go/reactor".Session]*@"".session }
+	func (@"".h·2 *@"".handler) HandleMessagingEvent (@"".t·3 @"qpid.apache.org/proton/go/reactor".MessagingEventType, @"".e·4 @"qpid.apache.org/proton/go/reactor".Event) (? error)
+	func (@"".h·1 *@"".handler "esc:0x0") @"".close ()
+	type @"qpid.apache.org/proton/go/amqp".UidCounter struct { @"qpid.apache.org/proton/go/amqp".count uint64 }
+	func (@"qpid.apache.org/proton/go/amqp".uc·2 *@"qpid.apache.org/proton/go/amqp".UidCounter) Next () (? string)
+	func (@"qpid.apache.org/proton/go/amqp".uc·2 *@"qpid.apache.org/proton/go/amqp".UidCounter) NextInt () (? uint64)
+	type @"qpid.apache.org/proton/go/internal".FlexChannel struct { In chan<- interface {}; Out <-chan interface {}; @"qpid.apache.org/proton/go/internal".in chan interface {}; @"qpid.apache.org/proton/go/internal".out chan interface {}; @"qpid.apache.org/proton/go/internal".buffer []interface {}; @"qpid.apache.org/proton/go/internal".limit int }
+	func (@"qpid.apache.org/proton/go/internal".fc·1 *@"qpid.apache.org/proton/go/internal".FlexChannel) @"qpid.apache.org/proton/go/internal".run ()
+	type @"net".Listener interface { Accept() (@"net".c @"net".Conn, @"net".err error); Addr() (? @"net".Addr); Close() (? error) }
+	type @"".Connection struct { Server bool; AllowIncoming int; LinkPrefix string; ? @"".endpoint; @"".handler *@"".handler; @"".pump *@"qpid.apache.org/proton/go/reactor".Pump; @"".err @"qpid.apache.org/proton/go/internal".FirstError; @"".linkNames @"qpid.apache.org/proton/go/amqp".UidCounter; @"".eConnection @"qpid.apache.org/proton/go/reactor".Connection; @"".incoming *@"qpid.apache.org/proton/go/internal".FlexChannel }
+	func (@"".c·2 *@"".Connection) Accept (@"".l·3 @"net".Listener) (? error)
+	func (@"".c·1 *@"".Connection) Close (@"".err·2 error)
+	func (@"".c·2 *@"".Connection) Dial (@"".network·3 string, @"".address·4 string) (? error)
+	func (@"".c·3 *@"".Connection) Incoming () (? @"".Endpoint, ? error)
+	func (@"".c·3 *@"".Connection) IncomingTimeout (@"".timeout·4 @"time".Duration) (? @"".Endpoint, ? error)
+	func (@"".c·2 *@"".Connection) Open (@"".conn·3 @"net".Conn) (@"".err·1 error)
+	func (@"".c·3 *@"".Connection) OpenSession () (@"".s·1 @"".Session, @"".err·2 error)
+	func (@"".c·1 *@"".Connection) @"".close (@"".err·2 error)
+	func (@"".c·1 *@"".Connection "esc:0x0") @"".handleIncoming (@"".sn·2 *@"".session, @"".l·3 @"qpid.apache.org/proton/go/reactor".Link)
+	func (@"".c·2 *@"".Connection) @"".nextLinkName () (? string)
+	type @"".Session interface { Close(? error); Connection() (? *@"".Connection); Error() (? error); NewReceiver(@"".target string) (? @"".Receiver); NewSender(@"".target string) (? @"".Sender); Open() (? error); String() (? string) }
+	type @"qpid.apache.org/proton/go/internal".Error string
+	func (@"qpid.apache.org/proton/go/internal".e·2 @"qpid.apache.org/proton/go/internal".Error "esc:0x0") Error () (? string) { return "proton: " + string(@"qpid.apache.org/proton/go/internal".e·2) }
+	var @"".Timeout @"qpid.apache.org/proton/go/internal".Error
+	const @"".Forever @"time".Duration = -0x1
+	const @"".Unlimited = -0x1
+	const @"".NoDisposition @"".Disposition = 0x0
+	const @"".Accepted = 0x24
+	const @"".Rejected = 0x25
+	const @"".Released = 0x26
+	func @"".init ()
+	var @"time".months [12]string
+	var @"time".days [7]string
+	var @"time".Local *@"time".Location
+	var @"time".UTC *@"time".Location
+
+$$
+
Mime
View raw message