p2p

type Command interface {
	Send(ctx context.Context, body map[string]interface{}) (response.Response, error)
	SendTo(ctx context.Context, cid cid.Cid, body map[string]interface{}) (response.Response, error)
}

type CommandService interface {
	Close()
}

type MatchDefinition struct {
	Project     string
	Application string
	Protocol    string
	Command     string
}

type Service interface {
	components.ServiceComponent
	Stream(ctx context.Context, projectID, applicationID, protocol string) (Stream, error)
	StartStream(name, protocol string, handler StreamHandler) (CommandService, error)
	LookupService(matcher *MatchDefinition) (config *structureSpec.Service, application string, err error)
	Discover(ctx context.Context, max int, timeout time.Duration) ([]peer.AddrInfo, error)
}

type ServiceResource interface {
	Application() string
	Config() *structureSpec.Service
	Context() context.Context
	Project() (cid.Cid, error)
	SmartOps(smartOps []string) (uint32, error)
	Type() uint32
}

type Serviceable interface {
	components.Serviceable
	Handle(data *command.Command) (time.Time, response.Response, error)
	Name() string
	Close()
	Config() *structureSpec.Function
}

type Stream interface {
	Listen() (protocol string, err error)
	Command(command string) (Command, error)
	Close()
}

type StreamHandler func(cmd *command.Command) (resp response.Response, err error)