http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/bd3fb337/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 deleted file mode 100644 index 3bafe9c..0000000 --- a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a +++ /dev/null @@ -1,1100 +0,0 @@ -!<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 - -$$ - _go_.6 0 0 0 644 468572 ` -go object linux amd64 go1.4.2 X:precisestack - -! - go13ld@qpid.apache.org/proton/go/amqp.aFqpid.apache.org/proton/go/reactor.a -fmt.aio.aHqpid.apache.org/proton/go/internal.areflect.a time.aruntime/cgo.asyscall.a -net.a �"".newHandler � � dH� % H;aw� ��H��XH� H�$H�D$ � H�\$H�\$@H� H�$H�D$ � H�\$H�\$8H� H�$H�D$ � H�\$H�\$0H� H�$� H�L$H��H�� �� 1�� H�L$(H� $H�<$ �y H�$H�\$`H�\$� H�\$(H�$H�<$ �E H�$H�\$@H�\$� H�\$(H�$H�<$ � H�$H�\$8H�\$� H�\$(H�$H�<$ �� H�$ H�\$0H�\$� H�D$(H�D$ H�D$(H� 1�H9�tzH�L$(H�D$HH�$H�L$PH�L$� H�D$H�\$ H�$H�<$ t?H�D$� H�D$ H�HÇX H�1�@��Q H�1�@��P H�D$hH��XÃ% �H� H�$H� H�\$H� H�\$� H�D$�T����% �����% ������% �����% �{�����Y���, - 0runtime.morestack_noctxt : xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver ^ runtime.makemap � ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender � runtime.makemap � |type.map[qpid.apache.org/proton/go/reactor.Session]*"".session � runtime.makemap � type."".handler � "runtime.newobject �� runtime.duffzero � .runtime.writebarrierptr � .runtime.writebarrierptr � .runtime.writebarrierptr � .runtime.writebarrierptr � �go.itab.*"".handler.qpid.apache.org/proton/go/reactor.MessagingHandler � nqpid.apache.org/proton/go/reactor.NewMessagingDelegator � .runtime.writebarrierptr � type.*"".handler � ntype.qpid.apache.org/proton/go/reactor.MessagingHandler � �go.itab.*"".handler.qpid.apache.org/proton/go/reactor.MessagingHandler � runtime.typ2Itab � "".autotmp_0033 _ type.*"".handle r "".autotmp_0031 type.*"".handler "".autotmp_0030 O|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session "".autotmp_0029 ?ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender "".autotmp_0028 /xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver "".h o type.*"".handler "".~r1 type.*"".handler "".c &type.*"".Connection ����v � 4L##� Y - ;; 0 .##A(((:�J Tgclocals·a89e82532b08703817da6ad245f4f6c1 Tgclocals·afe2b15161969548d2683e49e081ad97 �/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/handler.go�D"".(*handler).HandleMessagingEvent �: �:dH� % H��$ ���H;Aw� ��H��` H��$h HÇ$� HÇ$� H��$p H�� �> H���t H��� H��$x H��$@ H��H��� H��$X H��$� H�$� �\$H�� H!Ã� �� 1�<