nan0

package module

Go to main page

Versions in this module

v2

v2.5.3

Sep 12, 2020

v2.5.2

Sep 6, 2020

v2.5.1

Sep 6, 2020

Changes in this version

+ func AwaitNSignals(c chan struct{}, n int)

+ func CheckAndDo(awaitedCondition func() bool, do func())

+ func CheckAndDoWithDuration(awaitedCondition func() bool, do func(), after time.Duration)

+ func DoAfterFirstSignal(c chan struct{}, action func())

+ func DoAfterNSignals(c chan struct{}, n int, action func())

+ func MaxConnections(max int) baseBuilderOption

+ func MaxIdleDuration(duration time.Duration) baseBuilderOption

+ func PurgeConnectionsAfter(duration time.Duration) baseBuilderOption

type ConnectionHandler

+ ActiveConnectionsCount func() int

type Nan0

+ func (n Nan0) LastComm() time.Time

type NanoServer

+ func (server NanoServer) ActiveConnectionsCount() int

type TxRx

+ LastComm func() time.Time

type WsNan0

+ func (n WsNan0) LastComm() time.Time

v2.5.0

Sep 1, 2020

Changes in this version

+ const DefaultRoute

+ func Route(messageIdent proto.Message, route ExecutableRoute) baseBuilderOption

+ type ExecutableRoute interface

+ Execute func(msg proto.Message, sender chan<- interface{})

+ type RouteMap map[string]ExecutableRoute

v2.4.4

Aug 30, 2020

v2.4.3

Aug 29, 2020

v2.4.2

Jul 21, 2020

v2.4.1

Jul 21, 2020

v2.4.0

Jul 20, 2020

Changes in this version

+ func AddOrigins(origin ...string) wsBuilderOption

+ func AppendOrigins(origin ...*url.URL) wsBuilderOption

+ func SecureWs(config TLSConfig) wsBuilderOption

v2.3.0

Jul 20, 2020

Changes in this version

+ var File_apiKey_proto protoreflect.FileDescriptor

+ var File_mdns_definition_proto protoreflect.FileDescriptor

+ var File_service_proto protoreflect.FileDescriptor

+ func AddMessageIdentities(messageIdents ...proto.Message) baseBuilderOption

+ func AddMessageIdentity(messageIdent proto.Message) baseBuilderOption

+ func CheckHMAC(data, suppliedMAC []byte, key *[32]byte) bool

+ func Decrypt(ciphertext []byte, key *[32]byte) (plaintext []byte, err error)

+ func DecryptProtobuf(rawData []byte, msg proto.Message, hmacSize int, decryptKey *[32]byte, ...) (err error)

+ func Default() clientDNSStrategy

+ func Encrypt(plaintext []byte, key *[32]byte) (ciphertext []byte, err error)

+ func EncryptProtobuf(pb proto.Message, typeVal int, encryptKey *[32]byte, hmacKey *[32]byte) []byte

+ func GenerateHMAC(data []byte, key *[32]byte) []byte

+ func Insecure(bb *baseBuilder)

+ func NewEncryptionKey() *[32]byte

+ func NewHMACKey() *[32]byte

+ func ReceiveBuffer(receiveBuffer int) baseBuilderOption

+ func Secure(bb *baseBuilder)

+ func SendBuffer(sendBuffer int) baseBuilderOption

+ func ServiceDiscovery(bb *baseBuilder)

+ func ToggleWriteDeadline(writeDeadline bool) baseBuilderOption

+ func WithTimeout(duration time.Duration) clientDNSStrategy

+ type ApiKey struct

+ EncKey []byte

+ HmacKey []byte

+ func (*ApiKey) Descriptor() ([]byte, []int)

+ func (*ApiKey) ProtoMessage()

+ func (x *ApiKey) GetEncKey() []byte

+ func (x *ApiKey) GetHmacKey() []byte

+ func (x *ApiKey) ProtoReflect() protoreflect.Message

+ func (x *ApiKey) Reset()

+ func (x *ApiKey) String() string

+ type ClientDNSFactory func(strictProtocols bool) (nan0 NanoServiceWrapper, err error)

+ func BuildDNS(ctx context.Context, bb *baseBuilder, clientBuilder nanoClientFactory, ...) ClientDNSFactory

+ type Closer interface

+ Close func()

+ IsClosed func() bool

+ type ConnectionHandler interface

+ AddConnection func(NanoServiceWrapper)

+ GetConnections func() <-chan NanoServiceWrapper

type ConnectionInfo

+ func (x *ConnectionInfo) ProtoReflect() protoreflect.Message

+ type DiscoverableService interface

+ MdnsTag func() string

+ type Equality interface

+ Equals func(NanoServiceWrapper) bool

+ type Identity interface

+ GetServiceName func() string

type MDefinition

+ func (x *MDefinition) ProtoReflect() protoreflect.Message

type NanoBuilder

+ func (nsb *NanoBuilder) BuildNanoClient(opts ...baseBuilderOption) (nan0 NanoServiceWrapper, err error)

+ func (nsb *NanoBuilder) BuildNanoDNS(ctx context.Context, strategy clientDNSStrategy, opts ...baseBuilderOption) ClientDNSFactory

+ func (nsb *NanoBuilder) BuildNanoServer(opts ...baseBuilderOption) (*NanoServer, error)

type NanoServer

+ func (server NanoServer) MdnsTag() string

+ type Receiver interface

+ GetReceiver func() <-chan interface{}

+ type Sender interface

+ GetSender func() chan<- interface{}

type Service

+ func (ns *Service) NewWebsocketBuilder() *WebsocketBuilder

+ func (x *Service) ProtoReflect() protoreflect.Message

+ type ServiceLifecycle interface

+ IsShutdown func() bool

+ Shutdown func()

+ type TxRx interface

+ type WebsocketBuilder struct

+ func (wsb *WebsocketBuilder) AddOrigins(origin ...string) baseBuilderOption

+ func (wsb *WebsocketBuilder) AppendOrigins(origin ...*url.URL) baseBuilderOption

+ func (wsb *WebsocketBuilder) BuildWebsocketClient(opts ...baseBuilderOption) (nan0 NanoServiceWrapper, err error)

+ func (wsb *WebsocketBuilder) BuildWebsocketDNS(ctx context.Context, strategy clientDNSStrategy, opts ...baseBuilderOption) ClientDNSFactory

+ func (wsb *WebsocketBuilder) BuildWebsocketServer(opts ...baseBuilderOption) (*NanoServer, error)

+ func (wsb *WebsocketBuilder) Secure(config *TLSConfig) baseBuilderOption

v2.2.2

Jul 18, 2020

Changes in this version

+ var MaxNanoCache = 50

+ var ProtoPreamble = []byte

+ var SizeArrayWidth = defaultArrayWidth

+ var SizeReader = func(bytes []byte) int

+ var SizeWriter = func(size int) (bytes []byte)

+ var TCPTimeout = 10 * time.Second

+ type ConnectionInfo struct

+ HostName string

+ Port int32

+ Uri string

+ Websocket bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConnectionInfo) Descriptor() ([]byte, []int)

+ func (*ConnectionInfo) ProtoMessage()

+ func (m *ConnectionInfo) GetHostName() string

+ func (m *ConnectionInfo) GetPort() int32

+ func (m *ConnectionInfo) GetUri() string

+ func (m *ConnectionInfo) GetWebsocket() bool

+ func (m *ConnectionInfo) Reset()

+ func (m *ConnectionInfo) String() string

+ func (m *ConnectionInfo) XXX_DiscardUnknown()

+ func (m *ConnectionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectionInfo) XXX_Merge(src proto.Message)

+ func (m *ConnectionInfo) XXX_Size() int

+ func (m *ConnectionInfo) XXX_Unmarshal(b []byte) error

+ type MDefinition struct

+ ConnectionInfo *ConnectionInfo

+ SupportedMessageTypes []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MDefinition) Descriptor() ([]byte, []int)

+ func (*MDefinition) ProtoMessage()

+ func (m *MDefinition) GetConnectionInfo() *ConnectionInfo

+ func (m *MDefinition) GetSupportedMessageTypes() []string

+ func (m *MDefinition) Reset()

+ func (m *MDefinition) String() string

+ func (m *MDefinition) XXX_DiscardUnknown()

+ func (m *MDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MDefinition) XXX_Merge(src proto.Message)

+ func (m *MDefinition) XXX_Size() int

+ func (m *MDefinition) XXX_Unmarshal(b []byte) error

+ type Nan0 struct

+ ServiceName string

+ func (n *Nan0) Close()

+ func (n Nan0) Equals(other NanoServiceWrapper) bool

+ func (n Nan0) GetReceiver() <-chan interface{}

+ func (n Nan0) GetSender() chan<- interface{}

+ func (n Nan0) GetServiceName() string

+ func (n Nan0) IsClosed() bool

+ type NanoBuilder struct

+ func (sec *NanoBuilder) AddMessageIdentities(messageIdents ...proto.Message) *NanoBuilder

+ func (sec *NanoBuilder) AddMessageIdentity(messageIdent proto.Message) *NanoBuilder

+ func (sec *NanoBuilder) AddOrigins(origin ...string) *NanoBuilder

+ func (sec *NanoBuilder) AppendOrigins(origin ...*url.URL)

+ func (sec *NanoBuilder) Build() (nan0 NanoServiceWrapper, err error)

+ func (sec *NanoBuilder) BuildNan0DNS(ctx context.Context) ...

+ func (sec *NanoBuilder) BuildServer(handler func(net.Listener, *NanoBuilder)) (*NanoServer, error)

+ func (sec *NanoBuilder) Insecure() *NanoBuilder

+ func (sec *NanoBuilder) ReceiveBuffer(receiveBuffer int) *NanoBuilder

+ func (sec *NanoBuilder) Secure(config TLSConfig) *NanoBuilder

+ func (sec *NanoBuilder) SendBuffer(sendBuffer int) *NanoBuilder

+ func (sec *NanoBuilder) ServiceDiscovery() *NanoBuilder

+ func (sec *NanoBuilder) ToggleWriteDeadline(writeDeadline bool) *NanoBuilder

+ func (sec *NanoBuilder) Websocket() *NanoBuilder

+ func (sec NanoBuilder) WrapConnection(connection interface{}) (nan0 NanoServiceWrapper, err error)

+ type NanoServer struct

+ func (server *NanoServer) AddConnection(conn NanoServiceWrapper)

+ func (server *NanoServer) GetAllConnections() []NanoServiceWrapper

+ func (server *NanoServer) GetConnections() <-chan NanoServiceWrapper

+ func (server *NanoServer) IsShutdown() bool

+ func (server *NanoServer) Shutdown()

+ func (server NanoServer) GetHost() string

+ func (server NanoServer) GetPort() int32

+ func (server NanoServer) GetServiceName() string

+ func (server NanoServer) GetServiceType() string

+ func (server NanoServer) GetStartTime() int64

+ type NanoServiceWrapper interface

+ Close func()

+ Equals func(NanoServiceWrapper) bool

+ GetReceiver func() <-chan interface{}

+ GetSender func() chan<- interface{}

+ GetServiceName func() string

+ IsClosed func() bool

+ type Server interface

+ AddConnection func(NanoServiceWrapper)

+ GetConnections func() <-chan NanoServiceWrapper

+ GetServiceName func() string

+ IsShutdown func() bool

+ Shutdown func()

+ type Service struct

+ Expired bool

+ HostName string

+ Port int32

+ ServiceName string

+ ServiceType string

+ StartTime int64

+ Uri string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service) Descriptor() ([]byte, []int)

+ func (*Service) ProtoMessage()

+ func (m *Service) GetExpired() bool

+ func (m *Service) GetHostName() string

+ func (m *Service) GetPort() int32

+ func (m *Service) GetServiceName() string

+ func (m *Service) GetServiceType() string

+ func (m *Service) GetStartTime() int64

+ func (m *Service) GetUri() string

+ func (m *Service) Reset()

+ func (m *Service) String() string

+ func (m *Service) XXX_DiscardUnknown()

+ func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service) XXX_Merge(src proto.Message)

+ func (m *Service) XXX_Size() int

+ func (m *Service) XXX_Unmarshal(b []byte) error

+ func (ns *Service) NewNanoBuilder() *NanoBuilder

+ func (ns Service) Equals(other Service) bool

+ func (ns Service) MdnsTag() string

+ type TLSConfig struct

+ CertFile string

+ KeyFile string

+ type WsNan0 struct

+ ServiceName string

+ func (n WsNan0) Close()

+ func (n WsNan0) Equals(other NanoServiceWrapper) bool

+ func (n WsNan0) GetReceiver() <-chan interface{}

+ func (n WsNan0) GetSender() chan<- interface{}

+ func (n WsNan0) GetServiceName() string

+ func (n WsNan0) IsClosed() bool

Other modules containing this package

github.com/yomiji/nan0

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL