server

Documentation

Index

• Constants
• type Server
  • func NewServer(nc *nats.Conn, cfg config.Config) *Server
  • func (s *Server) CreateDataProduct(m *nats.Msg)
  • func (s *Server) DeleteDataProduct(m *nats.Msg)
  • func (s *Server) InfoDataProduct(m *nats.Msg)
  • func (s *Server) ListDataProducts(m *nats.Msg)
  • func (s *Server) Start()
  • func (s *Server) UpdateDataProduct(m *nats.Msg)

Constants

const (
	StateDataProductSubjectPrefix  = "$RAINFOREST.DP.STATE."
	EventDataProductSubjectPrefix  = "$RAINFOREST.DP.EVENT."
	SourceDataProductSubjectPrefix = "$RAINFOREST.DP.SOURCE."

	StateDataProductPrefix  = "STATE_"
	EventDataProductPrefix  = "EVENT_"
	SourceDataProductPrefix = "SOURCE_"
)

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(nc *nats.Conn, cfg config.Config) *Server

func (*Server) CreateDataProduct

func (s *Server) CreateDataProduct(m *nats.Msg)

func (*Server) DeleteDataProduct

func (s *Server) DeleteDataProduct(m *nats.Msg)

TODO:

func (*Server) InfoDataProduct

func (s *Server) InfoDataProduct(m *nats.Msg)

TODO:

func (*Server) ListDataProducts

func (s *Server) ListDataProducts(m *nats.Msg)

TODO

func (*Server) Start

func (s *Server) Start()

func (*Server) UpdateDataProduct

func (s *Server) UpdateDataProduct(m *nats.Msg)

TODO: