flowtest

Documentation

Index

• func NewPeerAuthorizer(names []string) flow.PeerAuthorizer
• func Pipe(t *testing.T, 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, map[string]security.Discharge, error)

Functions

func NewPeerAuthorizer

func NewPeerAuthorizer(names []string) flow.PeerAuthorizer

func Pipe

func Pipe(t *testing.T, 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 map[string]security.Discharge,
) ([]string, []security.RejectedBlessing, error)

func (AllowAllPeersAuthorizer) BlessingsForPeer

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