middleware

package
v1.14.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2023 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Repo = map[string]messages.AOR{}

Functions

func VerifyAdaptation added in v1.14.8 

func VerifyAdaptation(msgFromServer []byte, sizeOfMsgSize []byte, conn net.Conn, send func(sizeOfMsgSize []byte, msgToServer []byte, conn net.Conn) error) (err error)

func VerifyAdaptationQUIC added in v1.14.8 

func VerifyAdaptationQUIC(msgFromServer []byte, sizeOfMsgSize []byte, stream quic.Stream, send func(sizeOfMsgSize []byte, msgToServer []byte, stream quic.Stream) error) (err error)

func VerifyProtocolAdaptation added in v1.14.9 

func VerifyProtocolAdaptation(msgFromServer []byte, protocol generic.Protocol) (err error)

Types

type CRHHTTP added in v1.14.9 

type CRHHTTP struct{}

@Type: CRHHTTP @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHHTTP) I_Process added in v1.14.9 

func (c CRHHTTP) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHHTTP2 added in v1.14.9 

type CRHHTTP2 struct{}

@Type: CRHHTTP2 @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHHTTP2) I_Process added in v1.14.9 

func (c CRHHTTP2) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHHTTPS added in v1.14.9 

type CRHHTTPS struct{}

@Type: CRHHTTPS @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHHTTPS) I_Process added in v1.14.9 

func (c CRHHTTPS) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHQUIC added in v1.14.7 

type CRHQUIC struct {
}

@Type: CRHQUIC @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHQUIC) I_Process added in v1.14.7 

func (c CRHQUIC) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHRPC added in v1.14.8 

type CRHRPC struct{}

@Type: CRHRPC @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHRPC) I_Process added in v1.14.8 

func (c CRHRPC) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHTCP 

type CRHTCP struct{}

@Type: CRHTCP @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHTCP) I_Process 

func (c CRHTCP) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHTLS 

type CRHTLS struct{}

@Type: CRHTLS @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHTLS) I_Process 

func (c CRHTLS) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type CRHUDP 

type CRHUDP struct{}

@Type: CRHUDP @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (CRHUDP) I_Process 

func (c CRHUDP) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type Gobmarshaller 

type Gobmarshaller struct{}

@Type: Gobmarshaller @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (Gobmarshaller) I_Process 

func (g Gobmarshaller) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Gobmarshaller) Marshall 

func (Gobmarshaller) Marshall(m interface{}) []byte

func (Gobmarshaller) Unmarshall 

func (Gobmarshaller) Unmarshall(m []byte) interface{}

type Jsonmarshaller 

type Jsonmarshaller struct{}

@Type: Jsonmarshaller @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (Jsonmarshaller) I_Process 

func (j Jsonmarshaller) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Jsonmarshaller) Marshall 

func (Jsonmarshaller) Marshall(m miop.MiopPacket) []byte

func (Jsonmarshaller) Unmarshall 

func (Jsonmarshaller) Unmarshall(m []byte) miop.MiopPacket

type Naming 

type Naming struct{}

type Naminginvoker 

type Naminginvoker struct{}

@Type: Naminginvoker @Behaviour: Behaviour = InvP.e1 -> I_Beforeunmarshalling -> InvR.e2 -> TerR.e2 -> I_Beforeserver -> InvR.e3 -> TerR.e3 -> I_Beforemarshalling -> InvR.e2 -> TerR.e2 -> I_Beforesend -> TerP.e1 -> Behaviour

func (Naminginvoker) I_Beforemarshalling 

func (Naminginvoker) I_Beforemarshalling(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Naminginvoker) I_Beforesend 

func (Naminginvoker) I_Beforesend(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Naminginvoker) I_Beforeserver 

func (Naminginvoker) I_Beforeserver(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Naminginvoker) I_Beforeunmarshalling 

func (Naminginvoker) I_Beforeunmarshalling(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type Namingserver 

type Namingserver struct{}

@Type: Namingserver @Behaviour: Behaviour = InvP.e1 -> I_Process -> TerP.e1 -> Behaviour

func (Namingserver) I_Process 

func (s Namingserver) I_Process(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Namingserver) List 

func (Namingserver) List() []interface{}

func (Namingserver) Lookup 

func (Namingserver) Lookup(s string) (interface{}, bool)

func (Namingserver) Register 

func (Namingserver) Register(serviceName string, aor messages.AOR) bool

type Requestor 

type Requestor struct{}

@Type: Requestor @Behaviour: Behaviour = InvP.e1 -> I_Beforemarshalling -> InvR.e2 -> TerR.e2 -> I_Beforesend -> InvR.e3 -> TerR.e3 -> I_Beforeunmarshalling -> InvR.e2 -> TerR.e2 -> I_Beforeproxy -> TerP.e1 -> Behaviour

func (Requestor) I_Beforemarshalling 

func (Requestor) I_Beforemarshalling(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Requestor) I_Beforeproxy 

func (Requestor) I_Beforeproxy(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Requestor) I_Beforesend 

func (Requestor) I_Beforesend(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (Requestor) I_Beforeunmarshalling 

func (Requestor) I_Beforeunmarshalling(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHHTTP added in v1.14.9 

type SRHHTTP struct {
}

@Type: SRHHTTP @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHHTTP) I_Accept added in v1.14.9 

func (s SRHHTTP) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTP) I_Receive added in v1.14.9 

func (s SRHHTTP) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTP) I_Send added in v1.14.9 

func (s SRHHTTP) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHHTTP2 added in v1.14.9 

type SRHHTTP2 struct {
}

@Type: SRHHTTP2 @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHHTTP2) I_Accept added in v1.14.9 

func (s SRHHTTP2) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTP2) I_Receive added in v1.14.9 

func (s SRHHTTP2) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTP2) I_Send added in v1.14.9 

func (s SRHHTTP2) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHHTTPS added in v1.14.9 

type SRHHTTPS struct {
}

@Type: SRHHTTPS @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHHTTPS) I_Accept added in v1.14.9 

func (s SRHHTTPS) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTPS) I_Receive added in v1.14.9 

func (s SRHHTTPS) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHHTTPS) I_Send added in v1.14.9 

func (s SRHHTTPS) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHQUIC added in v1.14.7 

type SRHQUIC struct {
}

@Type: SRHQUIC @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHQUIC) I_Accept added in v1.14.7 

func (s SRHQUIC) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHQUIC) I_Receive added in v1.14.7 

func (s SRHQUIC) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHQUIC) I_Send added in v1.14.7 

func (e SRHQUIC) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHRPC added in v1.14.8 

type SRHRPC struct {
}

@Type: SRHRPC @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHRPC) I_Accept added in v1.14.8 

func (s SRHRPC) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHRPC) I_Receive added in v1.14.8 

func (s SRHRPC) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHRPC) I_Send added in v1.14.8 

func (s SRHRPC) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHTCP 

type SRHTCP struct{}

@Type: SRHTCP @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHTCP) I_Accept 

func (s SRHTCP) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHTCP) I_Receive 

func (s SRHTCP) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHTCP) I_Send 

func (s SRHTCP) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHTLS 

type SRHTLS struct{}

@Type: SRHTLS @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHTLS) I_Accept 

func (s SRHTLS) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHTLS) I_Receive 

func (s SRHTLS) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHTLS) I_Send 

func (s SRHTLS) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

type SRHUDP 

type SRHUDP struct{}

@Type: SRHUDP @Behaviour: Behaviour = I_Accept -> I_Receive -> InvR.e1 -> TerR.e1 -> I_Send -> Behaviour

func (SRHUDP) I_Accept 

func (s SRHUDP) I_Accept(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHUDP) I_Receive 

func (s SRHUDP) I_Receive(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

func (SRHUDP) I_Send 

func (s SRHUDP) I_Send(id string, msg *messages.SAMessage, info *interface{}, reset *bool)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.