flowtest

Documentation

Index

• func NewPeerAuthorizer(names []string) flow.PeerAuthorizer
• func NewPipe(ctx *context.T, network, address string) (dialed, accepted flow.Conn, err error)
• func Pipe(t testing.TB, ctx *context.T, network, address string) (dialed, accepted flow.Conn)
• type AllowAllPeersAuthorizer
  • func (AllowAllPeersAuthorizer) AuthorizePeer(ctx *context.T, localEndpoint, remoteEndpoint naming.Endpoint, ...) ([]string, []security.RejectedBlessing, error)
  • func (AllowAllPeersAuthorizer) BlessingsForPeer(ctx *context.T, _ []string) (security.Blessings, security.Discharges, error)

Functions

func NewPeerAuthorizer

func NewPeerAuthorizer(names []string) flow.PeerAuthorizer

func NewPipe

func NewPipe(ctx *context.T, network, address string) (dialed, accepted flow.Conn, err error)

NewPipe returns a connection pair dialed on against a listener using the given network and address.

func Pipe

func Pipe(t testing.TB, ctx *context.T, network, address string) (dialed, accepted flow.Conn)

Pipe returns a connection pair dialed on against a listener using the given network and address.

Types

type AllowAllPeersAuthorizer

type AllowAllPeersAuthorizer struct{}

func (AllowAllPeersAuthorizer) AuthorizePeer

func (AllowAllPeersAuthorizer) AuthorizePeer(
	ctx *context.T,
	localEndpoint, remoteEndpoint naming.Endpoint,
	remoteBlessings security.Blessings,
	remoteDischarges security.Discharges,
) ([]string, []security.RejectedBlessing, error)

func (AllowAllPeersAuthorizer) BlessingsForPeer

func (AllowAllPeersAuthorizer) BlessingsForPeer(ctx *context.T, _ []string) (security.Blessings, security.Discharges, error)