grpctunnel

type Data struct {
	Tag   int32  `protobuf:"varint,1,opt,name=tag,proto3" json:"tag,omitempty"`     // Tag associated with the initial TCP stream setup.
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`    // Bytes received from client connection.
	Close bool   `protobuf:"varint,3,opt,name=close,proto3" json:"close,omitempty"` // Connection has reached EOF.
	// contains filtered or unexported fields
}

type RegisterOp struct {

	// Types that are assignable to Registration:
	//	*RegisterOp_Target
	//	*RegisterOp_Session
	//	*RegisterOp_Subscription
	Registration isRegisterOp_Registration `protobuf_oneof:"Registration"`
	// contains filtered or unexported fields
}

type RegisterOp_Session struct {
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3,oneof"`
}

type RegisterOp_Subscription struct {
	Subscription *Subscription `protobuf:"bytes,3,opt,name=subscription,proto3,oneof"`
}

type RegisterOp_Target struct {
	Target *Target `protobuf:"bytes,1,opt,name=target,proto3,oneof"`
}

type Session struct {

	// The tag associated with the initial TCP stream setup.
	Tag int32 `protobuf:"varint,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// Used to ack the connection tag.
	Accept bool `protobuf:"varint,2,opt,name=accept,proto3" json:"accept,omitempty"`
	// Target identifies which handler to use for a tunnel stream.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// String value of the corresponding TargetType for a standard protocol.
	// A non-enumerated protocol is supported so long as both tunnel client and
	// server are in agreement on a particular value.
	TargetType string `protobuf:"bytes,4,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	// Error allows the register stream to return an error without breaking the
	// stream.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Subscription struct {
	Op Subscription_SubscriptionOp `protobuf:"varint,1,opt,name=op,proto3,enum=grpctunnel.Subscription_SubscriptionOp" json:"op,omitempty"`
	// Used to ack the registration of (un)subscription.
	Accept bool `protobuf:"varint,2,opt,name=accept,proto3" json:"accept,omitempty"`
	// String value of the corresponding TargetType for a standard protocol.
	// Used to filter targets for subscription. If empty, it will subscribe all.
	TargetType string `protobuf:"bytes,3,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	Error      string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Subscription_SubscriptionOp int32

type Target struct {
	Op Target_TargetOp `protobuf:"varint,1,opt,name=op,proto3,enum=grpctunnel.Target_TargetOp" json:"op,omitempty"`
	// Used to ack the registration of target and target_type.
	Accept bool `protobuf:"varint,2,opt,name=accept,proto3" json:"accept,omitempty"`
	// Target identifies which handler to use for a tunnel stream.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// String value of the corresponding TargetType for a standard protocol.
	// A non-enumerated protocol is supported so long as both tunnel client and
	// server are in agreement on a particular value.
	TargetType string `protobuf:"bytes,4,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	Error      string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type TargetType int32

type Target_TargetOp int32

type TunnelClient interface {
	// Register is used to register targets reachable via either the client
	// or server and request new Tunnel RPC invocations.
	Register(ctx context.Context, opts ...grpc.CallOption) (Tunnel_RegisterClient, error)
	// Tunnel allows the tunnel client and server to create a bidirectional stream
	// in which data can be forwarded.
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (Tunnel_TunnelClient, error)
}

type TunnelServer interface {
	// Register is used to register targets reachable via either the client
	// or server and request new Tunnel RPC invocations.
	Register(Tunnel_RegisterServer) error
	// Tunnel allows the tunnel client and server to create a bidirectional stream
	// in which data can be forwarded.
	Tunnel(Tunnel_TunnelServer) error
	// contains filtered or unexported methods
}

type Tunnel_RegisterClient interface {
	Send(*RegisterOp) error
	Recv() (*RegisterOp, error)
	grpc.ClientStream
}

type Tunnel_RegisterServer interface {
	Send(*RegisterOp) error
	Recv() (*RegisterOp, error)
	grpc.ServerStream
}

type Tunnel_TunnelClient interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ClientStream
}

type Tunnel_TunnelServer interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ServerStream
}

type UnimplementedTunnelServer struct {
}

type UnsafeTunnelServer interface {
	// contains filtered or unexported methods
}