forward

Documentation

Index

• type Forward
  • func Default() *Forward
  • func (f *Forward) Del(id int64)
  • func (f *Forward) Forward(str string, c *gin.Context)
  • func (f *Forward) Get(c *gin.Context, str string) (ctx context.Context, cc *grpc.ClientConn, e error)
  • func (f *Forward) Put(id int64, cc *grpc.ClientConn, gateway *runtime.ServeMux)
  • func (f *Forward) Subscribe(ctx context.Context) (s *Subscription)
  • func (f *Forward) Unsubscribe(s *Subscription) (exists bool)
• type State
• type Subscription
  • func (s *Subscription) Change(targets []int64)
  • func (s *Subscription) Get() (items []State, e error)

Types

type Forward

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

func Default

func Default() *Forward

func (*Forward) Del

func (f *Forward) Del(id int64)

func (*Forward) Forward

func (f *Forward) Forward(str string, c *gin.Context)

func (*Forward) Get

func (f *Forward) Get(c *gin.Context, str string) (ctx context.Context, cc *grpc.ClientConn, e error)

func (*Forward) Put

func (f *Forward) Put(id int64, cc *grpc.ClientConn, gateway *runtime.ServeMux)

func (*Forward) Subscribe

func (f *Forward) Subscribe(ctx context.Context) (s *Subscription)

func (*Forward) Unsubscribe

func (f *Forward) Unsubscribe(s *Subscription) (exists bool)

type State

type State struct {
	ID    int64
	Ready bool
}

type Subscription

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

func (*Subscription) Change

func (s *Subscription) Change(targets []int64)

func (*Subscription) Get

func (s *Subscription) Get() (items []State, e error)